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_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年4月10日)

• 新機能: バッチジョブの送信とドキュメントの送信操作のためのsubmit-jobsとsubmit-job/uploadツールを追加しました

  • 1回のAPI呼び出しで複数のジョブを一度に送信できます

  • 入力はリクエストボディとしてAPIに直接渡されます

  • ジョブ構成にJSON形式をサポート

  • ドキュメントに基づいてジョブの送信を許可する

v1.0.0（初回リリース）

• 基本的なSeaTunnel統合機能を備えた初期リリース

• ジョブ管理ツール（送信、停止、監視）

• システム監視ツール

• 接続構成ユーティリティ

ライセンス

Apacheライセンス