DolphinScheduler MCP Server - MCP服务，MCP服务器，MCP教程

基本能力

产品定位

DolphinScheduler MCP Server 是一个为 Apache DolphinScheduler 提供标准化协议接口的服务，支持 AI 代理通过 MCP 协议与 DolphinScheduler 交互，实现 AI 驱动的工作流管理。

核心功能

• 完整的 DolphinScheduler API 覆盖
• 遵循 Model Context Protocol 的标准化工具接口
• 通过环境变量或命令行参数轻松配置
• 全面的工具文档

适用场景

• AI 代理与 DolphinScheduler 的交互
• AI 驱动的工作流管理
• 自动化任务调度与管理

工具列表

DolphinScheduler MCP Server 提供以下工具：
- 项目管理
- 流程定义管理
- 流程实例管理
- 任务定义管理
- 调度管理
- 资源管理
- 数据源管理
- 告警组管理
- 告警插件管理
- 工作机组管理
- 租户管理
- 用户管理
- 系统状态监控

常见问题解答

无明确常见问题解答内容。

使用教程

使用依赖

无明确前置依赖说明。

安装教程

bash
pip install dolphinscheduler-mcp

配置

环境变量

• DOLPHINSCHEDULER_API_URL: DolphinScheduler API 的 URL (默认: http://localhost:12345/dolphinscheduler)
• DOLPHINSCHEDULER_API_KEY: 用于 DolphinScheduler API 认证的 API token
• DOLPHINSCHEDULER_MCP_HOST: MCP 服务器绑定的主机 (默认: 0.0.0.0)
• DOLPHINSCHEDULER_MCP_PORT: MCP 服务器绑定的端口 (默认: 8089)
• DOLPHINSCHEDULER_MCP_LOG_LEVEL: 日志级别 (默认: INFO)

调试方式

命令行启动服务器

bash
ds-mcp --host 0.0.0.0 --port 8089

Python API 启动服务器

```python
from dolphinscheduler_mcp.server import run_server

启动服务器

run_server(host="0.0.0.0", port=8089)
```

示例客户端使用

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