Integrations

Provides tools for interacting with Apache DolphinScheduler's REST API, enabling AI-driven workflow management including project management, process definition and instance management, task management, resource management, data source management, and system monitoring.
Offers a Python API for starting and configuring the MCP server, as well as client libraries for invoking DolphinScheduler tools programmatically through Python.

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

This server cannot be installed

-

security - not tested

F

license - not found

-

quality - not tested

模型上下文协议服务器允许 AI 代理通过标准化协议与 Apache DolphinScheduler 交互，从而实现 AI 驱动的工作流管理。

DolphinScheduler MCP Server