DolphinScheduler MCP Server

DolphinScheduler MCP 服务

一个用于 Apache DolphinScheduler 的模型上下文协议（MCP）服务，允许 AI Agent 通过标准化协议与 DolphinScheduler 交互。

概览

DolphinScheduler MCP 提供基于 FastMCP 的服务，将 DolphinScheduler 的 REST API 暴露为一组可供 AI Agent 使用的工具。该服务充当 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

# Start the server
run_server(host="0.0.0.0", port=8089)

可用工具

DolphinScheduler MCP 服务提供以下方面的工具：

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

客户端使用示例

from mcp_client import MCPClient

# Connect to the MCP server
client = MCPClient("http://localhost:8089/mcp")

# Get a list of projects
response = await client.invoke_tool("get-project-list")

# Create a new project
response = await client.invoke_tool(
    "create-project", 
    {"name": "My AI Project", "description": "Project created by AI"}
)

许可证

Apache 许可证 2.0