杂项 SQL 函数

InfluxDB SQL 实现支持以下杂项函数以执行各种操作

• arrow_cast
• arrow_typeof
• interpolate
• locf

arrow_cast

将值转换为特定 Arrow 数据类型。

arrow_cast(expression, datatype)

参数

• expression: 要转换的表达式。可以是常量、列或函数，以及算术或字符串运算符的任意组合。
• datatype: 要转换到的 Arrow 数据类型。

SELECT
  arrow_cast(time, 'Int64') AS time,
  arrow_cast(temp, 'Utf8') AS temp,
  arrow_cast(co, 'Float64')AS co
FROM home
LIMIT 1

arrow_typeof

返回表达式的底层 Arrow 数据类型。

arrow_typeof(expression)

参数

• expression: 要评估的表达式。可以是常量、列或函数，以及算术或字符串运算符的任意组合。

SELECT
  arrow_typeof(time) AS time,
  arrow_typeof(room) AS room,
  arrow_typeof(temp) AS temp,
  arrow_typeof(co) AS co
FROM home
LIMIT 1

interpolate

通过插值现有值来填充指定聚合列中的空值。必须与 date_bin_gapfill 一起使用。

interpolate(aggregate_expression)

参数

• aggregate_expression: 对指定表达式的聚合操作。操作可以使用任何 聚合函数。表达式可以是常量、列或函数，以及聚合函数支持的算术运算符的任意组合。

相关函数

date_bin_gapfill, 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

locf

使用date_bin_gapfill填充指定聚合列中的空值。必须与date_bin_gapfill一起使用。

LOCF是“last observation carried forward”（最后观测值前推）的缩写。

locf(aggregate_expression)

参数

• aggregate_expression: 对指定表达式的聚合操作。操作可以使用任何 聚合函数。表达式可以是常量、列或函数，以及聚合函数支持的算术运算符的任意组合。

相关函数

date_bin_gapfill，interpolate

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