杂项 SQL 函数

InfluxDB 集群 SQL 实现支持以下杂项功能，以执行多种操作：

• arrow_cast
• arrow_typeof
• 插值
• locf

箭头转换

将值转换为特定的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 数据类型：

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

插值

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

interpolate(aggregate_expression)

参数

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

相关函数

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 一起使用。

LOCF是“最后观察延续”的首字母缩略词。

locf(aggregate_expression)

参数

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

相关函数

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