RTC MCP Server

RTC MCP Server

Alibaba Cloud Realtime Compute for Apache Flink リソースを管理するための Model Context Protocol（MCP）サーバー実装です。このサーバーは、AI モデルが Alibaba Cloud Flink サービスと連携するための標準化されたインターフェースを提供します。

機能

• Flink クラスターの作成と管理
• Flink SQL ジョブの作成と管理
• Flink アプリケーションのデプロイと制御
• ジョブのステータスとメトリクスの監視
• セーブポイントの作成と管理
• デプロイメントの一覧表示と管理
• ワークスペースと名前空間の管理

前提条件

• JDK 17 以降
• Maven 3.6 以降
• RTC（Realtime Compute）へのアクセス権を持つ Alibaba Cloud アカウント
• Alibaba Cloud Access Key ID と Secret

クライアント設定

このサーバーを MCP クライアントとして使用するには、MCP 設定ファイル（例：cline_mcp_settings.json）に次の設定を追加します。

{
  "mcpServers": {
    "rtc-mcp-server": {
      "command": "java",
      "args": [
        "-Dtransport.mode=stdio",
        "-Dspring.main.web-application-type=none",
        "-Dspring.main.banner-mode=off",
        "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
        "-jar",
        "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
      ],
      "env": {
        "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
        "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
      },
      "disabled": false,
      "autoApprove": []
    }
  }
}

/path/to/rtc-mcp-server を実際のサーバーパスに置き換え、環境変数に Alibaba Cloud の認証情報を設定してください。

利用可能なツール

このサーバーは次の MCP ツールを提供します。

1. ジョブ管理

   • start_job：デプロイ済みの Flink ジョブを開始します
   • stop_job：実行中の Flink ジョブを停止します
   • list_jobs：デプロイメント内のすべてのジョブを一覧表示します
   • delete_job：実行中でないジョブを削除します
   • get_job_diagnosis：ジョブの診断情報を取得します

2. デプロイメント管理

   • create_deployment：新しい Flink デプロイメントを作成します
   • get_deployment_metrics：デプロイメントのメトリクスを取得します
   • create_savepoint：ジョブのセーブポイントを作成します

3. 変数管理

   • create_variable：新しい変数を作成します
   • update_variable：既存の変数を更新します
   • delete_variable：変数を削除します
   • list_variables：ページネーションを使用して変数を一覧表示します

4. ワークスペース管理

   • create_workspace：新しいワークスペースを作成します
   • get_workspace_info：ワークスペース情報を取得します
   • list_workspaces：すべてのワークスペースを一覧表示します

5. カタログ操作

   • get_catalogs：カタログ情報を取得します
   • get_deployment_databases：データベース情報を取得します
   • get_tables：テーブル情報を取得します
   • execute_sql_statement：SQL 文を実行します

ビルドと実行

1. プロジェクトをビルドします：

mvn clean package

2. サーバーを実行します：

java -jar target/rtc-mcp-server-1.0-SNAPSHOT.jar

stdio トランスポートを使用した開発モードの場合：

java -Dtransport.mode=stdio -Dspring.main.web-application-type=none -jar target/rtc-mcp-server-1.0-SNAPSHOT.jar

サーバーモード

サーバーは複数のトランスポートモードに対応しています。

• webflux：Spring WebFlux を使用するデフォルトモード
• stdio：開発とテスト用のコマンドラインモード

ロギング

ログは application.yml で次のデフォルト設定に構成されています。

• ルートレベル：WARN
• アプリケーションレベル（com.rtc）：INFO
• ログファイルは毎日ローテーションされ、GZIP で圧縮されます

コントリビューション

1. リポジトリをフォークします
2. 機能ブランチを作成します
3. 変更をコミットします
4. プルリクエストを作成します

ライセンス

Apache License, Version 2.0（「ライセンス」）に基づいてライセンスされています。 このファイルは、ライセンスに従う場合を除き、使用できません。 ライセンスのコピーは、次の場所から入手できます。

http://www.apache.org/licenses/LICENSE-2.0

適用される法律で義務付けられている場合、または書面で合意されている場合を除き、 ライセンスに基づいて配布されるソフトウェアは「現状のまま」提供され、 明示的か黙示的かを問わず、いかなる保証もありません。 ライセンスに基づく権利と制限については、 ライセンスをご確認ください。