clcikhouse创建分布式表

create table if not exists 库名.表名 ON CLUSTER default_cluster(
   data_date Date COMMENT '数据时间',
   d_year Int(32) comment '时间对应年份',
   d_month Int(32) comment '时间对应月份',
   d_week Int(32) COMMENT '时间对应的月份周数'
)
ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/库名/表名', '{replica}')
partition by toYYYYMM(data_date)
ORDER BY (data_date,wid)
TTL data_date + toIntervalMonth(24); //TTL数据自动失效时间

在表的基础上创建视图查询

CREATE TABLE if not exists 库名.表名 ON CLUSTER default_cluster  AS 来源库名.来源表名ENGINE = Distributed(default_cluster,来源库名,来源表名,rand());