如何在Apache IoTDB 1.3.4中创建CQ实现固定日窗口数据聚合？

一、原生CQ调整方案（适配固定窗口） #

IoTDB 1.3.4的CQ支持通过偏移配置实现非整点的固定日窗口聚合，你可以调整CQ的触发规则和窗口定义来满足需求：

正确的CQ SQL语句 #

CREATE CQ cq_daily_sum
RESAMPLE EVERY 1d BEGIN OFFSET 7h
BEGIN
SELECT sum(num)
INTO `root.lab.device_num_sum`(max_v)
FROM `root.lab.device_num`
GROUP BY (24h) OFFSET 7h
END;

语句说明 #

• RESAMPLE EVERY 1d BEGIN OFFSET 7h：设置CQ每日触发一次，触发时间为每日07:00（相对于零点偏移7小时）。
• GROUP BY (24h) OFFSET 7h：指定聚合窗口为前一天07:00至当日07:00的24小时固定窗口，OFFSET 7h用来将窗口起始点从零点偏移到7点。
• 触发时自动计算该窗口的总和，结果的时间戳默认是窗口结束时间（当日07:00），完全匹配你的需求。

二、原生CQ不满足时的替代方案 #

如果上述配置在实际场景中存在延迟或精度问题，可采用以下两种变通方法：

1. 外部定时任务脚本 #

通过外部定时任务（比如Linux的crontab），每日07:00执行预定义的查询语句，将结果写入目标时序：

-- 每日07:00执行该SQL，计算前一天07:00到当日07:00的总和
INSERT INTO `root.lab.device_num_sum`(max_v)
SELECT sum(num)
FROM `root.lab.device_num`
WHERE time >= now() - 24h - INTERVAL '7h' AND time < now() - INTERVAL '7h';

• 用crontab设置定时：0 7 * * * iotdb-cli -e "上述SQL语句"（需提前配置iotdb-cli的连接参数）。

2. 用户自定义函数（UDF）结合CQ #

如果需要更灵活的窗口控制，可以编写UDF来识别固定窗口的时间范围，再配合CQ定期触发计算，但这种方式开发成本较高，适合复杂场景。

内容的提问来源于stack exchange，提问作者何乐怡