Timeplus MCP 服务器

Timeplus 的 MCP 服务器。

<a href="https://glama.ai/mcp/servers/9aleefsq9s"><img width="380" height="200" src="https://gips0.baidu.com/it/u=2925825138,4234516102&fm=3081&app=3081&f=PNG?w=760&h=400" alt="mcp-timeplus MCP 服务器" /></a>

功能

提示

• generate_sql 用于给大模型更多关于如何通过 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 (整数)：要显示的消息数量，默认为 1。

• create_kafka_stream

  • 在 Timeplus 中设置流式 ETL，以本地保存 Kafka 消息
  • 输入：topic (字符串)：主题的名称。

• connect_to_apache_iceberg

  • 连接到基于 Apache Iceberg 的数据库。目前仅可通过 Timeplus Enterprise 访问，并计划很快在 Timeplus Proton 上提供。
  • 输入：iceberg_db (字符串)：Iceberg 数据库的名称。aws_account_id (整数)：AWS 账户 ID（12 位）。s3_bucket (字符串)：S3 存储桶名称。aws_region (字符串)：AWS 区域，默认为 "us-west-2"。is_s3_table_bucket (布尔值)：S3 存储桶是否为 S3 表存储桶，默认为 False。

配置

首先，请确保已安装 uv 可执行文件。如果没有，请按照 这里 的说明进行安装。

1. 打开位于以下位置的 Claude Desktop 配置文件：

   • 在 macOS 上：~/Library/Application Support/Claude/claude_desktop_config.json
   • 在 Windows 上：%APPDATA%/Claude/claude_desktop_config.json

2. 添加以下内容：

{
  "mcpServers": {
    "mcp-timeplus": {
      "command": "uvx",
      "args": ["mcp-timeplus"],
      "env": {
        "TIMEPLUS_HOST": "<timeplus-host>",
        "TIMEPLUS_PORT": "<timeplus-port>",
        "TIMEPLUS_USER": "<timeplus-user>",
        "TIMEPLUS_PASSWORD": "<timeplus-password>",
        "TIMEPLUS_SECURE": "false",
        "TIMEPLUS_VERIFY": "true",
        "TIMEPLUS_CONNECT_TIMEOUT": "30",
        "TIMEPLUS_SEND_RECEIVE_TIMEOUT": "30",
        "TIMEPLUS_READ_ONLY": "false",
        "TIMEPLUS_KAFKA_CONFIG": "{\"bootstrap.servers\":\"a.aivencloud.com:28864\", \"sasl.mechanism\":\"SCRAM-SHA-256\",\"sasl.username\":\"avnadmin\", \"sasl.password\":\"thePassword\",\"security.protocol\":\"SASL_SSL\",\"enable.ssl.certificate.verification\":\"false\"}"
      }
    }
  }
}

更新环境变量以指向您自己的 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 文件中添加以下变量。

TIMEPLUS_HOST=localhost
TIMEPLUS_PORT=8123
TIMEPLUS_USER=default
TIMEPLUS_PASSWORD=
TIMEPLUS_SECURE=false
TIMEPLUS_VERIFY=true
TIMEPLUS_CONNECT_TIMEOUT=30
TIMEPLUS_SEND_RECEIVE_TIMEOUT=30
TIMEPLUS_READ_ONLY=false
TIMEPLUS_KAFKA_CONFIG={"bootstrap.servers":"a.aivencloud.com:28864", "sasl.mechanism":"SCRAM-SHA-256","sasl.username":"avnadmin", "sasl.password":"thePassword","security.protocol":"SASL_SSL","enable.ssl.certificate.verification":"false"}

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"
  • 设置为 "false" 以启用 DDL/DML
• TIMEPLUS_KAFKA_CONFIG：Kafka 配置的 JSON 字符串。请参阅 librdkafka 配置或参考上述示例。