Saltar al contenido principal
BladePipe es una herramienta de integración de datos de extremo a extremo en tiempo real, con latencia inferior a un segundo, que facilita un flujo de datos fluido entre plataformas. ClickHouse es uno de los conectores preconfigurados de BladePipe, lo que permite a los usuarios integrar automáticamente datos de diversas fuentes en ClickHouse. En esta página se muestra paso a paso cómo cargar datos en ClickHouse en tiempo real.

​
Fuentes compatibles

Actualmente, BladePipe admite la integración de datos con ClickHouse desde las siguientes fuentes:
  • MySQL/MariaDB/AuroraMySQL
  • Oracle
  • PostgreSQL/AuroraPostgreSQL
  • MongoDB
  • Kafka
  • PolarDB-MySQL
  • OceanBase
  • TiDB
Próximamente se admitirán más fuentes.
1

​
Descargar y ejecutar BladePipe

  1. Inicia sesión en BladePipe Cloud.
  2. Sigue las instrucciones de Instalar Worker (Docker) o Instalar Worker (binario) para descargar e instalar un Worker de BladePipe.
Como alternativa, puedes descargar y desplegar BladePipe Enterprise.
2

​
Agregar ClickHouse como destino

  1. BladePipe admite ClickHouse versión 20.12.3.3 o posterior.
  2. Para usar ClickHouse como destino, asegúrese de que el usuario tenga permisos de SELECT, INSERT y DDL habituales.
  1. En BladePipe, haga clic en “DataSource” > “Add DataSource”.
  2. Seleccione ClickHouse y complete la configuración indicando el host y el puerto de ClickHouse, el nombre de usuario y la contraseña; luego haga clic en “Test Connection”.
  3. Haga clic en “Add DataSource” en la parte inferior para agregar una instancia de ClickHouse.
3

​
Agregar MySQL como fuente

En este tutorial, usamos una instancia de MySQL como fuente y explicamos el proceso para cargar datos de MySQL en ClickHouse.
Para usar MySQL como fuente, asegúrese de que el usuario tenga los permisos necesarios.
  1. En BladePipe, haga clic en “DataSource” > “Add DataSource”.
  2. Seleccione MySQL y complete la configuración con el host y el puerto de MySQL, el nombre de usuario y la contraseña; luego haga clic en “Test Connection”.
  3. Haga clic en “Add DataSource” en la parte inferior y se agregará una instancia de MySQL.
4

​
Crear un pipeline

  1. En BladePipe, haz clic en “DataJob” > “Create DataJob”.
  2. Selecciona las instancias de MySQL y ClickHouse que has agregado y haz clic en “Test Connection” para comprobar que BladePipe esté conectado a ellas. Luego, selecciona las bases de datos que se van a mover.
  3. Selecciona “Incremental” en DataJob Type, junto con la opción “Full Data”.
  4. Selecciona las tablas que se van a replicar.
  5. Selecciona las columnas que se van a replicar.
  6. Confirma la creación del DataJob y este se ejecutará automáticamente.
5

​
Verifique los datos

  1. Detenga la escritura de datos en la instancia de MySQL y espere a que ClickHouse complete la fusión de los datos.
Como el momento en que ClickHouse realiza la fusión automática es impredecible, puede forzar manualmente una fusión ejecutando el comando OPTIMIZE TABLE xxx FINAL;. Tenga en cuenta que es posible que esta fusión manual no siempre se complete correctamente.Como alternativa, puede ejecutar el comando CREATE VIEW xxx_v AS SELECT * FROM xxx FINAL; para crear una vista y realizar consultas en ella a fin de asegurarse de que los datos se hayan fusionado por completo.
  1. Cree un DataJob de verificación. Una vez que se complete el DataJob de verificación, revise los resultados para confirmar que los datos de ClickHouse sean los mismos que los de MySQL.
Última modificación el 25 de junio de 2026