Influx Flux如何合并两个数据集并追加计算得到的可用性百分比字段

问题根因 #

你之前的写法失效是因为union()操作返回的是两行独立数据，map()函数为逐行处理逻辑，仅能访问当前行的字段，无法跨行读取另一个统计值，因此无法完成除法计算。

最简适配写法 #

针对你当前单设备、单时间范围的查询场景，直接提取统计标量值构造输出即可，完全匹配你需要的返回格式：

data = from(bucket: "foo")
    |> range(start:-1d)
    |> filter(fn: (r) => r._measurement == "io")
    |> filter(fn: (r) => r["device_id"] == "12345")
    |> filter(fn: (r) => r._field == "status_id" )

# 统计总点数
totals = data
    |> count(column: "_value")
    |> toFloat()
    |> set(key: "_field", value: "total_count")

# 统计在线点数
onlines = data
    |> filter(fn: (r) => r._value == 1)
    |> count(column: "_value")
    |> toFloat()
    |> set(key: "_field", value: "online_count")

# 提取两个统计的标量值
totalVal = totals |> findRecord(fn: (key) => true, idx: 0)
onlineVal = onlines |> findRecord(fn: (key) => true, idx: 0)

# 构造最终输出结构
array.from(rows: [
  {online_count: onlineVal._value},
  {total_count: totalVal._value},
  {availability: onlineVal._value / totalVal._value}
])

通用多维度适配写法 #

如果后续需要同时查询多个设备的统计数据，可以使用行转列+计算+列转行的逻辑实现：

data = from(bucket: "foo")
    |> range(start:-1d)
    |> filter(fn: (r) => r._measurement == "io")
    // 如果要查询多设备，去掉下面这行设备过滤条件即可
    |> filter(fn: (r) => r["device_id"] == "12345")
    |> filter(fn: (r) => r._field == "status_id" )

totals = data
    |> count(column: "_value")
    |> toFloat()
    |> set(key: "_field", value: "total_count")

onlines = data
    |> filter(fn: (r) => r._value == 1)
    |> count(column: "_value")
    |> toFloat()
    |> set(key: "_field", value: "online_count")

union(tables: [totals, onlines])
    // 按通用标签分组后行转列，让两个统计值落在同一行
    |> pivot(rowKey: ["_time", "device_id", "_measurement"], columnKey: ["_field"], valueColumn: "_value")
    // 计算可用率
    |> map(fn: (r) => ({r with availability: r.online_count / r.total_count}))
    // 列转回行，匹配所需输出结构
    |> melt(
        rowKey: ["_time", "device_id", "_measurement"],
        valueColumns: ["online_count", "total_count", "availability"]
    )
    // 可选：清理多余字段，只保留键值对输出
    |> keep(columns: ["_field", "_value"])

内容的提问来源于stack exchange，提问作者Juliën