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);
