Seatunnel

🚀 SeaTunnel MCP サーバー

大規模言語モデル（LLM）インターフェースを介してSeaTunnelとやり取りするためのモデルコンテキストプロトコル（MCP）サーバーです。

🚀 クイックスタート

操作ビデオ

Seatunnel MCPの機能と使い方をよりよく理解するために、デモビデオを用意しています。以下のリンクを参照するか、プロジェクトドキュメントディレクトリ内のビデオファイルを直接確認してください。

https://www.youtube.com/watch?v=JaLA8EkZD7Q

⚠️ 重要提示

ビデオが直接再生できない場合は、デバイスがMP4形式をサポートしていることを確認し、最新のブラウザまたはビデオプレイヤーを使用して開いてみてください。

✨ 主な機能

• ジョブ管理（送信、停止、監視）
• システム情報の照会と検索
• SeaTunnelサービスのREST APIとのやり取り
• 組み込みのログと監視ツール
• 動的接続設定
• 包括的なジョブ情報と統計

📦 インストール

# リポジトリをクローンする
git clone <repository_url>
cd seatunnel-mcp

# 仮想環境を作成してインストールする
python -m venv .venv
source .venv/bin/activate  # Windowsシステムの場合は：.venv\Scripts\activate
pip install -e .

構成要件

• Python ≥ 3.12
• 実行中のSeaTunnelインスタンス
• Node.js（MCP Inspectorとのテスト用）

💻 使用例

環境変数

SEATUNNEL_API_URL=http://localhost:8090  # デフォルトのSeaTunnel REST API URL
SEATUNNEL_API_KEY=your_api_key           # オプション：デフォルトのSeaTunnel APIキー

動的接続設定

サーバーは接続設定を表示および更新するツールを提供しています。

• get-connection-settings：現在の接続URLとAPIキーの状態を表示します。
• update-connection-settings：異なるSeaTunnelインスタンスに接続するために、URLおよび/またはAPIキーを更新します。

MCPサンプルを使用した例：

// 現在の設定を取得する
{
  "name": "get-connection-settings"
}

// 接続設定を更新する
{
  "name": "update-connection-settings",
  "arguments": {
    "url": "http://new-host:8090",
    "api_key": "new-api-key"
  }
}

ジョブ管理

サーバーはSeaTunnelジョブを送信および管理するツールを提供しています。

• submit-job：ジョブ構成を含む新しいジョブを送信します。
• submit-jobs：複数のジョブを一度に送信します。
• stop-job：指定されたジョブを停止します。
• monitor-jobs：ジョブの状態を監視します。

サーバーの起動

# ターミナルで以下のコマンドを実行してサーバーを起動します。
python -m seatunnel_mcp_server

Claude Desktopとの統合

Claude DesktopでSeatunnel MCP Serverを使用するには、以下の手順で設定してください。

1. Claude Desktopの設定を開きます。
2. 新しいAPIエンドポイントを追加し、URLをhttp://localhost:8090に設定します。
3. プロジェクトでこのエンドポイントを選択してやり取りを行います。

テスト

以下のコマンドを実行して、MCPサーバーとの接続をテストします。

curl http://localhost:8090/health

📚 ドキュメント

変更履歴

v1.1.0（最新バージョン）

• 動的接続設定ツールのエラーを修正し、APIキーが正しく更新できない問題を解決しました。
• ジョブ監視機能を改善し、現在はリアルタイムで状態を更新できるようになりました。

v1.0.1

• JSON形式のジョブ構成のサポートを追加しました。
• Claude Desktopとの統合エクスペリエンスを最適化しました。

v1.0.0（初期バージョン）

• 初回リリースで、基本的なSeaTunnel統合機能を備えています。
• 基本的なジョブ管理ツール（送信、停止、監視）を提供します。
• システム情報照会ツール
• 接続設定ユーティリティ

📄 ライセンス

Apache License