海底隧道MCP服务器
一个模型上下文协议（MCP）服务器，用于通过Claude等LLM接口与SeaTunnel交互。
操作视频
为了帮助您更好地了解海底隧道MCP的功能和使用方法，我们提供了一个视频演示。请参考以下链接或直接查看项目文档目录中的视频文件。
https://www.youtube.com/watch?v=JaLA8EkZD7Q
小贴士：如果视频不能直接播放，请确保您的设备支持MP4格式，并尝试使用现代浏览器或视频播放器打开。
特性
- 作业管理（提交、停止、监控）
- 系统监控和信息检索
- REST API与SeaTunnel服务的交互
- 内置日志和监控工具
- 动态连接配置
- 全面的工作信息和统计数据
安装
# Clone repository
git clone
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.12
- 正在运行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检验员测试
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.2.0（2025-06-10）
v1.2.0中的新功能
- SSE支持：已添加
st-mcp-sse用于通过服务器发送事件（SSE）与SeaTunnel MCP进行实时通信。相应的sse分行 - UV/工作室模式：已添加
st-mcp-uv（或st-mcp-studio)支持使用运行MCP服务器uv用于提高性能和异步支持的工具。对应uv分支
示例 claude_desktop_config.json:
{
"mcpServers": {
"st-mcp-sse": {
"url": "http://your-server:18080/sse"
},
"st-mcp-uv": {
"command": "uv",
"args": ["run", "seatunnel-mcp"],
"env": {
"SEATUNNEL_API_URL": "http://127.0.0.1:8080"
}
}
}
}
v1.1.0（2025-04-10）
- 新功能：已添加
submit-jobs和submit-job/upload用于批量作业提交和文档提交操作的工具
- 允许使用单个API调用同时提交多个作业 - 输入作为请求主体直接传递给API - 支持作业配置的JSON格式 - 允许基于文档提交作业
v1.0.0（初始版本）
- 具有基本SeaTunnel集成功能的初始版本
- 作业管理工具（提交、停止、监控）
- 系统监控工具
- 连接配置实用程序
许可证
Apache许可证