query.filterMeasurement() 函数
query.filterMeasurement()
是实验性的,并且随时可能更改。
query.filterMeasurement()
按 measurement 过滤输入数据。
函数类型签名
(<-table: stream[{B with _measurement: C}], measurement: A) => stream[{B with _measurement: C}] where A: Equatable, C: Equatable
有关更多信息,请参阅函数类型签名。
参数
measurement
(必需)要按其过滤的 InfluxDB measurement 名称。
table
输入数据。默认值为管道转发数据 (<-
)。
示例
从 InfluxDB 中查询特定 measurement 中的数据
import "experimental/query"
query.fromRange(bucket: "example-bucket", start: -1h)
|> query.filterMeasurement(measurement: "example-measurement")
此页是否对您有帮助?
感谢您的反馈!