SeaTunnel MCP サーバー
Claude などの LLM インターフェイスを介して SeaTunnel と対話するためのモデル コンテキスト プロトコル (MCP) サーバー。
操作ビデオ
SeaTunnel MCPの機能と使い方をより深くご理解いただくために、ビデオデモをご用意しました。下記のリンクを参照するか、プロジェクトドキュメントディレクトリ内のビデオファイルを直接ご確認ください。
https://www.youtube.com/watch?v=JaLA8EkZD7Q
ヒント: ビデオが直接再生されない場合は、デバイスが MP4 形式をサポートしていることを確認し、最新のブラウザまたはビデオ プレーヤーで開いてみてください。
Related MCP server: OpenAPI MCP Server
特徴
ジョブ管理（送信、停止、監視）
システム監視と情報検索
SeaTunnel サービスとの REST API のやり取り
組み込みのログおよび監視ツール
動的接続構成
包括的な求人情報と統計
インストール
# 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.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: 別の SeaTunnel インスタンスに接続するために URL や API キーを更新します
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: 完了したジョブを状態 (FINISHED、CANCELED、FAILED など) 別に一覧表示します。
サーバーの実行
python -m src.seatunnel_mcpClaude 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年4月10日)
新機能: バッチジョブの送信とドキュメントの送信操作のための
submit-jobsとsubmit-job/uploadツールを追加しました1回のAPI呼び出しで複数のジョブを一度に送信できます
入力はリクエストボディとしてAPIに直接渡されます
ジョブ構成にJSON形式をサポート
ドキュメントに基づいてジョブの送信を許可する
v1.0.0（初回リリース）
基本的なSeaTunnel統合機能を備えた初期リリース
ジョブ管理ツール（送信、停止、監視）
システム監視ツール
接続構成ユーティリティ
ライセンス
Apacheライセンス