准备 Kafka 环境

本实践以 QingCloud Kafka 为例。

准备 ClickHouse 环境

本实践以 QingCloud ClickHouse 为例。

  1. 创建 ClickHouse 集群

  2. 连接 ClickHouse

  3. 连接成功后,执行以下命令,创建数据库 pk

     create database if not exists pk;
  4. 执行以下命令,在数据库 pk 中创建数据库表 clickhouse_key_words

     create table clickhouse_key_words(
         province String,
         sex      String,
         word     String,
         stt      DateTime,
         edt      DateTime,
         ct       Int64
     )engine TinyLog;