SeaTunnel MCP Server

by ocean-zhc
Verified

hybrid server

The server is able to function both locally and remotely, depending on the configuration or use case.

Integrations

  • Integrates with SeaTunnel (an Apache project) to provide job management capabilities including submitting, stopping, and monitoring jobs, as well as retrieving system monitoring information and cluster overview.

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 :使用作业配置提交新作业
  • submit-jobs :批量提交多个作业
  • stop-job :停止正在运行的作业
  • get-job-info :获取特定工作的详细信息
  • get-running-jobs :列出所有当前正在运行的作业
  • get-finished-jobs :按状态列出所有已完成的作业(已完成、已取消、已失败等)

运行服务器

python -m src.seatunnel_mcp

与 Claude Desktop 一起使用

要将其与 Claude Desktop 一起使用,请将以下内容添加到您的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 格式的配置提交新作业
  • submit-job/upload :提交作业源上传配置文件
  • submit-jobs :批量提交多个作业,直接将用户输入作为请求主体传递
  • stop-job :使用可选的保存点停止正在运行的作业
  • get-job-info :获取特定工作的详细信息
  • get-running-jobs :列出所有当前正在运行的作业
  • get-running-job :获取特定正在运行的作业的详细信息
  • get-finished-jobs :按州列出所有已完成的工作

系统监控

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

变更日志

v1.1.0 (2025-04-10)

  • 新功能:添加了submit-jobssubmit-job/upload工具,用于批量作业提交和文档提交操作
    • 允许通过单个 API 调用同时提交多个作业
    • 输入直接作为请求主体传递给 API
    • 支持 JSON 格式的作业配置
    • 允许根据文档提交作业

v1.0.0(初始版本)

  • 具有基本 SeaTunnel 集成功能的初始版本
  • 作业管理工具(提交、停止、监控)
  • 系统监控工具
  • 连接配置实用程序

执照

Apache 许可证

-
security - not tested
A
license - permissive license
-
quality - not tested

一个模型上下文协议服务器,可以通过 LLM 接口与 Apache SeaTunnel 进行交互,允许用户通过自然语言管理作业、监控系统信息和配置连接。

  1. Operation Video
    1. Features
      1. Installation
        1. Requirements
          1. Usage
            1. Environment Variables
            2. Dynamic Connection Configuration
            3. Job Management
            4. Running the Server
            5. Usage with Claude Desktop
            6. Testing with MCP Inspector
          2. Available Tools
            1. Connection Management
            2. Job Management
            3. System Monitoring
          3. Changelog
            1. v1.1.0 (2025-04-10)
            2. v1.0.0 (Initial Release)
          4. License
            ID: 5ksdj0wcva