Timeplus MCP サーバー

Timeplus 用の MCP サーバー。

特徴

プロンプト

• generate_sql 、LLM に SQL 経由で Timeplus をクエリする方法に関するより多くの知識を与えます。

ツール

• run_sql

  • Timeplus クラスターで SQL クエリを実行します。

  • 入力: sql (文字列): 実行する SQL クエリ。

  • デフォルトでは、すべてのTimeplusクエリは安全性を確保するためにreadonly = 1で実行されます。DDLまたはDMLクエリを実行する場合は、環境変数TIMEPLUS_READ_ONLYをfalseに設定できます。

• list_databases

  • Timeplus クラスター上のすべてのデータベースを一覧表示します。

• list_tables

  • データベース内のすべてのテーブルを一覧表示します。

  • 入力: database (文字列): データベースの名前。

• list_kafka_topics

  • Kafka クラスター内のすべてのトピックを一覧表示する

• explore_kafka_topic

  • Kafkaトピック内のいくつかのメッセージを表示する

  • 入力: topic (文字列): トピックの名前。 message_count (int): 表示するメッセージの数。デフォルトは 1。

• create_kafka_stream

  • Timeplus でストリーミング ETL を設定し、Kafka メッセージをローカルに保存します。

  • 入力: topic (文字列): トピックの名前。

• connect_to_apache_iceberg

  • Apache Icebergベースのデータベースに接続します。現在、この機能はTimeplus Enterpriseでのみ利用可能ですが、近日中にTimeplus Protonでも利用可能になる予定です。

  • 入力: iceberg_db (文字列): Iceberg データベースの名前。 aws_account_id (int): AWS アカウント ID (12 桁)。 s3_bucket (文字列): S3 バケット名。 aws_region (文字列): AWS リージョン。デフォルトは「us-west-2」。 is_s3_table_bucket (bool): S3 バケットが S3 テーブル バケットであるかどうか。デフォルトは False。

構成

まず、 uv実行ファイルがインストールされていることを確認してください。まだインストールされていない場合は、こちらの手順に従ってインストールできます。

1. 次の場所にある Claude Desktop 構成ファイルを開きます。

   • macOSの場合: ~/Library/Application Support/Claude/claude_desktop_config.json

   • Windows の場合: %APPDATA%/Claude/claude_desktop_config.json

2. 以下を追加します。

独自の Timeplus サービスを指すように環境変数を更新します。

3. 変更を適用するには、Claude Desktop を再起動します。

この MCP サーバーを5ireなどの他の MCP クライアントで試すこともできます。

発達

1. test-servicesディレクトリでdocker compose up -dを実行し、Timeplus Proton サーバーを起動します。または、 curl https://install.timeplus.com/oss | shでダウンロードし、 ./proton serverで起動することもできます。

2. リポジトリのルートにある.envファイルに次の変数を追加します。

3. uv syncを実行して依存関係をインストールします。その後、 source .venv/bin/activate実行します。

4. 簡単なテストとして、 mcp dev mcp_timeplus/mcp_server.pyを実行してMCPサーバーを起動できます。「接続」ボタンをクリックしてUIをMCPサーバーに接続し、「ツール」タブに切り替えて利用可能なツールを実行してください。

5. Docker イメージをビルドするには、 docker build -t mcp_timeplus . .

環境変数

Timeplus 接続を構成するには、次の環境変数が使用されます。

必須変数

• TIMEPLUS_HOST : Timeplusサーバーのホスト名

• TIMEPLUS_USER : 認証用のユーザー名

• TIMEPLUS_PASSWORD : 認証用のパスワード

オプション変数

• TIMEPLUS_PORT : Timeplusサーバーのポート番号

  • デフォルト: HTTPS が有効な場合は8443 、無効な場合は8123

  • 非標準ポートを使用しない限り、通常は設定する必要はありません

• TIMEPLUS_SECURE : HTTPS接続を有効/無効にする

  • デフォルト: "false"

  • 安全な接続のために"true"に設定

• TIMEPLUS_VERIFY : SSL証明書検証を有効/無効にする

  • デフォルト: "true"

  • 証明書の検証を無効にするには"false"に設定します（本番環境では推奨されません）

• TIMEPLUS_CONNECT_TIMEOUT : 接続タイムアウト（秒）

  • デフォルト: "30"

  • 接続タイムアウトが発生する場合はこの値を増やしてください

• TIMEPLUS_SEND_RECEIVE_TIMEOUT : 送受信タイムアウト（秒）

  • デフォルト: "300"

  • 長時間実行されるクエリの場合はこの値を増やします

• TIMEPLUS_DATABASE : 使用するデフォルトのデータベース

  • デフォルト: なし (サーバーのデフォルトを使用)

  • 特定のデータベースに自動的に接続するにはこれを設定します

• TIMEPLUS_READ_ONLY : 読み取り専用モードを有効/無効にする

  • デフォルト: "true"

  • DDL/DMLを有効にするには"false"に設定してください

• TIMEPLUS_KAFKA_CONFIG : Kafka 設定用の JSON 文字列。librdkafka設定を参照するか、上記の例を参考にしてください。