SeaTunnel MCP 服务器

一个用于通过大语言模型（LLM）接口与SeaTunnel交互的模型上下文协议（MCP）服务器。

操作视频

为了更好地了解Seatunnel MCP的功能和使用方法，我们提供了一个演示视频。请参考以下链接或直接查看项目文档目录中的视频文件。

https://www.youtube.com/watch?v=JaLA8EkZD7Q

提示: 如果视频无法直接播放，请确保您的设备支持MP4格式，并尝试使用现代浏览器或视频播放器打开。

功能

• 作业管理（提交、停止、监控）
• 系统信息查询与检索
• 与SeaTunnel服务的REST API交互
• 内置日志和监控工具
• 动态连接配置
• 全面的作业信息和统计

安装

# 克隆仓库
git clone <repository_url>
cd seatunnel-mcp

# 创建虚拟环境并安装
python -m venv .venv
source .venv/bin/activate  # Windows系统请使用：.venv\Scripts\activate
pip install -e .

配置要求

• Python ≥ 3.12
• 运行中的SeaTunnel实例
• Node.js（用于与MCP Inspector测试）

使用方法

环境变量

SEATUNNEL_API_URL=http://localhost:8090  # 默认的SeaTunnel REST API URL
SEATUNNEL_API_KEY=your_api_key           # 可选：默认的SeaTunnel API密钥

动态连接配置

服务器提供了查看和更新连接设置的工具：

• get-connection-settings：查看当前连接URL和API密钥状态
• update-connection-settings：更新URL和/或API密钥以连接到不同的SeaTunnel实例

通过MCP示例使用：

// 获取当前设置
{
  "name": "get-connection-settings"
}

// 更新连接设置
{
  "name": "update-connection-settings",
  "arguments": {
    "url": "http://new-host:8090",
    "api_key": "new-api-key"
  }
}

作业管理

服务器提供了提交和管理SeaTunnel作业的工具：

• submit-job：提交一个新的作业，带有作业配置
• submit-jobs：一次性提交多个作业
• stop-job：停止指定的作业
• monitor-jobs：监控作业状态

运行服务器

# 在终端中运行以下命令启动服务器：
python -m seatunnel_mcp_server

与Claude Desktop集成

要在Claude Desktop中使用Seatunnel MCP Server，请按照以下步骤配置：

1. 打开Claude Desktop的设置。
2. 添加新的API端点，URL为http://localhost:8090。
3. 在项目中选择该端点以进行交互。

测试

运行以下命令测试与MCP服务器的连接：

curl http://localhost:8090/health

变更日志

v1.1.0（最新版本）

• 修复了动态连接配置工具中的一个错误，导致无法正确更新API密钥。
• 改进了作业监控功能，现在支持实时更新状态。

v1.0.1

• 增加了对JSON格式作业配置的支持。
• 优化了与Claude Desktop的集成体验。

v1.0.0（初始版本）

• 首次发布，具备基础SeaTunnel整合能力
• 提供基本的作业管理工具（提交、停止、监控）
• 系统信息查询工具
• 连接配置实用程序

许可证

Apache License