InfluxQL查询到Flux转换

Question

我想从InfluxQL切换到通量，但是现在我想转换查询：

SELECT sum("execution_duration") / sum("interval_duration) as "Availability" FROM "data-oee" WHERE $timeFilter GROUP BY time($time_interval)

不断变化的语言，但还不能完全完成。我在这里做错什么了？

我的Flux查询：

from(bucket: "Dashboard")
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["_measurement"] == "oee-data")
  |> filter(fn: (r) => r["machine"] == "ilv")
  |> cumulativeSum(columns: ["duration"])
  |> cumulativeSum(columns: ["production_duration"])
  |> group(columns: ["_time"])
  |> aggregateWindow(every: 1d, fn: mean, createEmpty: false)
  |> yield(name: "mean")

我有个错误：

 error @5:44-5:78: missing required argument tables

Answer 1

从"data-oee“中选择sum("execution_duration") / sum("interval_duration")作为”可用性“，其中$timeFilter按时间分组($time_interval)

在这个流入的查询中，我假设您只使用在查询中写入的数据，例如使用名为" data -oee“的度量中的"execution_duration”和"interval_duration“两个列字段，因此，要根据存储在其中的不同值来划分"_field”列，我们必须使用pivot()函数，然后使用任何计算将两个查询的数据分组到一个列中(比如‘+’/‘’/‘’*‘/’/‘’)，您需要使用map()函数。查询的内容如下：

from(bucket: "Dashboard")
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["_measurement"] == "oee-data")
  |> filter(fn: (r) => r["machine"] == "ilv")
  |> filter(fn: (r) => r["_field"] == "execution_duration" or r["_field"] == "interval_duration" )
  |> group(columns: ["_field"])
  |> aggregateWindow(every: 1d, fn: sum, createEmpty: false)
  |> pivot(rowKey: ["_time"], columnKey: ["_field"], valueColumn: "_value")
  |> map(fn: (r) => ({r with _value: (r.execution_duration/r.interval_duration)}))  
  |> yield(name: "sum")

我无法理解的是，当您必须计算列中值的和时，为什么要在aggregatewWindow中使用平均值？也许这种通量语法会帮助某人..。我很难调剂一下。

(稍后谢谢我;)