MCP 服务器

airflow-mcp-server

好的，这是对提供的 GitHub 链接的翻译： **标题:** Airflow MCP Server **翻译:** Airflow MCP 服务器 (Airflow MCP 服务器) **解释:** * **Airflow:** Airflow (无需翻译，是 Apache Airflow 的简称) * **MCP:** MCP (无需翻译，通常指 Metadata Collection Platform，元数据收集平台) * **Server:** 服务器 (fú wù qì) 因此，整个标题可以翻译为： * **Airflow MCP 服务器** (最直接的翻译) * **Airflow 元数据收集平台服务器** (更详细的翻译，如果需要解释 MCP 的含义) 根据上下文，选择哪个翻译更合适。通常情况下，直接使用 "Airflow MCP 服务器" 即可。

Tools

get_version

get_connections

post_connection

get_connection

patch_connection

delete_connection

test_connection

get_dags

delete_dag

patch_dags

get_dag

patch_dag

post_clear_task_instances

set_task_instance_note

set_mapped_task_instance_note

get_task_instance_dependencies

get_mapped_task_instance_dependencies

post_set_task_instances_state

get_dag_runs

post_dag_run

get_dag_runs_batch

get_dag_run

delete_dag_run

update_dag_run_state

clear_dag_run

get_upstream_dataset_events

set_dag_run_note

get_dag_dataset_queued_event

delete_dag_dataset_queued_event

get_dag_dataset_queued_events

delete_dag_dataset_queued_events

reparse_dag_file

get_dataset_queued_events

delete_dataset_queued_events

get_event_logs

get_event_log

get_import_errors

get_import_error

get_pools

post_pool

get_pool

patch_pool

delete_pool

get_providers

get_task_instances

get_task_instance

patch_task_instance

get_mapped_task_instance

patch_mapped_task_instance

get_mapped_task_instances

get_task_instances_batch

get_task_instance_try_details

get_task_instance_tries

get_mapped_task_instance_tries

get_mapped_task_instance_try_details

get_variables

post_variables

get_variable

patch_variable

delete_variable

get_xcom_entries

get_xcom_entry

get_extra_links

get_log

get_dag_details

get_tasks

get_task

get_dag_stats

get_dag_source

get_dag_warnings

get_datasets

get_dataset

get_dataset_events

create_dataset_event

get_config

get_value

get_health

get_plugins

get_roles

post_role

get_role

patch_role

delete_role

get_permissions

get_users

post_user

get_user

patch_user

delete_user

README

airflow-mcp-server: 用于控制 Airflow 的 MCP 服务器

在 Glama 上查找

概述

一个模型上下文协议服务器，用于通过 Airflow API 控制 Airflow。

演示视频

https://github.com/user-attachments/assets/f3e60fff-8680-4dd9-b08e-fa7db655a705

设置

与 Claude Desktop 一起使用

{
  "mcpServers": {
    "airflow-mcp-server": {
      "command": "uvx",
      "args": [
        "airflow-mcp-server"
      ],
      "env": {
        "AIRFLOW_BASE_URL": "http://<host:port>/api/v1",
        // 可以使用 AUTH_TOKEN 进行基本身份验证
        "AUTH_TOKEN": "<base64_encoded_username_password>",
        // 或者使用 COOKIE 进行基于 Cookie 的身份验证
        "COOKIE": "<session_cookie>"
      }
    }
  }
}

运行模式

服务器支持两种运行模式：

安全模式 (--safe): 仅允许只读操作（GET 请求）。当您想阻止对 Airflow 实例的任何修改时，这非常有用。
非安全模式 (--unsafe): 允许包括修改在内的所有操作。这是默认模式。

以安全模式启动：

airflow-mcp-server --safe

显式以非安全模式启动（尽管这是默认设置）：

airflow-mcp-server --unsafe

注意事项

MCP 服务器需要设置环境变量：

AIRFLOW_BASE_URL: Airflow API 的基本 URL
AUTH_TOKEN: 用于基本身份验证的令牌 (这应该是 base64 编码的 username:password) (如果提供了 COOKIE，则为可选)
COOKIE: 用于身份验证的会话 Cookie (如果提供了 AUTH_TOKEN，则为可选)
OPENAPI_SPEC: OpenAPI 规范文件的路径 (可选) (默认为最新的稳定版本)