CREATE TABLE IF NOT EXISTS telemetry.telemetry ( device_id String, zone_id String, sensor_type String, value Float64, recorded_at DateTime, received_at DateTime ) ENGINE = MergeTree() ORDER BY (device_id, recorded_at);