mcp-server-apache-airflow
mcp-server-apache-airflowは、Apache AirflowのREST APIをラップしたModel Context Protocol (MCP)サーバーの実装です。このプロジェクトは、MCPクライアントがAirflowと標準化された方法で対話できるようにすることを目的としています。公式のApache Airflowクライアントライブラリを使用しており、互換性と保守性が確保されています。
GitHubスター
86
ユーザー評価
未評価
お気に入り
0
閲覧数
21
フォーク
24
イシュー
10
インストール方法
難易度
中級推定所要時間
10-20 分
必要な環境
Python 3.6以上Apache Airflow 2.0以上インストール方法
インストール方法
前提条件
必要なソフトウェアとバージョン:Python: 3.6以上
Apache Airflow: 2.0以上
インストール手順
1. リポジトリのクローン
bash
git clone https://github.com/yangkyeongmo/mcp-server-apache-airflow.git
cd mcp-server-apache-airflow
2. 依存関係のインストール
bash
pip install -r requirements.txt
3. サーバーの起動
bash
python app.py
トラブルシューティング
よくある問題
問題: サーバーが起動しない 解決策: PythonとApache Airflowのバージョンを確認してください。設定方法
設定方法
基本設定
サーバー設定
config.jsonを編集してMCPサーバーの設定を行います：
json
{
"api_base_url": "http://localhost:8080/api/v1",
"airflow_url": "http://localhost:8080"
}
環境変数
必要に応じて以下の環境変数を設定：bash
export AIRFLOW_URL="http://localhost:8080"
export MCP_PORT="8080"
セキュリティ設定
APIキーは環境変数または安全な設定ファイルに保存
ファイルアクセス権限の適切な設定
ログレベルの調整
使用例
使用例
基本的な使用方法
プログラムでの使用
python
import requests
def call_mcp_tool(tool_name, params):
response = requests.post(
'http://localhost:8080/api/v1/call',
json={
'tool': tool_name,
'parameters': params
}
)
return response.json()
使用例
result = call_mcp_tool('list_dags', {})
print(result)
自動化スクリプト
bash
#!/bin/bash
DAGの一覧を取得するスクリプト
curl -X GET http://localhost:8080/api/v1/dags
使用ケース
データパイプラインの自動化において、DAGをプログラムから管理する。
特定のDAGの状態を監視し、必要に応じて一時停止または再開する。
DAGの詳細情報を取得し、ダッシュボードに表示する。
複数のDAGを一括で更新するスクリプトを作成する。