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 的标准工具接口。
• 支持通过环境变量或命令行参数进行简便配置。
• 具备全面的工具文档。

💻 使用示例

基础用法

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 许可证。