ClickHouse-副本

网友投稿 983 2022-09-11

ClickHouse-副本

ClickHouse-副本

副本的目的主要是保障数据的高可用性,即使一台 ClickHouse 节点宕机,那么也可以从其他服务器获得相同的数据。

1.副本写入流程

2.配置步骤

(1)启动 zookeeper 集群(Node1-3)

配置zookeeper环境

(2)clickhouse准备两个节点

Node1, Node2 在 Node1 的/etc/clickhouse-server/config.d 目录下创建一个名为 metrika.xml 的配置文件,内容如下: 注:也可以不创建外部文件,直接在 config.xml 中指定

vim /etc/clickhouse-server/config.d/metrika.xml node2 2181 xxx 2181 xxx 2181

host自己更新

(3)同步到Node2

scp /etc/clickhouse-server/config.d/metrika.xml root@Node2:/etc/clickhouse-server/config.d/

(4)在 Node1 的/etc/clickhouse-server/config.xml 中增加

/etc/clickhouse-server/config.d/metrika.xml

(5)同步到 Node2

scp /etc/clickhouse-server/config.xml root@Node2:/etc/clickhouse-server/

重启clickhouse服务

sudo clickhouse restart

(6)在 Node1 和 Node2 上分别建表 副本只能同步数据,不能同步表结构,所以我们需要在每台机器上自己手动建表   Node1:

create table t_order_rep7 (id UInt32,sku_id String,total_amount Decimal(16,2),create_time Datetime) engine =ReplicatedMergeTree('/clickhouse/table/01/t_order_rep7','rep_fz_102')partition by toYYYYMMDD(create_time)primary key (id)order by (id,sku_id);

Node2:

create table t_order_rep7 (id UInt32,sku_id String,total_amount Decimal(16,2),create_time Datetime) engine =ReplicatedMergeTree('/clickhouse/table/01/t_order_rep7','rep_fz_103')partition by toYYYYMMDD(create_time)primary key (id)order by (id,sku_id);

参数解释: ReplicatedMergeTree 中, 第一个参数是分片的 zk_path 一般按照:/clickhouse/table/{shard}/{table_name} 的格式写,如果只有一个分片就写 01 即可。 第二个参数是副本名称,相同的分片副本名称不能相同。

(7)在 Node1 上执行 insert 语句

insert into t_order_rep7 values(101,'sku_001',1000.00,'2020-06-01 12:00:00'),(102,'sku_002',2000.00,'2020-06-01 12:00:00'),(103,'sku_004',2500.00,'2020-06-01 12:00:00'),(104,'sku_002',2000.00,'2020-06-01 12:00:00'),(105,'sku_003',600.00,'2020-06-02 12:00:00');

(8)在 Node2 上执行 select,可以查询出结果,说明副本配置正确

Done.

版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:vue添加图片(vue添加图片http)
下一篇:Flink-任务提交流程
相关文章

 发表评论

暂时没有评论,来抢沙发吧~