I am trying to filter based on two values for two different fields

Fluxlang
1

from(bucket: “data”)
|> range(start: -999d, stop: now())
|> filter(fn: (r) => (
r[“testFile”] == “70” and
(
( (r[“_field”] == “wind” and r[“_value”] > 5000) and (r[“_field”] == “speed” and r[“_value”] > 90) )
)
))
|> keep(columns: [“_measurement”,“_field”,“_value”])
|> group()
|> distinct(column: “_measurement”)
|> limit(n: 1000)
|> sort()

I am trying to find _measurement where wind > 500 let AND ALSO speed > 90 in the same _measurement . I think my mistake here is it is anding the _field which can’t happen so I am getting no data

2

@Adrelien Sorry this answer is a little late, but if you’re still looking to solve this problem, I think I have a solution. To return rows based on the value of two fields, you have to pivot fields into columns in each row. You can then filter rows based on the values for each field:

from(bucket: "data")
    |> range(start: -999d, stop: now())
    |> filter(fn: (r) => r["testFile"] == "70")
    |> filter(fn: (r) => r["_field"] == "wind" or r["_field"] == "speed")
    |> pivot(rowKey: ["_time"], columnKey: ["_field"], valueColumn: "_value")
    |> filter(fn: (r) => r["wind"] > 5000 and r["speed"] > 90)
    |> keep(columns: ["_measurment", "_time", "wind", "speed"])
1 Like