DolphinScheduler MCP Server
2025.03.31
6
Python工作流管理任务调度开发效率
DolphinScheduler MCP Server 是一个基于 Model Context Protocol (MCP) 的服务，为 Apache DolphinScheduler 提供标准化的协议接口，使 AI 代理能够通过标准化协议与 DolphinScheduler 交互。该服务作为 AI 模型与 DolphinScheduler 之间的桥梁，支持 AI 驱动的工作流管理。
View on GitHub
Overview
基本能力
产品定位
DolphinScheduler MCP Server 是一个为 Apache DolphinScheduler 提供标准化协议接口的服务，支持 AI 代理通过 MCP 协议与 DolphinScheduler 交互，实现 AI 驱动的工作流管理。
核心功能
- 完整的 DolphinScheduler API 覆盖
- 遵循 Model Context Protocol 的标准化工具接口
- 通过环境变量或命令行参数轻松配置
- 全面的工具文档
适用场景
- AI 代理与 DolphinScheduler 的交互
- AI 驱动的工作流管理
- 自动化任务调度与管理
工具列表
DolphinScheduler MCP Server 提供以下工具： - 项目管理 - 流程定义管理 - 流程实例管理 - 任务定义管理 - 调度管理 - 资源管理 - 数据源管理 - 告警组管理 - 告警插件管理 - 工作机组管理 - 租户管理 - 用户管理 - 系统状态监控
常见问题解答
无明确常见问题解答内容。
使用教程
使用依赖
无明确前置依赖说明。
安装教程
pip install dolphinscheduler-mcp
配置
环境变量
DOLPHINSCHEDULER_API_URL: DolphinScheduler API 的 URL (默认: http://localhost:12345/dolphinscheduler)DOLPHINSCHEDULER_API_KEY: 用于 DolphinScheduler API 认证的 API tokenDOLPHINSCHEDULER_MCP_HOST: MCP 服务器绑定的主机 (默认: 0.0.0.0)DOLPHINSCHEDULER_MCP_PORT: MCP 服务器绑定的端口 (默认: 8089)DOLPHINSCHEDULER_MCP_LOG_LEVEL: 日志级别 (默认: INFO)
调试方式
命令行启动服务器
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)
示例客户端使用
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": "Project created by AI"}
)