Mcp Airflow Postgres について
Airflow の PostgreSQL データベースに直接アクセスするための MCP サーバーです。失敗した DAG 実行の照会とカスタム SQL クエリの実行により、Airflow ユーザーが診断できます。
主な機能
- 01失敗した DAG 実行を照会
- 02SQL クエリを実行
- 03PostgreSQL データベース接続
- 04時間範囲フィルタリング
活用シーン
- 01Airflow ワークフロー障害を診断
- 02データベース内の DAG 実行記録を分析
- 03Airflow アプリケーションをデバッグ
MCP 対応
Airflow データベースを照会・管理するツールを公開する MCP サーバーとして機能し、LLM クライアントが DAG 実行とカスタム SQL を操作できます。
詳細
MCP Airflow Database
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.yaml ファイルで設定されている Smithery で直接使用できます。サーバーを起動する際に必ず DATABASE_URL 設定を提供してください。
利用可能なツール
failed_runs: 指定された期間内の失敗した Airflow DAG 実行をクエリします。query: Airflow データベースに対して SQL クエリを直接実行します。
ライセンス
[Your License]
コメント
Markdown 対応
AI アプリケーションが外部のツールやデータソースに統一的な方法で接続するためのオープンなプロトコルです。クライアントはモデルとの対話を担い、MCP サーバーはツール・リソース・プロンプトテンプレートを提供します。標準メッセージでやり取りするため、1 つのサーバーを複数のクライアントで再利用できます。