准备 Kafka 环境

本实践以 QingCloud Kafka 为例。

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

准备 ClickHouse 环境

本实践以 QingCloud ClickHouse 为例。

1. 创建 ClickHouse 集群。

2. 连接 ClickHouse。

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

   create database if not exists pk;
   

4. 执行以下命令，在数据库 pk 中创建数据库表 output_uv。

   create table output_uv
   (
       `userids`     String,
       `uv`          UInt64,
       `create_time` DateTime
   ) engine = SummingMergeTree(uv)
       primary key (userids)
       order by (userids);
   
   create table output_pv
   (
       `pagevisits` String,
       `product_id` String,
       `pv`         UInt64,
       `stt`        DateTime,
       `edt`        DateTime
   ) engine = Memory;
   
   CREATE TABLE `output_conversion_rate`
   (
       `conversion_rate` String,
       `rate`            String,
       `create_time`     DateTime
   ) engine = ReplacingMergeTree(create_time)
       partition by toYYYYMMDD(create_time)
       primary key (conversion_rate)
       order by (conversion_rate,create_time);