DolphinScheduler MCP 服务器

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

概述

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

Related MCP server: Role-Specific Context MCP Server

特征

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