填充数据空缺

使用 date_bin_gapfill 与 interpolate 或 locf 来填充没有返回数据的时间间隔的空白。空白填充 SQL 查询通过用插值值填充间隔或通过携带最后一个可用观察值来处理时间序列数据中的缺失数据。

填充数据空白

1. 使用 date_bin_gapfill 函数将数据窗口化为基于时间的组，并对每个窗口应用一个 聚合函数。如果一个窗口中没有数据，date_bin_gapfill 会插入一个新行，其中包含窗口的起始时间戳，在 GROUP BY 子句中填充所有列，以及对于查询字段使用空值。

2. 使用 interpolate 或 locf 来填充指定列中的插入空值。

   • interpolate: 通过在非空值之间插值来填充空值。
   • locf: 通过将最后一个观察值向前传递来填充空值。

   传递给 interpolate 或 locf 的表达式必须使用一个 聚合函数。

3. 包含一个 WHERE 子句，设置时间上界和下界。例如

WHERE time >= '2022-01-01T08:00:00Z' AND time <= '2022-01-01T10:00:00Z'

填充数据空白的示例

以下示例使用InfluxDB 入门教程中提供的示例数据集，以展示如何使用date_bin_gapfill以及interplate和locf的不同结果。

SELECT
  date_bin_gapfill(INTERVAL '30 minutes', time) as _time,
  room,
  interpolate(avg(temp))
FROM home
WHERE
    time >= '2022-01-01T08:00:00Z'
    AND time <= '2022-01-01T10:00:00Z'
GROUP BY _time, room

SELECT
  date_bin_gapfill(INTERVAL '30 minutes', time) as _time,
  room,
  locf(avg(temp))
FROM home
WHERE
    time >= '2022-01-01T08:00:00Z'
    AND time <= '2022-01-01T10:00:00Z'
GROUP BY _time, room