Skip to content

Create

1
2
3
4
5
6
7
from(bucket: "oems-edge")
  |> range(start: 2023-06-29T13:00:00.000Z, stop: now())
  |> filter(fn: (r) => r["_measurement"] == "data")
  |> filter(fn: (r) => r["_field"] == "meter-production/ActivePower" or r["_field"] == "meter-grid/ActivePower" or r["_field"] == "meter-grid-1/ActivePower" or r["_field"] == "meter-grid-2/ActivePower" or r["_field"] == "meter-consumption/ActivePower" or r["_field"] == "meter-ess/ActivePower")
  |> aggregateWindow(every: 15m, fn: mean, createEmpty: true)
  |> keep(columns: ["_field", "_time", "_value"])
  |> pivot(rowKey: ["_time"], columnKey: ["_field"], valueColumn: "_value")