Dolphinscheduler MCP

🚀 Apache DolphinScheduler MCP 服務器

Apache DolphinScheduler 的 Model Context Protocol (MCP) 服務器基於 FastMCP 服務，將 DolphinScheduler 的 REST API 轉化為一系列工具，供 AI 代理通過標準化協議與之交互。它作為 AI 模型與 DolphinScheduler 之間的橋樑，實現了 AI 驅動的工作流管理。

🚀 快速開始

安裝

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 的各項功能。
• 提供符合 Model Context Protocol 的標準工具接口。
• 支持通過環境變量或命令行參數進行簡便配置。
• 具備全面的工具文檔。

📦 安裝指南

安裝命令

pip install dolphinscheduler-mcp

配置環境變量

💻 使用示例

基礎用法

from dolphinscheduler_mcp.server import run_server

# 啟動服務器
run_server(host="0.0.0.0", port=8089)

高級用法

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 創建的項目"}
)

📚 詳細文檔

可用工具

DolphinScheduler MCP 服務器提供的工具包括：

• 項目管理
• 流程定義管理
• 流程實例管理
• 任務定義管理
• 調度管理
• 資源管理
• 數據源管理
• 告警組管理
• 告警插件管理
• 工作機組管理
• 租戶管理
• 用戶管理
• 系統狀態監控

📄 許可證

本項目採用 Apache License 2.0 許可證。