cat > pipe_log.sql <<EOF
        CREATE DATABASE IF NOT EXISTS opera_log ON cluster 'GITEE_CK_1S_3R';
        CREATE TABLE IF NOT EXISTS opera_log.sa_agent_log ON cluster 'GITEE_CK_1S_3R'
        (
          log_uuid String COMMENT '作业id' CODEC (ZSTD(1)),
          position UInt32 COMMENT '日志行号' CODEC (ZSTD(1)),
          create_time DATETIME('Asia/Shanghai') COMMENT '创建时间，归档' CODEC (ZSTD(1)),
          log_time DATETIME64(3, 'Asia/Shanghai') COMMENT '实际写入时间' CODEC (ZSTD(1)),
          end UInt8 COMMENT '日志结束标识' CODEC(ZSTD(1)),
          log String COMMENT '日志内容' CODEC (ZSTD(1))
        ) ENGINE = ReplicatedMergeTree('/clickhouse/tables/{database}/{table}/{shard}', '{replica}')
        ORDER BY (log_uuid, position)
        PARTITION BY toYYYYMMDD(create_time)
        TTL create_time + INTERVAL 2 WEEK;
        CREATE TABLE IF NOT EXISTS opera_log.pipeline_log ON cluster 'GITEE_CK_1S_3R'
        (
          log_uuid String COMMENT '作业id' CODEC (ZSTD(1)),
          position UInt32 COMMENT '日志行号' CODEC (ZSTD(1)),
          create_time DATETIME('Asia/Shanghai') COMMENT '创建时间，归档' CODEC (ZSTD(1)),
          log_time DATETIME64(3, 'Asia/Shanghai') COMMENT '实际写入时间' CODEC (ZSTD(1)),
          end UInt8 COMMENT '日志结束标识' CODEC(ZSTD(1)),
          log String COMMENT '日志内容' CODEC (ZSTD(1))
        ) ENGINE = ReplicatedMergeTree('/clickhouse/tables/{database}/{table}/{shard}', '{replica}')
        ORDER BY (log_uuid, position)
        PARTITION BY toYYYYMMDD(create_time)
        TTL create_time + INTERVAL 2 WEEK;
EOF

clickhouse-client --password=Admin@2025 -n < pipe_log.sql




cat > pipe_log.sql <<EOF
        CREATE DATABASE IF NOT EXISTS opera_log ON cluster 'GITEE_CK_1S_3R';
        CREATE TABLE IF NOT EXISTS opera_log.sa_agent_log ON cluster 'GITEE_CK_1S_3R'
        (
          log_uuid String COMMENT '作业id' CODEC (ZSTD(1)),
          position UInt32 COMMENT '日志行号' CODEC (ZSTD(1)),
          create_time DATETIME('Asia/Shanghai') COMMENT '创建时间，归档' CODEC (ZSTD(1)),
          log_time DATETIME64(3, 'Asia/Shanghai') COMMENT '实际写入时间' CODEC (ZSTD(1)),
          end UInt8 COMMENT '日志结束标识' CODEC(ZSTD(1)),
          log String COMMENT '日志内容' CODEC (ZSTD(1))
        ) ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/sa_agent_log', '{replica}')
        ORDER BY (log_uuid, position)
        PARTITION BY toYYYYMMDD(create_time)
        TTL create_time + INTERVAL 2 WEEK;
        CREATE TABLE IF NOT EXISTS opera_log.pipeline_log ON cluster 'GITEE_CK_1S_3R'
        (
          log_uuid String COMMENT '作业id' CODEC (ZSTD(1)),
          position UInt32 COMMENT '日志行号' CODEC (ZSTD(1)),
          create_time DATETIME('Asia/Shanghai') COMMENT '创建时间，归档' CODEC (ZSTD(1)),
          log_time DATETIME64(3, 'Asia/Shanghai') COMMENT '实际写入时间' CODEC (ZSTD(1)),
          end UInt8 COMMENT '日志结束标识' CODEC(ZSTD(1)),
          log String COMMENT '日志内容' CODEC (ZSTD(1))
        ) ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/pipeline_log', '{replica}')
        ORDER BY (log_uuid, position)
        PARTITION BY toYYYYMMDD(create_time)
        TTL create_time + INTERVAL 2 WEEK;
EOF

clickhouse-client --password=Admin@2025 -n < /tmp/1.sql




CREATE TABLE t1 ON cluster 'GITEE_CK_1S_3R' (
  dt DateTime,
  customer_id UInt32,
  total_spent Float32
) ENGINE = ReplicatedMergeTree('/clickhouse/tables/{database}/{table}/{shard}', '{replica}')
ORDER BY dt;

INSERT INTO t1 SELECT now() - INTERVAL randUniform(1,1_000_000) SECOND AS dt,
  number AS customer_id,
  15 + round(randExponential(1/10), 2) AS total_spent
FROM numbers(5000000);