InfluxDB Flux 加入系列

如何解决InfluxDB Flux 加入系列

我在 influxdb 中有以下数据

server,operation=ADD queryMs=7.9810 1620608972904452000
server,operation=GET queryMs=12.2430 1620608972909339200
server,operation=UPDATE queryMs=11.5780 1620608972909655400
server,operation=ADD queryMs=11.2460 1620608972910445700
server,operation=GET queryMs=15.0620 1620608972911305000
etc...

所以在我的图表中我看到三个系​​列

我想实现一系列所有 operation。

我尝试|> group(columns: ["_field"])，这正是我需要的，但查询速度非常慢！

from(bucket: "initial")
  |> range(start: v.timeRangeStart,stop: v.timeRangeStop)
  |> filter(fn: (r) => r["_measurement"] == "server")
  |> filter(fn: (r) => r["_field"] == "queryMs")
  |> group(columns: ["_field"])
  |> aggregateWindow(every: v.windowPeriod,fn: mean,createEmpty: false)
  |> yield(name: "mean")

我的问题有什么快速解决方案吗？

解决方法

这工作得更快

union(tables: [
  from(bucket: "initial")
    |> range(start: v.timeRangeStart,stop: v.timeRangeStop)
    |> filter(fn: (r) => r["_measurement"] == "server")
    |> filter(fn: (r) => r["_field"] == "queryMs")
    |> filter(fn: (r) => r["operation"] == "GET")
    |> aggregateWindow(every: v.windowPeriod,fn: mean,createEmpty: false),from(bucket: "initial")
    |> range(start: v.timeRangeStart,stop: v.timeRangeStop)
    |> filter(fn: (r) => r["_measurement"] == "server")
    |> filter(fn: (r) => r["_field"] == "queryMs")
    |> filter(fn: (r) => r["operation"] == "ADD")
    |> aggregateWindow(every: v.windowPeriod,stop: v.timeRangeStop)
    |> filter(fn: (r) => r["_measurement"] == "server")
    |> filter(fn: (r) => r["_field"] == "queryMs")
    |> filter(fn: (r) => r["operation"] == "UPDATE")
    |> aggregateWindow(every: v.windowPeriod,])
  |> drop(columns:["operation"])
  |> sort(columns: ["_time"],desc: false)
  |> aggregateWindow(every: v.windowPeriod,createEmpty: false)
  |> yield(name: "mean")