mcp-timeplus

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設定を参照するか、上記の例を参考にしてください。