InfluxDBOutNode

Warning! This page documents an old version of Kapacitor, which is no longer actively developed. Kapacitor v1.2 is the most recent stable version of Kapacitor.

Writes the data to InfluxDB as it is received.

Example:

    stream
        .eval(lambda: "errors" / "total")
            .as('error_percent')
        // Write the transformed data to InfluxDB
        .influxDBOut()
            .database('mydb')
            .retentionPolicy('myrp')
            .measurement('errors')
            .tag('kapacitor', 'true')
            .tag('version', '0.2')

Properties

Property methods modify state on the calling node. They do not add another node to the pipeline, and always return a reference to the calling node.

Database

The name of the database.

node.database(value string)

Measurement

The name of the measurement.

node.measurement(value string)

Precision

The precision to use when writing the data.

node.precision(value string)

RetentionPolicy

The name of the retention policy.

node.retentionPolicy(value string)

Tag

Add a static tag to all data points. Tag can be called more than once.

node.tag(key string, value string)

WriteConsistency

The write consistency to use when writing the data.

node.writeConsistency(value string)