Airflow MCP 服务器
Description
# Airflow MCP 服务器 ## 项目概述 本项目是一个与 Apache Airflow 集成的 Model Context Protocol (MCP) 服务器，提供多种工具来管理和监控 Airflow 的 DAG 运行。它支持触发 DAG、获取 DAG 状态、回填数据、获取日志等操作。 ## 功能特性 - **触发 DAG (`trigger-dag`)**: 触发指定 DAG 的运行。 - **启用 DAG (`enable-dag`)**: 启用指定的 DAG。 - **获取每日报告 (`get-daily-report`)**…
About
# Airflow MCP 服务器 ## 项目概述 本项目是一个与 Apache Airflow 集成的 Model Context Protocol (MCP) 服务器，提供多种工具来管理和监控 Airflow 的 DAG 运行。它支持触发 DAG、获取 DAG 状态、回填数据、获取日志等操作。 ## 功能特性 - **触发 DAG (`trigger-dag`)**: 触发指定 DAG 的运行。 - **启用 DAG (`enable-dag`)**: 启用指定的 DAG。 - **获取每日报告 (`get-daily-report`)**: 获取指定时间范围内的所有 DAG 运行的汇总报告。 - **列出所有 DAG…
Details
- Author
- treerootboy
- Downloads
- 236
- Categories
- Search
Jump to
- 触发指定 DAG（trigger-dag）
- 启用/禁用指定 DAG（enable-dag）
- 获取每日 DAG 运行汇总报告（get-daily-report）
- 列出所有可用 DAG（list-dags）
- 批量获取 DAG 运行记录（list-dag-runs）
- 获取特定 DAG 运行状态（get-dag-status）
- 获取 DAG 运行日志（get-dag-logs）
- 回填指定日期范围的 DAG 数据（backfill-dag）
Setting up with Highlight
This MCP is not yet compatible with Highlight’s one-click setup. However, you can still use it with Highlight by following these steps:
- Download and install Highlight from highlightai.com/download
- Navigate to the plugins tab and select "Add Custom Plugin"
-
Configure the plugin with the settings below
Plugin Name
Airflow MCP 服务器Command (node, npx, python, etc.)Please refer to the README for specific instructions on how to obtain API keys or other required environment variables.
- Enable "Start Automatically" if you want the plugin to start when Highlight launches
From the repository
通过配置 MCP 客户端（如 Claude），在 mcpServers 中添加 airflow 条目，指定命令 uvx 和参数 airflow-mcp，并设置环境变量 AIRFLOW_API_BASE、AIRFLOW_USERNAME 和 AIRFLOW_PASSWORD。也可以使用 uv run 方式在本地开发。
Claude Desktop / Cursor
Paste into your MCP client config file to install this server.
{
"mcpServers": {
"airflow mcp \u670d\u52a1\u5668": {
"airflow-mcp": {
"command": "docker",
"args": [
"compose",
"up",
"-d"
]
}
}
}
}McpServers
{
"airflow-mcp": {
"command": "docker",
"args": [
"compose",
"up",
"-d"
]
}
}Airflow MCP 服务器
项目概述
本项目是一个与 Apache Airflow 集成的 Model Context Protocol (MCP) 服务器，提供多种工具来管理和监控 Airflow 的 DAG 运行。它支持触发 DAG、获取 DAG 状态、回填数据、获取日志等操作。功能特性
- 触发 DAG (trigger-dag): 触发指定 DAG 的运行。
- 启用 DAG (enable-dag): 启用指定的 DAG。
- 获取每日报告 (get-daily-report): 获取指定时间范围内的所有 DAG 运行的汇总报告。
- 列出所有 DAG (list-dags): 列出所有可用的 DAG。
- 批量获取 DAG 运行记录 (list-dag-runs): 批量获取 DAG 的运行记录。
- 获取 DAG 运行状态 (get-dag-status): 获取特定 DAG 的运行状态。
- 获取 DAG 日志 (get-dag-logs): 获取 DAG 运行的日志。
- 回填 DAG (backfill-dag): 回填指定日期范围内的 DAG 数据。
使用
{
"mcpServers": {
"airflow": {
"command": "uvx",
"args": [
"airflow-mcp"
],
"env": {
"AIRFLOW_API_BASE": "http://localhost:8000/api/v1",
"AIRFLOW_USERNAME": "admin",
"AIRFLOW_PASSWORD": "admin"
}
}
}
}
开发
1. uv sync 2. 修改 mcp_config.json, 加入 airflow 配置{
"mcpServers": {
"airflow": {
"command": "uv",
"args": [
"--directory",
"/path/to/airflow-mcp",
"run",
"airflow_mcp.py"
],
"env": {
"AIRFLOW_API_BASE": "http://localhost:8000/api/v1",
"AIRFLOW_USERNAME": "admin",
"AIRFLOW_PASSWORD": "admin"
}
}
}
}
mkdir ~/airflow-docker
cd ~/airflow-docker
curl -LfO 'https://airflow.apache.org/docs/apache-airflow/2.8.3/docker-compose.yaml'
cat << EOF > .env
AIRFLOW_UID=$(id -u)
AIRFLOW__CORE__LOAD_EXAMPLES=false
AIRFLOW__CORE__EXECUTOR=SequentialExecutor
EOF
docker compose up -d
贡献
欢迎贡献代码！请提交 Pull Request 并确保遵循项目的编码规范。许可
本项目采用 MIT 许可协议。Sign in to leave a review
Use Google, GitHub, or an email account so ratings stay tied to real people.
No reviews posted yet.
