Timeplus
Interactúa con la plataforma de datos en tiempo real Timeplus para consultar y gestionar flujos de datos.
GitHub
12
Prueba este MCPPatrocinadoDocumentación
Servidor MCP de Timeplus
Un servidor MCP para Timeplus.
Características
Prompts
generate_sqlpara dar al LLM más conocimiento sobre cómo consultar Timeplus mediante SQL
Herramientas
run_sql- Ejecuta consultas SQL en tu clúster de Timeplus.
- Entrada:
sql(cadena): La consulta SQL a ejecutar. - Por defecto, todas las consultas de Timeplus se ejecutan con
readonly = 1para garantizar que sean seguras. Si deseas ejecutar consultas DDL o DML, puedes establecer la variable de entornoTIMEPLUS_READ_ONLYenfalse.
- Entrada:
- Ejecuta consultas SQL en tu clúster de Timeplus.
list_databases- Lista todas las bases de datos en tu clúster de Timeplus.
list_tables- Lista todas las tablas en una base de datos.
- Entrada:
database(cadena): El nombre de la base de datos.
- Entrada:
- Lista todas las tablas en una base de datos.
list_kafka_topics- Lista todos los temas en un clúster de Kafka.
explore_kafka_topic- Muestra algunos mensajes en el tema de Kafka.
- Entrada:
topic(cadena): El nombre del tema.message_count(entero): El número de mensajes a mostrar, por defecto 1.
- Entrada:
- Muestra algunos mensajes en el tema de Kafka.
create_kafka_stream- Configura un ETL de streaming en Timeplus para guardar los mensajes de Kafka localmente.
- Entrada:
topic(cadena): El nombre del tema.
- Entrada:
- Configura un ETL de streaming en Timeplus para guardar los mensajes de Kafka localmente.
connect_to_apache_iceberg- Conecta a una base de datos basada en Apache Iceberg. Actualmente esto solo está disponible a través de Timeplus Enterprise y está planificado que esté disponible para Timeplus Proton pronto.
- Entrada:
iceberg_db(cadena): El nombre de la base de datos Iceberg.aws_account_id(entero): El ID de la cuenta de AWS (12 dígitos).s3_bucket(cadena): El nombre del bucket de S3.aws_region(cadena): La región de AWS, por defecto "us-west-2".is_s3_table_bucket(booleano): Si el bucket de S3 es un bucket de tabla S3, por defecto False.
- Entrada:
- Conecta a una base de datos basada en Apache Iceberg. Actualmente esto solo está disponible a través de Timeplus Enterprise y está planificado que esté disponible para Timeplus Proton pronto.
Configuración
Primero, asegúrate de tener el ejecutable uv instalado. Si no, puedes instalarlo siguiendo las instrucciones aquí.
- Abre el archivo de configuración de Claude Desktop ubicado en:
- En macOS:
~/Library/Application Support/Claude/claude_desktop_config.json- En Windows:
%APPDATA%/Claude/claude_desktop_config.json
- En Windows:
- En macOS:
- Agrega lo siguiente:
{
"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\"}"
}
}
}
}
Actualiza las variables de entorno para que apunten a tu propio servicio de Timeplus.
- Reinicia Claude Desktop para aplicar los cambios.
También puedes probar este servidor MCP con otros clientes MCP, como 5ire.
Desarrollo
- En el directorio
test-servicesejecutadocker compose up -dpara iniciar un servidor Timeplus Proton. También puedes descargarlo mediantecurl https://install.timeplus.com/oss | sh, luego iniciarlo con./proton server. - Agrega las siguientes variables a un archivo
.enven la raíz del repositorio.
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"}
- Ejecuta
uv syncpara instalar las dependencias. Luego hazsource .venv/bin/activate. - Para pruebas fáciles, puedes ejecutar
mcp dev mcp_timeplus/mcp_server.pypara iniciar el servidor MCP. Haz clic en el botón "Connect" para conectar la interfaz con el servidor MCP, luego cambia a la pestaña "Tools" para ejecutar las herramientas disponibles. - Para construir la imagen de Docker, ejecuta
docker build -t mcp_timeplus ..
Variables de Entorno
Las siguientes variables de entorno se utilizan para configurar la conexión de Timeplus:
Variables Requeridas
TIMEPLUS_HOST: El nombre de host de tu servidor TimeplusTIMEPLUS_USER: El nombre de usuario para la autenticaciónTIMEPLUS_PASSWORD: La contraseña para la autenticación
Variables Opcionales
TIMEPLUS_PORT: El número de puerto de tu servidor Timeplus- Predeterminado:
8443si HTTPS está habilitado,8123si está deshabilitado- Generalmente no necesita configurarse a menos que se use un puerto no estándar
- Predeterminado:
TIMEPLUS_SECURE: Habilitar/deshabilitar la conexión HTTPS- Predeterminado:
"false"- Establecer en
"true"para conexiones seguras
- Establecer en
- Predeterminado:
TIMEPLUS_VERIFY: Habilitar/deshabilitar la verificación del certificado SSL- Predeterminado:
"true"- Establecer en
"false"para deshabilitar la verificación del certificado (no recomendado para producción)
- Establecer en
- Predeterminado:
TIMEPLUS_CONNECT_TIMEOUT: Tiempo de espera de conexión en segundos- Predeterminado:
"30"- Aumenta este valor si experimentas tiempos de espera de conexión
- Predeterminado:
TIMEPLUS_SEND_RECEIVE_TIMEOUT: Tiempo de espera de envío/recepción en segundosTIMEPLUS_DATABASE: Base de datos predeterminada a usar- Predeterminado: Ninguno (usa el predeterminado del servidor)
- Establece esto para conectarte automáticamente a una base de datos específica
- Predeterminado: Ninguno (usa el predeterminado del servidor)
TIMEPLUS_READ_ONLY: Habilitar/deshabilitar el modo de solo lecturaTIMEPLUS_KAFKA_CONFIG: Una cadena JSON para la configuración de Kafka. Consulta la configuración de librdkafka o toma el ejemplo anterior como referencia.