airflow-mcp-server
@us-all/airflow-mcp
Airflow MCP 服务器 — 读取 DAG、运行记录、任务实例、日志尾部；触发和清除（写入受限）。基于
@us-all/mcp-toolkit构建。
一个专注于 Airflow 稳定版 REST API 的 MCP。默认只读；airflow-trigger-dag 和 airflow-clear-task 受 AIRFLOW_ALLOW_WRITE=true 限制。
如需更深入的 dbt 集成（清单解析、运行结果历史、源新鲜度、每列测试覆盖率、血缘关系遍历、自定义数据质量结果表），请同时安装配套的 @us-all/dbt-mcp。
7 个
airflow+meta类别的工具2 个用于 DAG 分诊工作流的 MCP 提示词
1 个聚合工具，替代 list-runs → get-task-instances 的组合操作
安装
pnpm add -D @us-all/airflow-mcp运行
AIRFLOW_API_URL=http://airflow.example.com:8080/api/v1 \
AIRFLOW_USERNAME=admin AIRFLOW_PASSWORD=... \
npx @us-all/airflow-mcp该服务器使用 MCP stdio 通信；将其连接到 Claude Desktop / Cursor / 任何 MCP 客户端。设置 MCP_TRANSPORT=http 以启用可流式传输的 HTTP 传输（Bearer 认证，/health 端点）。
工具
airflow (6 + 1 个聚合工具)
工具 | 描述 |
| 列出带有标签/搜索过滤器的活跃 DAG |
| 单个 DAG 的近期运行记录（状态过滤，按最新排序） |
| 特定 DAG 运行的任务实例 |
| 获取单个任务实例日志的尾部（最后 N kB） |
| 触发新的运行（写入受限） |
| 清除特定任务实例 → 重新运行（写入受限） |
| 聚合 DAG 健康状况：成功率 + 平均持续时间 + 最后一次失败运行 + 失败任务 |
meta
search-tools — 自然语言工具发现。
提示词
提示词 | 使用场景 |
| “为什么 DAG X 失败了？” — 拉取运行记录、定位失败原因、导出日志、提出修复建议 |
| “扫描所有 DAG 的低成功率和卡住的运行记录” |
环境变量
环境变量 | 必需 | 说明 |
| 是 | Airflow REST API 基础地址，例如 |
| 否 | 基本认证用户名 |
| 否 | 基本认证密码（密钥） |
| 否 |
|
| 否 | 类别开关 |
测试过的架构
Airflow 稳定版 REST API (2.x)。Airflow 3.x 通过
/api/v1/稳定端点暴露了相同的接口，因此该服务器适用于 2.x 和 3.x 部署。
配套服务器
如需 dbt 工件解析、运行结果历史和数据质量结果表，请同时安装 @us-all/dbt-mcp。
构建
pnpm install
pnpm run build # tsc → dist/
pnpm test # vitest
pnpm run smoke # spawns dist/index.js, calls initialize + tools/list (set env first)许可证
MIT — 参见 LICENSE。
Maintenance
Resources
Unclaimed servers have limited discoverability.
Looking for Admin?
If you are the server author, to access and configure the admin panel.
Latest Blog Posts
MCP directory API
We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/us-all/airflow-mcp-server'
If you have feedback or need assistance with the MCP directory API, please join our Discord server