fixed it
from(bucket: “netatmo”)
|> range(start: v.timeRangeStart, stop: v.timeRangeStop)
|> filter(fn: (r) => r[“_measurement”] == “WindStrength” or r[“_measurement”] == “WindAngle”)
|> filter(fn: (r) => r[“_field”] == “value”)
|> pivot(rowKey:[“_time”], columnKey: [“_measurement”], valueColumn: “_value”) // put dir and speed values into the same row based on timestamps
|> filter(fn: (r) => exists r[“WindAngle”] and exists r[“WindStrength”]) // drop rows that donot have both values
|> rename(columns: {“WindAngle”: “direction”, “WindStrength”: “speed”})
//|> map(fn: (r) => ({ r with direction: r.directionRad / 3.14 * 180.0 })) // convert to degrees from radians
//|> map(fn: (r) => ({ r with speed: r.speedMps / 0.514 })) // convert to knots from m/s
|> aggregateWindow(every: v.windowPeriod, fn: first, column: “direction”, createEmpty: false) // sample the first row for each window (real aggregation would show fake values in gusty winds)
1 Like