MCP 服务器

mcp-timeplus

与 Timeplus 集成，Timeplus 是一个流数据数据库，例如 Apache Kafka/Pulsar。

数据库

开发者工具

监控

访问服务器

Tools

list_databases

list_tables

run_sql

list_kafka_topics

explore_kafka_topic

create_kafka_stream

README

Timeplus MCP 服务器

Timeplus 的 MCP 服务器。

功能

提示词 (Prompts)

generate_sql：为 LLM 提供更多关于如何通过 SQL 查询 Timeplus 的知识

工具 (Tools)

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 (字符串)：主题的名称。

配置

首先，确保您已安装 uv 可执行文件。如果没有，您可以按照此处的说明进行安装。

打开位于以下位置的 Claude Desktop 配置文件：
- 在 macOS 上：~/Library/Application Support/Claude/claude_desktop_config.json
- 在 Windows 上：%APPDATA%/Claude/claude_desktop_config.json
添加以下内容：

{
  "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 服务。

重新启动 Claude Desktop 以应用更改。

您还可以尝试将此 MCP 服务器与其他 MCP 客户端一起使用，例如 5ire。

开发

在 test-services 目录中运行 docker compose up -d 以启动 Timeplus Proton 服务器。您也可以通过 curl https://install.timeplus.com/oss | sh 下载它，然后使用 ./proton server 启动。
将以下变量添加到存储库根目录中的 .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"}

运行 uv sync 以安装依赖项。然后执行 source .venv/bin/activate。
为了便于测试，您可以运行 mcp dev mcp_timeplus/mcp_server.py 以启动 MCP 服务器。单击“连接”按钮以将 UI 与 MCP 服务器连接，然后切换到“工具”选项卡以运行可用的工具。

环境变量

以下环境变量用于配置 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 配置或以上面的示例作为参考。