DolphinScheduler MCP Server

适用于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 Server提供的工具有：

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

示例客户端使用

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": "由AI创建的项目"}
)

许可证

Apache License 2.0