Dolphinscheduler MCP

🚀 Apache DolphinScheduler MCP サーバー

Apache DolphinScheduler の Model Context Protocol (MCP) サーバーは、FastMCP ベースのサービスを提供します。これにより、DolphinScheduler の REST API が一連のツールとして公開され、AI エージェントが標準化されたプロトコルを通じてこれらのツールとやり取りできます。このサーバーは、AI モデルと DolphinScheduler の間の橋渡し役となり、AI 駆動のワークフロー管理を実現します。

✨ 主な機能

• DolphinScheduler の機能を完全に網羅
• Model Context Protocol に準拠した標準ツールインターフェース
• 環境変数またはコマンドライン引数による簡便な設定
• 充実したツールドキュメント

📦 インストール

pip install dolphinscheduler-mcp

📚 ドキュメント

設定

環境変数

使用方法

コマンドライン

コマンドラインインターフェースを使用してサーバーを起動します：

ds-mcp --host 0.0.0.0 --port 8089

Python API

from dolphinscheduler_mcp.server import run_server

# サーバーを起動
run_server(host="0.0.0.0", port=8089)

利用可能なツール

DolphinScheduler MCP サーバーが提供するツールは以下の通りです：

• プロジェクト管理
• フロー定義管理
• フローインスタンス管理
• タスク定義管理
• スケジューリング管理
• リソース管理
• データソース管理
• アラートグループ管理
• アラートプラグイン管理
• ワーカーグループ管理
• テナント管理
• ユーザー管理
• システム状態監視

💻 使用例

基本的な使用法

from mcp_client import MCPClient

# MCP サーバーに接続
client = MCPClient("http://localhost:8089/mcp")

# プロジェクトリストを取得
response = await client.invoke_tool("get-project-list")

# 新しいプロジェクトを作成
response = await client.invoke_tool(
    "create-project", 
    {"name": "My AI Project", "description": "由 AI 创建的项目"}
)

📄 ライセンス

Apache License 2.0