如何根据其他字段值 Flux 过滤字段答案

【问题标题】：How can filter a field based on other field value Flux如何根据其他字段值 Flux 过滤字段
【发布时间】：2021-03-29 04:04:47
【问题描述】：

如何根据用户的特定值过滤值时间戳？我尝试了以下但没有返回结果。我想唯一地显示时间戳值。时间戳和用户都是 mqtt_consumer 中的字段。

from(bucket: "manager")
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["_measurement"] == "mqtt_consumer")
  |> filter(fn: (r) => r["_field"] == "timestamp")
  |> filter(fn: (r) => r["_field"] == "user" and r["_value"] == 225)
  |> aggregateWindow(every: v.windowPeriod, fn: mean, createEmpty: false)
  |> yield(name: "mean")

【问题讨论】：

标签： python filter flux

【解决方案1】：

您似乎必须先调整结果，但这可能不是最有效的方法（请参阅此处的讨论 GitHub）在你的情况下，这将是这样的：

import "influxdata/influxdb/v1"
from(bucket: "manager")
 |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
 |> filter(fn: (r) => r["_measurement"] == "mqtt_consumer")
 |> filter(fn: (r) => r["_field"] == "timestamp" or r["_field"] == "user")
 |> v1.fieldsAsCols()
 |> filter(fn: (r) => r["user"] == 255

【讨论】：