InfluxDB Flux - 过滤字段匹配值

Question

我正在使用 InfluxDB与 Grafana ，我有一个名为 items 的测量值带有一些标签和一个名为 itemType 的字段.我需要过滤 itemType 的行是某个字符串。以下 InfluxQL 查询正是我所需要的:

SELECT * FROM "items" WHERE "itemType" = 'example'

我如何在 Flux 中做同样的事情?
我目前有以下查询，它执行除按字段过滤之外的所有操作:

from(bucket: "dbname/autogen")
    |> range(start: 2020-10-12T01:56:34Z, stop: 2020-10-12T02:54:10Z)
    |> filter(fn:(r) => r._measurement == "items")
    |> aggregateWindow(every: 5m, fn: count)

但是更换了 filter功能与 filter(fn:(r) => r._measurement == "items" and r.itemType == "example")不返回结果，即使上面的 InfluxQL 查询在 InfluxDB CLI 中使用时确实返回数据。

Answer 1

如果 ，您指定的通量查询将起作用itemType 是一个标签，但是，因为它是一个字段，使查询工作的方法之一是通过对字段名称及其值设置条件，如下所示:

from(bucket: "dbname/autogen")
    |> range(start: 2020-10-12T01:56:34Z, stop: 2020-10-12T02:54:10Z)
    |> filter(fn:(r) => r._measurement == "items" and r._field == "itemType" and r._value == "example")
    |> aggregateWindow(every: 5m, fn: count)