写入 InfluxDB

要使用 Flux 将数据写入 InfluxDB，请使用 to() 或 experimental.to()。 为这两个函数提供以下参数

• bucket 或 bucketID: 要写入的 InfluxDB bucket 名称 或 bucket ID。
• org 或 orgID: 要写入的 InfluxDB 组织名称 或 组织 ID。
• host: InfluxDB URL 或 InfluxDB Cloud 区域 URL。
• token: InfluxDB API 令牌。

写入选项

• 将数据写入 InfluxDB
• 将透视数据写入 InfluxDB

将数据写入 InfluxDB

使用 to() 写入使用标准 InfluxDB v2.x 和 InfluxDB Cloud 数据结构 结构化的数据。 数据必须至少包含以下列

• _time
• _measurement
• _field
• _value

所有其他列都作为 标签 写入 InfluxDB。

给定以下输入 表流

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

示例：将数据写入 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",
    )

将透视数据写入 InfluxDB

使用 experimental.to() 将 透视 数据写入 InfluxDB。 输入数据必须具有以下列

• _time
• _measurement

分组键 中除 _time 和 _measurement 之外的所有列都作为 标签 写入 InfluxDB。 不在分组键中 的列作为 字段 写入 InfluxDB。

要将透视数据写入 InfluxDB

1. 导入 experimental 包。
2. 使用 experimental.to() 将透视数据写入 InfluxDB bucket。

import "experimental"

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

给定以下输入 表流

分组键 = [_measurement, id, loc]

experimental.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

示例：将透视数据写入 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",
    )