Documentation

monitor.stateChangesOnly() function

monitor.stateChangesOnly() takes a stream of tables that contains a _level column and returns a stream of tables grouped by _level where each record represents a state change.

Function type signature
(<-tables: stream[{A with _level: B}]) => stream[C] where B: Equatable, C: Record
For more information, see Function type signatures.

Parameters

tables

Input data. Default is piped-forward data (<-).

Examples

Return records representing state changes

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()

View example input and output


Was this page helpful?

Thank you for your feedback!


Upgrade to InfluxDB Cloud or InfluxDB 2.0!

InfluxDB Cloud and InfluxDB OSS 2.0 ready for production.