Airflow MCPサーバーとは？

Airflow MCPサーバーは、Model Context Protocol (MCP) に基づくツールで、Airflow APIを通じてAirflowインスタンスを制御および管理するために使用されます。実行モードに応じて、読み取りおよび書き込み操作を実行できます。

Airflow MCPサーバーの使い方は？

必要な環境変数を設定し、サーバーを起動するだけで使用を開始できます。必要に応じて、セキュリティモード（読み取り専用）または非セキュリティモード（読み書き）を選択できます。

適用シナリオ

Airflowタスクのリモート管理と自動スケジューリングが必要なユーザー、たとえば開発者、運用エンジニア、データアナリストに適しています。

主な機能

複数の認証方式をサポートTokenベースの基本認証とCookieベースのセッション認証をサポートします。

柔軟な権限制御セキュリティモードで読み取り専用操作に制限し、本番環境の安全性を確保します。

最新のAPIと互換性OpenAPI仕様ファイルを動的に解析し、Airflow APIのサポートを確保します。

多言語サポート英語と中国語のバイリンガルインターフェースを提供し、国際的なユーザーの使用を容易にします。

利点と制限

利点

Airflowタスクのリモート管理を簡素化

複数の認証方式をサポートし、柔軟性を向上

APIリクエストにリアルタイムで応答し、作業効率を向上

制限

事前に環境変数を設定する必要があり、初期設定の複雑さが増す

Airflow APIの安定性に依存する

使い方

環境変数のインストールと設定

AIRFLOW_BASE_URL、AUTH_TOKENまたはCOOKIEなどの必要な環境変数を設定します。

サーバーを起動する

コマンドを使用してサーバーを起動します。デフォルトは非セキュリティモードです。

接続を検証する

テストコマンドを使用してAirflowインスタンスへの接続が成功したかどうかを確認します。

使用例

ケース1：DAGリストを取得するAirflow MCPサーバーを使用して、現在実行中のDAGリストを取得します。

ケース2：DAGの実行をトリガーするMCPサーバーを通じて特定のDAGの実行をトリガーします。

よくある質問

セキュリティモードに切り替える方法は？

ページ制限をカスタマイズできますか？

AUTH_TOKENの設定を忘れた場合、どうすればいいですか？

🚀 Airflow MCPサーバー

このサーバーは、Airflow APIを通じてAirflowを制御するためのModel Context Protocol（MCP）サーバーです。

🚀 クイックスタート

このサーバーを使うことで、Airflow APIを通じてAirflowを制御できます。

🎥 デモビデオ

https://github.com/user-attachments/assets/f3e60fff-8680-4dd9-b08e-fa7db655a705

📦 インストール

Claude Desktopの設定方法

{
  "mcpServers": {
    "airflow-mcp-server": {
      "command": "uvx",
      "args": [
        "airflow-mcp-server"
      ],
      "env": {
        "AIRFLOW_BASE_URL": "http://<host:port>/api/v1",
        // AUTH_TOKENを使用した基本認証
        "AUTH_TOKEN": "<base64_encoded_username_password>",
        // または、COOKIEを使用したCookieベースの認証
        "COOKIE": "<session_cookie>"
      }
    }
  }
}