SeaTunnel MCP 服务器

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

操作视频

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

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

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

特性

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

安装

# Clone repository
git clone <repository_url>
cd seatunnel-mcp

# Create virtual environment and install
python -m venv .venv
source .venv/bin/activate  # On Windows: .venv\Scripts\activate
pip install -e .

要求

• Python ≥ 3.9
• 正在运行的 SeaTunnel 实例
• Node.js（用于使用 MCP Inspector 测试）

使用

环境变量

SEATUNNEL_API_URL=http://localhost:8090  # Default SeaTunnel REST API URL
SEATUNNEL_API_KEY=your_api_key           # Optional: Default SeaTunnel API key

动态连接配置

服务器提供了工具以在运行时查看和更新连接设置：

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

通过 MCP 的示例用法：

// Get current settings
{
  "name": "get-connection-settings"
}

// Update connection settings
{
  "name": "update-connection-settings",
  "arguments": {
    "url": "http://new-host:8090",
    "api_key": "new-api-key"
  }
}

作业管理

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

• submit-job：使用作业配置提交新作业
• stop-job：停止正在运行的作业
• get-job-info：获取特定作业的详细信息
• get-running-jobs：列出所有当前正在运行的作业
• get-finished-jobs：按状态（已完成、已取消、失败等）列出所有已完成的作业

运行服务器

python -m src.seatunnel_mcp

与 Claude 桌面版一起使用

要与 Claude 桌面版一起使用，请将以下内容添加到您的 claude_desktop_config.json 文件中：

{
  "mcpServers": {
    "seatunnel": {
      "command": "python",
      "args": ["-m", "src.seatunnel_mcp"],
      "cwd": "Project root directory"
    }
  }
}

使用 MCP Inspector 测试

npx @modelcontextprotocol/inspector python -m src.seatunnel_mcp

可用工具

连接管理

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

作业管理

• submit-job：使用 HOCON 格式的配置提交新作业
• stop-job：停止正在运行的作业（可选保存点）
• get-job-info：获取特定作业的详细信息
• get-running-jobs：列出所有当前正在运行的作业
• get-running-job：获取特定正在运行的作业的详情
• get-finished-jobs：按状态列出所有已完成的作业

系统监控

• get-overview：获取 SeaTunnel 集群的概览
• get-system-monitoring-information：获取详细的系统监控信息

贡献

希望这个翻译对你有帮助！如果有更多需要翻译的内容或其他问题，请随时告诉我。

1. Fork 仓库
2. 创建特性分支
3. 提交更改
4. 创建拉取请求

许可证

Apache 许可证