关于 Mcp Airflow Postgres
这是一个 MCP 服务，用于直接操作 Airflow 的 PostgreSQL 数据库。支持查询失败的 DAG 运行和执行任意 SQL 查询，帮助 Airflow 用户诊断和管理工作流。
主要功能
- 01查询失败的 DAG 运行
- 02执行 SQL 查询
- 03PostgreSQL 数据库连接
- 04时间范围过滤
适用场景
- 01诊断 Airflow 工作流失败
- 02分析数据库中的 DAG 运行记录
- 03调试 Airflow 应用
MCP 相关
作为 MCP 服务，向客户端暴露与 Airflow 数据库交互的工具，允许 Agent 直接查询和管理数据库内容。
详细介绍
MCP Airflow 数据库
用于与 Airflow 数据库交互的 Model Context Protocol (MCP) 服务。
使用 Poetry 设置
前置要求
- Python 3.8 或更高版本
- 已在系统上安装 Poetry
安装
-
克隆此仓库：
git clone <your-repository-url> cd mcp-airflow-db -
使用 Poetry 安装依赖：
poetry install -
配置你的环境： 创建一个
.env文件，包含你的数据库连接字符串：DATABASE_URL=postgresql://airflow:airflow123@localhost:5432/airflow
运行 MCP 服务
使用 Poetry 运行服务：
poetry run python src/server.py
或先激活 Poetry 环境：
poetry shell
python src/server.py
与 Smithery 结合使用
该 MCP 可直接与 Smithery 一起使用，如 smithery.yaml 文件中的配置所示。启动服务时，请确保提供 DATABASE_URL 配置。
可用工具
failed_runs：查询指定时间段内失败的 Airflow DAG 运行。query：直接对 Airflow 数据库执行 SQL 查询。
许可证
[你的许可证]
评论
支持 Markdown
一个开放协议，规定了 AI 应用如何以统一方式连接外部工具与数据源。客户端负责与模型对话，MCP 服务负责提供工具、资源和提示模板，两者通过标准消息通信，同一个服务可以被不同客户端复用。