mcpField
M
Mcp Airflow Postgres

Mcp Airflow Postgres

github.com/gavinHuangその他071 週間前に更新

Mcp Airflow Postgres について

Airflow の PostgreSQL データベースに直接アクセスするための MCP サーバーです。失敗した DAG 実行の照会とカスタム SQL クエリの実行により、Airflow ユーザーが診断できます。

主な機能

  1. 01失敗した DAG 実行を照会
  2. 02SQL クエリを実行
  3. 03PostgreSQL データベース接続
  4. 04時間範囲フィルタリング

活用シーン

  1. 01Airflow ワークフロー障害を診断
  2. 02データベース内の DAG 実行記録を分析
  3. 03Airflow アプリケーションをデバッグ

MCP 対応

Airflow データベースを照会・管理するツールを公開する MCP サーバーとして機能し、LLM クライアントが DAG 実行とカスタム SQL を操作できます。

詳細

MCP Airflow Database

Airflow データベースとやり取りするための Model Context Protocol (MCP) サーバーです。

Poetry でのセットアップ

前提条件
  • Python 3.8 以上
  • Poetry がシステムにインストールされていること
インストール
  1. このリポジトリをクローンします:

    git clone <your-repository-url>
    cd mcp-airflow-db
    
  2. Poetry で依存関係をインストールします:

    poetry install
    
  3. 環境を設定します: データベース接続文字列を含む .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]

コメント

MCP は初めてですか?

プロトコルの概要から最初のサーバーの導入まで、よくある疑問にまとめて答えます。

AI アプリケーションが外部のツールやデータソースに統一的な方法で接続するためのオープンなプロトコルです。クライアントはモデルとの対話を担い、MCP サーバーはツール・リソース・プロンプトテンプレートを提供します。標準メッセージでやり取りするため、1 つのサーバーを複数のクライアントで再利用できます。