ClickHouse Analytics กับ Zero Downtime
Zero Downtime Deployment สำหรับ ClickHouse
Zero Downtime Deployment ให้ Deploy ClickHouse โดยไม่หยุดบริการ ใช้ ReplicatedMergeTree, Distributed Tables, Rolling Updates ผู้ใช้ไม่รู้สึกถึงการเปลี่ยนแปลง
ClickHouse Cluster ที่ออกแบบดี รองรับ Node Failure, Schema Migration, Version Upgrade โดยไม่มี Downtime
ClickHouse Cluster Setup
=== ClickHouse Cluster สำหรับ High Availability ===
1. Docker Compose — 3-node Cluster
docker-compose.yml
version: '3.8'
services:
clickhouse-keeper-1:
image: clickhouse/clickhouse-keeper:latest
ports:
- "9181:9181"
volumes:
- keeper1_data:/var/lib/clickhouse-keeper
- ./keeper_config.xml:/etc/clickhouse-keeper/keeper_config.xml
clickhouse-1:
image: clickhouse/clickhouse-server:latest
ports:
- "8123:8123"
- "9000:9000"
volumes:
- ch1_data:/var/lib/clickhouse
- ./cluster_config.xml:/etc/clickhouse-server/config.d/cluster.xml
depends_on:
- clickhouse-keeper-1
clickhouse-2:
image: clickhouse/clickhouse-server:latest
ports:
- "8124:8123"
- "9001:9000"
volumes:
- ch2_data:/var/lib/clickhouse
- ./cluster_config.xml:/etc/clickhouse-server/config.d/cluster.xml
depends_on:
- clickhouse-keeper-1
clickhouse-3:
image: clickhouse/clickhouse-server:latest
ports:
- "8125:8123"
- "9002:9000"
volumes:
- ch3_data:/var/lib/clickhouse
- ./cluster_config.xml:/etc/clickhouse-server/config.d/cluster.xml
depends_on:
- clickhouse-keeper-1
2. Cluster Configuration
cluster_config.xml
<clickhouse>
<remote_servers>
<analytics_cluster>
<shard>
<replica>
<host>clickhouse-1</host>
<port>9000</port>
</replica>
<replica>
<host>clickhouse-2</host>
<port>9000</port>
</replica>
เนื้อหาเกี่ยวข้อง — อ่านต่อ: Shadcn UI Load Testing Strategy
</shard>
<shard>
<replica>
<host>clickhouse-3</host>
<port>9000</port>
</replica>
</shard>
แนะนำเพิ่มเติม — ระบบเทรดของ iCafeForex
</analytics_cluster>
</remote_servers>
</clickhouse>
3. ReplicatedMergeTree Table
CREATE TABLE analytics.events ON CLUSTER analytics_cluster (
event_date Date,
event_time DateTime,
user_id UInt64,
event_type LowCardinality(String),
page_url String,
duration_ms UInt32
) ENGINE = ReplicatedMergeTree(
'/clickhouse/tables/{shard}/events',
'{replica}'
)
PARTITION BY toYYYYMM(event_date)
เนื้อหาเกี่ยวข้อง — ดูเพิ่มเติมเรื่อง ลกไม — คู่มือฉบับสมบูรณ์ 2026
ORDER BY (event_date, user_id, event_time);
4. Distributed Table
CREATE TABLE analytics.events_distributed ON CLUSTER analytics_cluster
AS analytics.events
ENGINE = Distributed(analytics_cluster, analytics, events, rand());
5. ตรวจสอบ Cluster
SELECT * FROM system.clusters;
SELECT * FROM system.replicas;
echo "ClickHouse Cluster:"
echo " Nodes: 3 (2 shards, 2 replicas)"
echo " Keeper: ClickHouse Keeper"
echo " Engine: ReplicatedMergeTree"
echo " Query: Distributed Table"
แนะนำเพิ่มเติม — SiamCafeBook
Schema Migration
=== ClickHouse Schema Migration ===
1. Non-breaking Changes (Online)
ALTER TABLE analytics.events ADD COLUMN country String DEFAULT '';
ALTER TABLE analytics.events ADD COLUMN device LowCardinality(String) DEFAULT '';
ALTER TABLE analytics.events MODIFY COLUMN duration_ms UInt64;
2. Breaking Changes — Materialized View Approach
Step 1: สร้าง Table ใหม่
CREATE TABLE analytics.events_v2 (
event_date Date,
event_time DateTime,
user_id UInt64,
เนื้อหาเกี่ยวข้อง — แนะนำให้อ่าน domain controller คือ
event_type LowCardinality(String),
page_url String,
duration_ms UInt32,
country LowCardinality(String),
device LowCardinality(String),
session_id String
) ENGINE = ReplicatedMergeTree(...)
PARTITION BY toYYYYMM(event_date)
ORDER BY (event_date, user_id, event_time);
Step 2: สร้าง Materialized View รับข้อมูลใหม่
CREATE MATERIALIZED VIEW analytics.events_v2_mv
TO analytics.events_v2
AS SELECT
event_date, event_time, user_id, event_type,
page_url, duration_ms,
'' AS country, '' AS device, '' AS session_id
FROM analytics.events;
Step 3: Backfill ข้อมูลเก่า
INSERT INTO analytics.events_v2
SELECT *, '' AS country, '' AS device, '' AS session_id
FROM analytics.events
WHERE event_date < today();
Step 4: Switch Queries ไปใช้ events_v2
เนื้อหาเกี่ยวข้อง — ดูเพิ่มเติมเรื่อง technical analysis books
(Update application config)
Step 5: Cleanup
DROP VIEW analytics.events_v2_mv;
RENAME TABLE analytics.events TO analytics.events_old;
RENAME TABLE analytics.events_v2 TO analytics.events;
3. Migration Script
migration_steps = [
{"version": "001", "description": "Add country column",
"sql": "ALTER TABLE events ADD COLUMN country String DEFAULT ''",
"rollback": "ALTER TABLE events DROP COLUMN country"},
{"version": "002", "description": "Add device column",
"sql": "ALTER TABLE events ADD COLUMN device LowCardinality(String) DEFAULT ''",
"rollback": "ALTER TABLE events DROP COLUMN device"},
{"version": "003", "description": "Add TTL 1 year",
"sql": "ALTER TABLE events MODIFY TTL event_date + INTERVAL 1 YEAR",
"rollback": "ALTER TABLE events REMOVE TTL"},
]
Best Practices
- ReplicatedMergeTree: ใช้ ReplicatedMergeTree เสมอใน Production สำหรับ HA
- Rolling Updates: Update ทีละ Node ตรวจสอบ Replication Sync ก่อนไปตัวถัดไป
- Schema Migration: ใช้ ALTER TABLE สำหรับ Non-breaking Materialized View สำหรับ Breaking
- Backup ก่อน: Backup ข้อมูลก่อน Update หรือ Migration ทุกครั้ง
- Health Checks: ตรวจ system.replicas และ system.mutations หลัง Update
- Rollback Plan: เตรียม Rollback Plan สำหรับทุก Migration Step
Zero Downtime Deployment คืออะไร
Deploy Application Database ไม่หยุดบริการ ผู้ใช้ไม่รู้สึก Rolling Updates Blue-Green Canary ClickHouse ใช้ ReplicatedMergeTree Distributed Tables
