查询字段和标签
此页面记录了较早版本的 InfluxDB OSS。 InfluxDB OSS v2 是最新的稳定版本。 请参阅等效的 InfluxDB v2 文档: 查询字段和标签。
使用 filter()
函数 根据字段、标签或任何其他列值查询数据。 filter()
执行的操作类似于 InfluxQL 和其他类似 SQL 的查询语言中的 SELECT
语句和 WHERE
子句。
filter() 函数
filter()
有一个 fn
参数,该参数需要一个谓词函数,这是一个由一个或多个谓词表达式组成的匿名函数。谓词函数评估每个输入行。评估结果为 true
的行包含在输出数据中。评估结果为 false
的行将从输出数据中排除。
// ...
|> filter(fn: (r) => r._measurement == "example-measurement" )
fn
谓词函数需要一个 r
参数,该参数表示当 filter()
迭代输入数据时,每一行。行记录中的键值对表示列及其值。使用点表示法或括号表示法来引用谓词函数中的特定列值。使用 逻辑运算符 将多个谓词表达式链接在一起。
// Row record
r = {foo: "bar", baz: "quz"}
// Example predicate function
(r) => r.foo == "bar" and r["baz"] == "quz"
// Evaluation results
(r) => true and true
按字段和标签过滤
from()
、range()
和 filter()
的组合代表最基本的 Flux 查询
- 使用
from()
定义您的 bucket。 - 使用
range()
按时间限制查询结果。 - 使用
filter()
识别要输出的数据行。
from(bucket: "db/rp")
|> range(start: -1h)
|> filter(fn: (r) =>
r._measurement == "example-measurement" and
r._field == "example-field" and
r.tag == "example-tag"
)
此页是否对您有帮助?
感谢您的反馈!