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
# Start the server
run_server(host="0.0.0.0", port=8089)
可用工具
DolphinScheduler MCP 服务器提供以下工具:
- 项目管理
- 流程定义管理
- 流程实例管理
- 任务定义管理
- 调度管理
- 资源管理
- 数据源管理
- 警报组管理
- 警报插件管理
- 工人群体管理
- 租户管理
- 用户管理
- 系统状态监控
客户端使用示例
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