DolphinScheduler MCP 服务器

一个用于 Apache DolphinScheduler 的模型上下文协议 (MCP) 服务器，允许 AI 代理通过标准化协议与 DolphinScheduler 交互。

概述

DolphinScheduler MCP 提供了一个基于 FastMCP 的服务器，该服务器将 DolphinScheduler 的 REST API 作为一系列可供 AI 代理使用的工具公开。 该服务器充当 AI 模型和 DolphinScheduler 之间的桥梁，从而实现 AI 驱动的工作流管理。

特性

• DolphinScheduler 功能的完整 API 覆盖
• 遵循模型上下文协议的标准化工具接口
• 通过环境变量或命令行参数轻松配置
• 完善的工具文档

安装

pip install dolphinscheduler-mcp

配置

环境变量

• DOLPHINSCHEDULER_API_URL: DolphinScheduler API 的 URL (默认: http://localhost:12345/dolphinscheduler)
• DOLPHINSCHEDULER_API_KEY: 用于与 DolphinScheduler API 身份验证的 API 令牌
• DOLPHINSCHEDULER_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)

可用工具

DolphinScheduler MCP 服务器提供以下工具：

• 项目管理
• 流程定义管理
• 流程实例管理
• 任务定义管理
• 调度管理
• 资源管理
• 数据源管理
• 告警组管理
• 告警插件管理
• Worker 组管理
• 租户管理
• 用户管理
• 系统状态监控

客户端使用示例

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"}
)

许可证

Apache License 2.0