mcp气流
将Apache Airflow REST API操作作为工具公开的MCP服务器。建于 FastMCP.
安装
uv pip install -e "."发展：
uv pip install -e ".[dev]"
# or with dependency groups
uv sync --group dev配置
设置这些环境变量（或创建 .env 文件来自 .env.example):
| 变量 | 描述 | 示例 |
|---|---|---|
AIRFLOW_BASE_URL | 气流REST API基础URL | http://100.x.x.x:8080/api/v1 |
AIRFLOW_USERNAME | 基本身份验证用户名 | admin |
AIRFLOW_PASSWORD | 基本身份验证密码 |
用法
运行服务器：
mcp-airflow或者添加到您的MCP客户端配置中（例如，Claude Desktop）：
{
"mcpServers": {
"airflow": {
"command": "mcp-airflow",
"env": {
"AIRFLOW_BASE_URL": "http://100.x.x.x:8080/api/v1",
"AIRFLOW_USERNAME": "admin",
"AIRFLOW_PASSWORD": "your-password"
}
}
}
}工具
| 工具 | 说明 |
|---|---|
list_dags | 列出所有处于暂停/活动状态的DAGs |
get_dag_runs_today | 获取从今天开始的所有DAG运行状态 |
get_dag_run_status | 获取特定DAG的最新运行状态 |
trigger_dag_run | 触发手动DAG运行 |
get_task_instances | 获取特定DAG运行的任务实例 |
check_failed_dags | 检查过去24小时内是否出现故障的DAGs |
check_scheduler_health | 检查调度程序心跳和元数据库状态 |
测试
pytest