用途
mcp-airflow 是一个 MCP 服务器,用于通过 Apache Airflow 的 REST API 管理 Airflow。它将 Airflow REST API 操作暴露为工具,供 MCP 客户端调用。
主要能力
- 列出 DAG
- 检查运行(runs)和任务实例(task instances)
- 触发运行(trigger runs)
- 检查失败的 DAG
- 检查 scheduler 健康状态
使用方式
该项目基于 MCP Python SDK 的 FastMCP API 构建,是一个开源包。维护者不通过此仓库运营公共托管的 Airflow 端点。
认证方案
客户端会根据 Airflow 版本自动选择认证方案:
- Airflow 3.x(JWT):使用 AIRFLOW_USERNAME / AIRFLOW_PASSWORD 从 /auth/token 端点获取 JWT 令牌,以 Bearer 令牌发送,并自动刷新。需将 AIRFLOW_BASE_URL 指向 /api/v2。
- Airflow 2.x(基本认证):若 JWT 流程不可用,客户端回退到使用相同用户名/密码的 HTTP 基本认证。需将 AIRFLOW_BASE_URL 指向 /api/v1。
配置
设置环境变量(或从 .env.example 创建 .env 文件)。
运行
可运行服务器,或将其添加到 MCP 客户端配置(例如 Claude Desktop)。
适用场景
适用于需要通过 MCP 客户端(如 Claude Desktop)远程管理 Apache Airflow 工作流的开发或运维场景。
限制
文档未提供具体的环境变量名称、运行命令、MCP 客户端配置示例、支持的 Airflow 版本范围等详细信息。更多关于支持的流程、架构、操作指南和安全边界的内容,请参阅 docs/index.md。路线图和交付状态位于 GitHub Issues 和拉取请求中。