Airflow MCP Server 是一个面向 Airflow 3.x REST API(/api/v2)的 MCP 服务器,构建在 @us-all/mcp-toolkit 之上。它默认以只读方式工作,读取 DAG、运行记录、任务实例和日志尾部;触发 DAG(airflow-trigger-dag)和清除任务(airflow-clear-task)属于写入操作,需设置 AIRFLOW_ALLOW_WRITE=true 才会启用。
主要能力:提供 airflow 与 meta 类别下的 7 个工具,以及 2 个用于 DAG 分诊工作流的 MCP 提示词。其中包含 1 个聚合工具,可替代“先列出运行记录、再获取任务实例”的组合操作。另有 search-tools 工具用于自然语言发现工具。
使用方式:认证采用 JWT(SimpleAuthManager),需提供 AIRFLOW_USERNAME 和 AIRFLOW_PASSWORD,服务器会自动签发并刷新令牌;令牌在会话生命周期内缓存,并在过期前 1 分钟刷新。配置时只需传入主机基础地址,服务器内部会自动添加 /api/v2;若传入末尾带 /api/v1 或 /api/v2 的地址会被剥离。服务器使用 MCP stdio 通信,可接入 Claude Desktop、Cursor 或任何 MCP 客户端;设置 MCP_TRANSPORT=http 可启用 Streamable HTTP 传输(Bearer 认证,提供 /health 端点)。
适用场景:适合需要通过 MCP 客户端查看 Airflow DAG 健康状态、运行记录、任务实例与日志,并在受控条件下触发 DAG 或清除任务的运维与数据工程场景。若需要更深入的 dbt 集成(清单解析、运行结果历史、源新鲜度、逐列测试覆盖率、血缘遍历、自定义 DQ 结果表),可同时安装配套的 @us-all/dbt-mcp。
限制:已针对 Airflow 3.0–3.2 /api/v2 验证(以 3.2.1 为准)。v0.2+ 不支持 Airflow 2.x,因为 basic auth 和 /api/v1 已被移除;Airflow 2.x 部署需固定使用 @us-all/airflow-mcp@0.1.0。项目采用 MIT 许可证。