如何通过InfluxDB2 Flux查询聚合多结果，解决Grafana词云重复问题

修改后的Flux查询 #

from(bucket: v.bucket)
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r._measurement == "wordcount")
  |> group(columns: ["_field"])
  |> sum(column: "_value")
  |> group()
  |> pivot(rowKey: [], columnKey: ["_field"], valueColumn: "_value")
  |> sort(columns: ["_value"], desc: true)

关键步骤说明 #

• 按词汇分组：group(columns: ["_field"]) 将数据按每个词汇（对应字段名）单独分组，确保后续求和操作针对每个词汇的所有记录生效。
• 求和聚合：sum(column: "_value") 计算时间范围内每个词汇的总出现次数，直接解决重复计数的问题。
• 取消分组：group() 解除按字段的分组，让所有聚合结果处于同一组，为转成单行做准备。
• 转宽表合并行：pivot(...) 将多行的词汇-计数数据转换为单行，每个词汇作为列、总计数作为对应值，完全匹配你需要的合并效果。
• 排序（可选）：保留原查询的sort步骤，让词汇按总计数从高到低排序，适配词云的展示逻辑。

补充说明 #

如果你的数据中items标签是用来区分不同数据源/场景的，且需要按items分别聚合，只需调整分组逻辑：

from(bucket: v.bucket)
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r._measurement == "wordcount")
  |> group(columns: ["items", "_field"])
  |> sum(column: "_value")
  |> group(columns: ["items"])
  |> pivot(rowKey: ["items"], columnKey: ["_field"], valueColumn: "_value")
  |> sort(columns: ["_value"], desc: true)

内容的提问来源于stack exchange，提问作者user657127