如何在DuckDB中实现时序数据的时间间隔分段聚合？

API 探路者

2026-7-8

DuckDB中时序数据的时间间隔聚合实现方案

DuckDB提供了专门的函数来实现类似IoTDB的时间分段聚合需求，最直接的方式是使用date_bin函数，它可以将时间序列数据按照指定的时间间隔进行分箱，再对每个分箱内的数据执行聚合计算。

核心实现示例

假设你的时序表结构包含timestamp（时间戳字段）、temperature（温度值）、status（状态字段），要查询最近7天的数据并按120秒（2分钟）间隔聚合，可使用以下SQL：

-- 按120秒间隔分箱，计算每个时间段的温度平均值和状态计数
SELECT
  date_bin(INTERVAL '120 seconds', timestamp, CURRENT_TIMESTAMP - INTERVAL '7 days') AS time_window_start,
  AVG(temperature) AS avg_temperature,
  COUNT(status) AS status_count
FROM
  your_time_series_table
WHERE
  timestamp >= CURRENT_TIMESTAMP - INTERVAL '7 days'
GROUP BY
  time_window_start
ORDER BY
  time_window_start;

关键参数说明

date_bin(INTERVAL 'N units', time_column, origin_time)：第一个参数是你需要的聚合间隔（比如INTERVAL '120 seconds'、INTERVAL '1 hour'），第二个参数是表中的时间戳字段，第三个参数是分箱的起始基准点（这里用最近7天的起始时间，确保分箱从该时间点开始对齐）。
过滤条件WHERE timestamp >= CURRENT_TIMESTAMP - INTERVAL '7 days'确保只查询最近7天的数据，避免不必要的全表扫描。
最后按分箱起始时间排序，保证结果按时间顺序输出，适配前端图表的展示逻辑。

其他可选方式

如果需要按标准时间单位（如小时、天）对齐聚合，也可以使用date_trunc函数，示例如下：

SELECT
  date_trunc('hour', timestamp) AS hour_start,
  AVG(temperature) AS avg_temperature
FROM
  your_time_series_table
WHERE
  timestamp >= CURRENT_TIMESTAMP - INTERVAL '7 days'
GROUP BY
  hour_start
ORDER BY
  hour_start;