Write to InfluxDB

To write data to InfluxDB using Flux, use to() or experimental.to(). Provide the following parameters to both functions:

• bucket or bucketID: InfluxDB bucket name or bucket ID to write to.
• org or orgID: InfluxDB organization name or organization ID to write to.
• host: InfluxDB URL or InfluxDB Cloud region URL.
• token: InfluxDB API token.

Write options

• Write data to InfluxDB
• Write pivoted data to InfluxDB

Write data to InfluxDB

Use to() to write data structured using the standard InfluxDB v2.x and InfluxDB Cloud data structure. Data must include, at a minimum, the following columns:

• _time
• _measurement
• _field
• _value

All other columns are written to InfluxDB as tags.

Given the following input stream of tables:

to() generates the following line protocol and writes it to InfluxDB:

m,id=001,loc=SF temp=72.1,hum=40.5 1609459200000000000
m,id=001,loc=SF temp=71.8,hum=50.1 1609462800000000000
m,id=001,loc=SF temp=71.2,hum=52.8 1609466400000000000

Example: Write data to a bucket

data
    |> to(bucket: "example-bucket")

data
    |> to(bucket: "example-bucket", org: "example-org", token: "mY5uPeRs3Cre7tok3N")

data
    |> to(
        bucket: "example-bucket",
        org: "example-org",
        token: "mY5uPeRs3Cre7tok3N",
        host: "https://myinfluxdbdomain.com/8086",
    )

Write pivoted data to InfluxDB

Use experimental.to() to write pivoted data to InfluxDB. Input data must have the following columns:

• _time
• _measurement

All columns in the group key other than _time and _measurement are written to InfluxDB as tags. Columns not in the group key are written to InfluxDB as fields.

To write pivoted data to InfluxDB:

1. Import the experimental package.
2. Use experimental.to() to write pivoted data to an InfluxDB bucket.

import "experimental"

data
    |> experimental.to(bucket: "example-bucket")

Given the following input stream of tables:

Group key = [_measurement, id, loc]

experimental.to() generates the following line protocol and writes it to InfluxDB:

m,id=001,loc=FR min=2i,max=6i,mean=4 1609459200000000000
m,id=001,loc=FR min=2i,max=18i,mean=10 1609462800000000000
m,id=001,loc=FR min=1i,max=13i,mean=7 1609466400000000000
m,id=001,loc=BK min=4i,max=4i,mean=4 1609459200000000000
m,id=001,loc=BK min=3i,max=5i,mean=4 1609462800000000000
m,id=001,loc=BK min=5i,max=3i,mean=6.5 1609466400000000000

Example: Write pivoted data to InfluxDB

import "experimental"

data
    |> experimental.to(bucket: "example-bucket")

import "experimental"

data
    |> experimental.to(bucket: "example-bucket", org: "example-org", token: "mY5uPeRs3Cre7tok3N")

import "experimental"

data
    |> experimental.to(
        bucket: "example-bucket",
        org: "example-org",
        token: "mY5uPeRs3Cre7tok3N",
        host: "https://myinfluxdbdomain.com/8086",
    )