| 引擎写法 | ReplicatedMergeTree('/clickhouse/tables/{shard}/tbl', '{replica}') |
|---|---|
| 路径宏 | {shard}、{replica} 来自 config.xml 的 macros 配置,保证每台机器取值不同 |
| Replicated 库 | 库引擎为 Replicated 时可直接写 ReplicatedMergeTree,无需手写路径 |
示例
示例
CREATE TABLE events_local ON CLUSTER prod
(
ts DateTime,
id UInt64
)
ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/events_local', '{replica}')
PARTITION BY toYYYYMM(ts)
ORDER BY (id, ts);
-- 等待副本追平
SYSTEM SYNC REPLICA events_local;写任意一个副本即可,其余副本通过复制日志拉取;相同 INSERT 块按哈希去重,重试写入通常不会产生重复数据。