简介

为 MCP 客户端与 Apache Airflow 的 REST API 交互提供了一种标准化的方式，支持 DAG 管理和监控 Airflow 系统健康状态等操作。

简介

为 MCP 客户端与 Apache Airflow 的 REST API 交互提供了一种标准化的方式，支持 DAG 管理和监控 Airflow 系统健康状态等操作。

mcp-server-apache-airflow

这是一个为Apache Airflow实现的模型上下文协议（MCP）服务器，能够与MCP客户端无缝集成。该项目提供了一种通过模型上下文协议与Apache Airflow交互的标准方法。

关于

本项目实现了一个模型上下文协议服务器，该服务器封装了Apache Airflow的REST API，允许MCP客户端以标准化方式与Airflow进行交互。它使用官方的Apache Airflow客户端库来确保兼容性和可维护性。

功能实现状态

设置

依赖项

此项目依赖于官方的 Apache Airflow 客户端库 (apache-airflow-client)。当你安装此包时，它将被自动安装。

环境变量

设置以下环境变量：

AIRFLOW_HOST=<your-airflow-host>
AIRFLOW_USERNAME=<your-airflow-username>
AIRFLOW_PASSWORD=<your-airflow-password>

与 Claude Desktop 一起使用

在你的 claude_desktop_config.json 中添加：

{
  "mcpServers": {
    "mcp-server-apache-airflow": {
      "command": "uvx",
      "args": ["mcp-server-apache-airflow"],
      "env": {
        "AIRFLOW_HOST": "https://your-airflow-host",
        "AIRFLOW_USERNAME": "your-username",
        "AIRFLOW_PASSWORD": "your-password"
      }
    }
  }
}

使用 uv 的替代配置：

{
  "mcpServers": {
    "mcp-server-apache-airflow": {
      "command": "uv",
      "args": [
        "--directory",
        "/path/to/mcp-server-apache-airflow",
        "run",
        "mcp-server-apache-airflow"
      ],
      "env": {
        "AIRFLOW_HOST": "https://your-airflow-host",
        "AIRFLOW_USERNAME": "your-username",
        "AIRFLOW_PASSWORD": "your-password"
      }
    }
  }
}

将 /path/to/mcp-server-apache-airflow 替换为你克隆仓库的实际路径。

选择 API 组

你可以通过设置 --apis 标志来选择你想要使用的 API 组。

uv run mcp-server-apache-airflow --apis "dag,dagrun"

默认情况下会使用所有 API。

允许的值包括：

• config
• connections
• dag
• dagrun
• dagstats
• dataset
• eventlog
• importerror
• monitoring
• plugin
• pool
• provider
• taskinstance
• variable
• xcom

手动执行

你也可以手动运行服务器：

make run

make run 接受以下选项：

选项：

• --port: 监听 SSE 的端口（默认：8000）
• --transport: 传输类型（stdio/sse，默认：stdio）

或者，你可以直接运行 sse 服务器，它接受相同的参数：

make run-sse

通过 Smithery 安装

要通过 Smithery 自动为 Claude Desktop 安装 Apache Airflow MCP Server：

npx -y @smithery/cli install @yangkyeongmo/mcp-server-apache-airflow --client claude

贡献

欢迎贡献！请随时提交 Pull Request。

许可证

MIT 许可证

工具列表

• list_dags: Lists all DAGs in the Airflow instance

• get_dag: Get details of a specific DAG

• pause_dag: Pause a DAG

• unpause_dag: Unpause a DAG

• trigger_dag: Trigger a DAG run

• get_dag_runs: Get DAG runs for a specific DAG

• get_dag_tasks: Get tasks for a specific DAG

• get_task_instance: Get details of a specific task instance

• list_task_instances: List all task instances for a specific DAG run

• get_import_error: Get details of a specific import error

• list_import_errors: List all import errors

• get_health: Get the health status of the Airflow instance

• get_version: Get the version information of the Airflow instance

服务配置

[{'mcpServers': {'mcp-server-apache-airflow': {'args': ['mcp-server-apache-airflow'], 'command': 'uvx', 'env': {'AIRFLOW_HOST': 'https://your-airflow-host', 'AIRFLOW_PASSWORD': 'your-password', 'AIRFLOW_USERNAME': 'your-username'}}}}, {'mcpServers': {'mcp-server-apache-airflow': {'args': ['--directory', '/path/to/mcp-server-apache-airflow', 'run', 'mcp-server-apache-airflow'], 'command': 'uv', 'env': {'AIRFLOW_HOST': 'https://your-airflow-host', 'AIRFLOW_PASSWORD': 'your-password', 'AIRFLOW_USERNAME': 'your-username'}}}}]

来源

• 来源：github
• 链接：https://github.com/yangkyeongmo/mcp-server-apache-airflow