准备 Kafka 环境

本实践以 QingCloud Kafka 为例。

1. 创建 Kafka 集群。
2. 创建 Topic。

准备 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;