文档文档

monitor.stateChangesOnly() 函数

monitor.stateChangesOnly() 接收包含 _level 列的表流,并返回按 _level 分组的表流,其中每个记录代表一个状态更改。

函数类型签名
(<-tables: stream[{A with _level: B}]) => stream[C] where B: Equatable, C: Record

有关更多信息,请参见函数类型签名

参数

tables

输入数据。默认为管道转发数据 (<-)。

示例

返回表示状态更改的记录

import "array"
import "influxdata/influxdb/monitor"

data =
    array.from(
        rows: [
            {_time: 2021-01-01T00:00:00Z, _level: "ok"},
            {_time: 2021-01-01T00:01:00Z, _level: "ok"},
            {_time: 2021-01-01T00:02:00Z, _level: "warn"},
            {_time: 2021-01-01T00:03:00Z, _level: "crit"},
        ],
    )

data
    |> monitor.stateChangesOnly()

查看示例输入和输出


此页是否对您有帮助?

感谢您的反馈!


Flux 的未来

Flux 将进入维护模式。 您可以继续像现在一样使用它,而无需对您的代码进行任何更改。

了解更多

InfluxDB 3 开源版本现已推出公共 Alpha 版

InfluxDB 3 开源版本现已可用于 Alpha 测试,并已获得 MIT 或 Apache 2 许可。

我们将发布两个产品作为 Alpha 版的一部分。

InfluxDB 3 Core 是我们新的开源产品。 它是用于时间序列和事件数据的最新数据引擎。 InfluxDB 3 Enterprise 是一个商业版本,它建立在 Core 的基础上,增加了历史查询功能、读取副本、高可用性、可扩展性和细粒度的安全性。

有关如何开始使用的更多信息,请查看