SeaTunnel MCP Server

基本能力

产品定位

SeaTunnel MCP Server 是一个用于与 SeaTunnel 交互的中间件，通过 LLM 接口提供作业管理和系统监控功能。

核心功能

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

适用场景

• 需要高效管理 SeaTunnel 作业的场景
• 需要实时监控 SeaTunnel 系统状态的场景
• 需要通过 LLM 接口与 SeaTunnel 交互的场景

工具列表

连接管理

• 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: 获取详细的系统监控信息

常见问题解答

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

使用教程

使用依赖

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

安装教程

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

# 创建虚拟环境并安装
python -m venv .venv
source .venv/bin/activate  # Windows: .venv\Scripts\activate
pip install -e .

调试方式

# 运行服务器
python -m src.seatunnel_mcp

# 使用 MCP Inspector 进行测试
npx @modelcontextprotocol/inspector python -m src.seatunnel_mcp

环境变量

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

许可证

该项目遵循 Apache-2.0 开源许可条款，请参阅 Apache-2.0 了解完整条款。