Skip to content
ClickHouse Docs
ClickHouse DocsClickHouse Docs

Connect BladePipe to ClickHouse

Partner Integration

BladePipe is a real-time end-to-end data integration tool with sub-second latency, boosting seamless data flow across platforms.

ClickHouse is one of BladePipe’s pre-built connectors, allowing users to integrate data from various sources into ClickHouse automatically. This page will show how to load data into ClickHouse in real time step by step.

Supported sources

Currently BladePipe supports for data integration to ClickHouse from the following sources:

  • MySQL/MariaDB/AuroraMySQL
  • Oracle
  • PostgreSQL/AuroraPostgreSQL
  • MongoDB
  • Kafka
  • PolarDB-MySQL
  • OceanBase
  • TiDB

More sources are to be supported.

Download and run BladePipe

  1. Log in to BladePipe Cloud.

  2. Follow the instructions in Install Worker (Docker) or Install Worker (Binary) to download and install a BladePipe Worker.

Add ClickHouse as a target

  1. In BladePipe, click “DataSource” > “Add DataSource”.

  2. Select ClickHouse, and fill out the settings by providing your ClickHouse host and port, username and password, and click “Test Connection”.

    Add ClickHouse as a target
  3. Click “Add DataSource” at the bottom, and a ClickHouse instance is added.

Add MySQL as a source

In this tutorial, we use a MySQL instance as the source, and explain the process of loading MySQL data to ClickHouse.

  1. In BladePipe, click “DataSource” > “Add DataSource”.

  2. Select MySQL, and fill out the settings by providing your MySQL host and port, username and password, and click “Test Connection”.

    Add MySQL as a source
  3. Click “Add DataSource” at the bottom, and a MySQL instance is added.

Create a pipeline

  1. In BladePipe, click “DataJob” > “Create DataJob”.

  2. Select the added MySQL and ClickHouse instances and click “Test Connection” to ensure BladePipe is connected to the instances. Then, select the databases to be moved.

    Select source and target
  3. Select “Incremental” for DataJob Type, together with the “Full Data” option.

    Select sync type
  4. Select the tables to be replicated.

    Select tables
  5. Select the columns to be replicated.

    Select columns
  6. Confirm the DataJob creation, and the DataJob runs automatically.

    DataJob is running

Verify the data

  1. Stop data write in MySQL instance and wait for ClickHouse to merge data.
  1. Create a Verification DataJob. Once the Verification DataJob is completed, review the results to confirm that the data in ClickHouse is the same as the data in MySQL.
    Verify data
Navigation