开始写入数据

使用 Telegraf 消费 Line Protocol，然后将其写入 InfluxDB Clustered。

1. 如果您尚未执行此操作，请按照说明 下载并安装 Telegraf。

2. 复制 家庭传感器数据示例 并将其保存到本地系统上的文件中，例如 home.lp。

   cat <<- EOF > home.lp
   home,room=Living\ Room temp=21.1,hum=35.9,co=0i 1641024000
   home,room=Kitchen temp=21.0,hum=35.9,co=0i 1641024000
   home,room=Living\ Room temp=21.4,hum=35.9,co=0i 1641027600
   home,room=Kitchen temp=23.0,hum=36.2,co=0i 1641027600
   home,room=Living\ Room temp=21.8,hum=36.0,co=0i 1641031200
   home,room=Kitchen temp=22.7,hum=36.1,co=0i 1641031200
   home,room=Living\ Room temp=22.2,hum=36.0,co=0i 1641034800
   home,room=Kitchen temp=22.4,hum=36.0,co=0i 1641034800
   home,room=Living\ Room temp=22.2,hum=35.9,co=0i 1641038400
   home,room=Kitchen temp=22.5,hum=36.0,co=0i 1641038400
   home,room=Living\ Room temp=22.4,hum=36.0,co=0i 1641042000
   home,room=Kitchen temp=22.8,hum=36.5,co=1i 1641042000
   home,room=Living\ Room temp=22.3,hum=36.1,co=0i 1641045600
   home,room=Kitchen temp=22.8,hum=36.3,co=1i 1641045600
   home,room=Living\ Room temp=22.3,hum=36.1,co=1i 1641049200
   home,room=Kitchen temp=22.7,hum=36.2,co=3i 1641049200
   home,room=Living\ Room temp=22.4,hum=36.0,co=4i 1641052800
   home,room=Kitchen temp=22.4,hum=36.0,co=7i 1641052800
   home,room=Living\ Room temp=22.6,hum=35.9,co=5i 1641056400
   home,room=Kitchen temp=22.7,hum=36.0,co=9i 1641056400
   home,room=Living\ Room temp=22.8,hum=36.2,co=9i 1641060000
   home,room=Kitchen temp=23.3,hum=36.9,co=18i 1641060000
   home,room=Living\ Room temp=22.5,hum=36.3,co=14i 1641063600
   home,room=Kitchen temp=23.1,hum=36.6,co=22i 1641063600
   home,room=Living\ Room temp=22.2,hum=36.4,co=17i 1641067200
   home,room=Kitchen temp=22.7,hum=36.5,co=26i 1641067200
   EOF
   

3. 运行以下命令以生成 Telegraf 配置文件 (telegraf.conf)，该文件启用 inputs.file 和 outputs.influxdb_v2 插件

   mkdir -p iot-project \
   && telegraf --sample-config \
     --input-filter file \
     --output-filter influxdb_v2 \
     > iot-project/telegraf.conf
   

4. 在编辑器中，打开 iot-project/telegraf.conf 并配置以下内容：

   • file 输入插件：在 [[inputs.file]].files 列表中，将 "/tmp/metrics.out" 替换为您的示例数据文件名。如果 Telegraf 在启动时找不到文件，它将停止处理并退出。

     [[inputs.file]]
       ## Files to parse each interval.  Accept standard unix glob matching rules,
       ## as well as ** to match recursive files and directories.
       files = ["home.lp"]
       # Set the timestamp precision to the precision in your data.
       influx_timestamp_precision = '1s'
       ## Optionally, use the newer, more efficient line protocol parser
       influx_parser_type = 'upstream' 
     

使用您已有的、已使用 InfluxDB v1 /write API 端点的工作负载写入数据。

要使用 InfluxDB v1 HTTP API 将数据写入 InfluxDB，请使用 POST 请求方法向 InfluxDB API /write 端点 发送请求。

POST https://cluster-host.com/write

在您的请求中包含以下内容：

• 标头:
  • Authorization（授权）：Bearer <INFLUX_TOKEN>
  • Content-Type（内容类型）：text/plain; charset=utf-8
  • Accept（接受）：application/json
• 查询参数:
  • db：InfluxDB 数据库名称
  • precision（精度）：时间戳精度（默认为 ns）
• 请求正文：Line Protocol，纯文本格式

以下示例使用 cURL 和 InfluxDB v1 API 将 Line Protocol 写入 InfluxDB

response=$(curl --silent --write-out "%{response_code}:-%{errormsg}" \
  "https://cluster-host.com/write?db=get-started&precision=s" \
  --header "Authorization: Bearer 
DATABASE_TOKEN
" \
  --header "Content-type: text/plain; charset=utf-8" \
  --header "Accept: application/json" \
  --data-binary "
home,room=Living\ Room temp=21.1,hum=35.9,co=0i 1641024000
home,room=Kitchen temp=21.0,hum=35.9,co=0i 1641024000
home,room=Living\ Room temp=21.4,hum=35.9,co=0i 1641027600
home,room=Kitchen temp=23.0,hum=36.2,co=0i 1641027600
home,room=Living\ Room temp=21.8,hum=36.0,co=0i 1641031200
home,room=Kitchen temp=22.7,hum=36.1,co=0i 1641031200
home,room=Living\ Room temp=22.2,hum=36.0,co=0i 1641034800
home,room=Kitchen temp=22.4,hum=36.0,co=0i 1641034800
home,room=Living\ Room temp=22.2,hum=35.9,co=0i 1641038400
home,room=Kitchen temp=22.5,hum=36.0,co=0i 1641038400
home,room=Living\ Room temp=22.4,hum=36.0,co=0i 1641042000
home,room=Kitchen temp=22.8,hum=36.5,co=1i 1641042000
home,room=Living\ Room temp=22.3,hum=36.1,co=0i 1641045600
home,room=Kitchen temp=22.8,hum=36.3,co=1i 1641045600
home,room=Living\ Room temp=22.3,hum=36.1,co=1i 1641049200
home,room=Kitchen temp=22.7,hum=36.2,co=3i 1641049200
home,room=Living\ Room temp=22.4,hum=36.0,co=4i 1641052800
home,room=Kitchen temp=22.4,hum=36.0,co=7i 1641052800
home,room=Living\ Room temp=22.6,hum=35.9,co=5i 1641056400
home,room=Kitchen temp=22.7,hum=36.0,co=9i 1641056400
home,room=Living\ Room temp=22.8,hum=36.2,co=9i 1641060000
home,room=Kitchen temp=23.3,hum=36.9,co=18i 1641060000
home,room=Living\ Room temp=22.5,hum=36.3,co=14i 1641063600
home,room=Kitchen temp=23.1,hum=36.6,co=22i 1641063600
home,room=Living\ Room temp=22.2,hum=36.4,co=17i 1641067200
home,room=Kitchen temp=22.7,hum=36.5,co=26i 1641067200
")

# Format the response code and error message output.
response_code=${response%%:-*}
errormsg=${response#*:-}

# Remove leading and trailing whitespace from errormsg
errormsg=$(echo "${errormsg}" | tr -d '[:space:]')

echo "$response_code"
if [[ $errormsg ]]; then
  echo "$errormsg"
fi

替换以下内容：

• DATABASE_TOKEN：具有足够权限访问指定数据库的数据库令牌

如果成功，输出将是 HTTP 204 No Content 状态代码；否则，输出将是错误状态代码和失败消息。

204

要使用 InfluxDB v2 HTTP API 将数据写入 InfluxDB，请使用 POST 请求方法向 InfluxDB API /api/v2/write 端点发送请求。

POST https://cluster-host.com/api/v2/write

在您的请求中包含以下内容：

• 标头:
  • Authorization（授权）：Bearer <INFLUX_TOKEN>
  • Content-Type（内容类型）：text/plain; charset=utf-8
  • Accept（接受）：application/json
• 查询参数:
  • bucket（存储桶）：InfluxDB 数据库名称
  • precision（精度）：时间戳精度（默认为 ns）
• 请求正文：Line Protocol，纯文本格式

以下示例使用 cURL 和 InfluxDB v2 API 将 Line Protocol 写入 InfluxDB

response=$(curl --silent --write-out "%{response_code}:-%{errormsg}" \
  "https://cluster-host.com/api/v2/write?bucket=get-started&precision=s" \
  --header "Authorization: Bearer 
DATABASE_TOKEN
" \
  --header "Content-Type: text/plain; charset=utf-8" \
  --header "Accept: application/json" \
  --data-binary "
home,room=Living\ Room temp=21.1,hum=35.9,co=0i 1641024000
home,room=Kitchen temp=21.0,hum=35.9,co=0i 1641024000
home,room=Living\ Room temp=21.4,hum=35.9,co=0i 1641027600
home,room=Kitchen temp=23.0,hum=36.2,co=0i 1641027600
home,room=Living\ Room temp=21.8,hum=36.0,co=0i 1641031200
home,room=Kitchen temp=22.7,hum=36.1,co=0i 1641031200
home,room=Living\ Room temp=22.2,hum=36.0,co=0i 1641034800
home,room=Kitchen temp=22.4,hum=36.0,co=0i 1641034800
home,room=Living\ Room temp=22.2,hum=35.9,co=0i 1641038400
home,room=Kitchen temp=22.5,hum=36.0,co=0i 1641038400
home,room=Living\ Room temp=22.4,hum=36.0,co=0i 1641042000
home,room=Kitchen temp=22.8,hum=36.5,co=1i 1641042000
home,room=Living\ Room temp=22.3,hum=36.1,co=0i 1641045600
home,room=Kitchen temp=22.8,hum=36.3,co=1i 1641045600
home,room=Living\ Room temp=22.3,hum=36.1,co=1i 1641049200
home,room=Kitchen temp=22.7,hum=36.2,co=3i 1641049200
home,room=Living\ Room temp=22.4,hum=36.0,co=4i 1641052800
home,room=Kitchen temp=22.4,hum=36.0,co=7i 1641052800
home,room=Living\ Room temp=22.6,hum=35.9,co=5i 1641056400
home,room=Kitchen temp=22.7,hum=36.0,co=9i 1641056400
home,room=Living\ Room temp=22.8,hum=36.2,co=9i 1641060000
home,room=Kitchen temp=23.3,hum=36.9,co=18i 1641060000
home,room=Living\ Room temp=22.5,hum=36.3,co=14i 1641063600
home,room=Kitchen temp=23.1,hum=36.6,co=22i 1641063600
home,room=Living\ Room temp=22.2,hum=36.4,co=17i 1641067200
home,room=Kitchen temp=22.7,hum=36.5,co=26i 1641067200
")

# Format the response code and error message output.
response_code=${response%%:-*}
errormsg=${response#*:-}

# Remove leading and trailing whitespace from errormsg
errormsg=$(echo "${errormsg}" | tr -d '[:space:]')

echo "$response_code"
if [[ $errormsg ]]; then
  echo "$errormsg"
fi

替换以下内容：

• DATABASE_TOKEN：具有足够权限访问指定数据库的数据库令牌

如果成功，输出将是 HTTP 204 No Content 状态代码；否则，输出将是错误状态代码和失败消息。

204

要使用 Python 将数据写入 InfluxDB Clustered，请使用 influxdb_client_3 模块。以下步骤包括设置 Python 虚拟环境，以便将依赖项限定在当前项目中。

1. 创建一个模块目录并导航到该目录，例如：

   mkdir -p influxdb_py_client && cd influxdb_py_client
   

2. 设置您的 Python 虚拟环境。在您的模块目录中，输入以下命令：

   python -m venv envs/virtual-env
   

3. 激活虚拟环境。

   source ./envs/virtual-env/bin/activate
   

4. 安装客户端库包

   pip install influxdb3-python
   

   influxdb3-python 包提供 influxdb_client_3 模块，并且还安装了 pyarrow 包，用于处理从查询返回的 Arrow 数据。

5. 在您的终端或编辑器中，为您的代码创建一个新文件，例如：write.py。

   touch write.py
   

6. 在 write.py 中，输入以下示例代码：

   from influxdb_client_3 import InfluxDBClient3
   import os
   
   # INFLUX_TOKEN is an environment variable you assigned to your
   # database WRITE token value.
   token = os.getenv('INFLUX_TOKEN')
   
   # host is the URL hostname without protocol or trailing slash
   client = InfluxDBClient3(
       host='cluster-host.com',
       org='',
       token=token,
       database='get-started'
   )
   
   lines = [
       "home,room=Living\ Room temp=21.1,hum=35.9,co=0i 1641024000",
       "home,room=Kitchen temp=21.0,hum=35.9,co=0i 1641024000",
       "home,room=Living\ Room temp=21.4,hum=35.9,co=0i 1641027600",
       "home,room=Kitchen temp=23.0,hum=36.2,co=0i 1641027600",
       "home,room=Living\ Room temp=21.8,hum=36.0,co=0i 1641031200",
       "home,room=Kitchen temp=22.7,hum=36.1,co=0i 1641031200",
       "home,room=Living\ Room temp=22.2,hum=36.0,co=0i 1641034800",
       "home,room=Kitchen temp=22.4,hum=36.0,co=0i 1641034800",
       "home,room=Living\ Room temp=22.2,hum=35.9,co=0i 1641038400",
       "home,room=Kitchen temp=22.5,hum=36.0,co=0i 1641038400",
       "home,room=Living\ Room temp=22.4,hum=36.0,co=0i 1641042000",
       "home,room=Kitchen temp=22.8,hum=36.5,co=1i 1641042000",
       "home,room=Living\ Room temp=22.3,hum=36.1,co=0i 1641045600",
       "home,room=Kitchen temp=22.8,hum=36.3,co=1i 1641045600",
       "home,room=Living\ Room temp=22.3,hum=36.1,co=1i 1641049200",
       "home,room=Kitchen temp=22.7,hum=36.2,co=3i 1641049200",
       "home,room=Living\ Room temp=22.4,hum=36.0,co=4i 1641052800",
       "home,room=Kitchen temp=22.4,hum=36.0,co=7i 1641052800",
       "home,room=Living\ Room temp=22.6,hum=35.9,co=5i 1641056400",
       "home,room=Kitchen temp=22.7,hum=36.0,co=9i 1641056400",
       "home,room=Living\ Room temp=22.8,hum=36.2,co=9i 1641060000",
       "home,room=Kitchen temp=23.3,hum=36.9,co=18i 1641060000",
       "home,room=Living\ Room temp=22.5,hum=36.3,co=14i 1641063600",
       "home,room=Kitchen temp=23.1,hum=36.6,co=22i 1641063600",
       "home,room=Living\ Room temp=22.2,hum=36.4,co=17i 1641067200",
       "home,room=Kitchen temp=22.7,hum=36.5,co=26i 1641067200"
   ]
   
   client.write(lines,write_precision='s')
   

   该示例执行以下操作：

   1. 从 influxdb_client_3 模块导入 InfluxDBClient3 对象。

   2. 调用 InfluxDBClient3() 构造函数以实例化配置了以下凭据的 InfluxDB 客户端：

      • host：InfluxDB 集群主机名（不带协议或尾部斜杠的 URL）
      • org：一个空字符串或任意字符串（InfluxDB 忽略此参数）
      • token：具有写入访问指定数据库权限的数据库令牌。将其存储在密钥存储或环境变量中，以避免暴露原始令牌字符串。
      • database：要写入的 InfluxDB Clustered 数据库的名称

   3. 定义 Line Protocol 字符串列表，其中每个字符串代表一条数据记录。

   4. 使用 Line Protocol 记录列表和写入选项调用 client.write() 方法。

      由于示例 Line Protocol 中的时间戳精度为秒，因此示例传递 write_precision='s' 选项以将时间戳精度设置为秒。

7. 要执行模块并将 Line Protocol 写入您的 InfluxDB Clustered 数据库，请在您的终端中输入以下命令：

   python write.py
   

要使用 Go 将数据写入 InfluxDB Clustered，请使用 InfluxDB 3 influxdb3-go 客户端库包。

1. 在您的项目目录中，创建一个新的模块目录并导航到该目录。

   mkdir -p influxdb_go_client && cd influxdb_go_client
   

2. 在该目录中初始化一个新的 Go 模块。

   go mod init influxdb_go_client
   

3. 在您的终端或编辑器中，为您的代码创建一个新文件，例如：write.go。

   touch write.go
   

4. 在 write.go 中，输入以下示例代码：

   package main
   
   import (
     "context"
     "os"
     "fmt"
     "log"
   
     "github.com/InfluxCommunity/influxdb3-go/v2/influxdb3"
   )
   
   // Write line protocol data to InfluxDB
   func WriteLineProtocol() error {
     // INFLUX_TOKEN is an environment variable you assigned to your
     // database WRITE token value.
     token := os.Getenv("INFLUX_TOKEN")
     database := os.Getenv("INFLUX_DATABASE")
   
     // Initialize a client with URL and token,
     // and set the timestamp precision for writes.
     client, err := influxdb3.New(influxdb3.ClientConfig{
       Host:     "https://cluster-host.com",
       Token:    token,
       Database: database,
       WriteOptions: &influxdb3.WriteOptions{Precision: lineprotocol.Second},
     })
   
     // Close the client when the function returns.
     defer func(client *influxdb3.Client) {
       err := client.Close()
       if err != nil {
         panic(err)
       }
     }(client)
   
     // Define line protocol records to write.
     // Use a raw string literal (denoted by backticks)
     // to preserve backslashes and prevent interpretation
     // of escape sequences--for example, escaped spaces in tag values.
     lines := [...]string{
       `home,room=Living\ Room temp=21.1,hum=35.9,co=0i 1641124000`,
       `home,room=Kitchen temp=21.0,hum=35.9,co=0i 1641124000`,
       `home,room=Living\ Room temp=21.4,hum=35.9,co=0i 1641127600`,
       `home,room=Kitchen temp=23.0,hum=36.2,co=0i 1641127600`,
       `home,room=Living\ Room temp=21.8,hum=36.0,co=0i 1641131200`,
       `home,room=Kitchen temp=22.7,hum=36.1,co=0i 1641131200`,
       `home,room=Living\ Room temp=22.2,hum=36.0,co=0i 1641134800`,
       `home,room=Kitchen temp=22.4,hum=36.0,co=0i 1641134800`,
       `home,room=Living\ Room temp=22.2,hum=35.9,co=0i 1641138400`,
       `home,room=Kitchen temp=22.5,hum=36.0,co=0i 1641138400`,
       `home,room=Living\ Room temp=22.4,hum=36.0,co=0i 1641142000`,
       `home,room=Kitchen temp=22.8,hum=36.5,co=1i 1641142000`,
       `home,room=Living\ Room temp=22.3,hum=36.1,co=0i 1641145600`,
       `home,room=Kitchen temp=22.8,hum=36.3,co=1i 1641145600`,
       `home,room=Living\ Room temp=22.3,hum=36.1,co=1i 1641149200`,
       `home,room=Kitchen temp=22.7,hum=36.2,co=3i 1641149200`,
       `home,room=Living\ Room temp=22.4,hum=36.0,co=4i 1641152800`,
       `home,room=Kitchen temp=22.4,hum=36.0,co=7i 1641152800`,
       `home,room=Living\ Room temp=22.6,hum=35.9,co=5i 1641156400`,
       `home,room=Kitchen temp=22.7,hum=36.0,co=9i 1641156400`,
       `home,room=Living\ Room temp=22.8,hum=36.2,co=9i 1641160000`,
       `home,room=Kitchen temp=23.3,hum=36.9,co=18i 1641160000`,
       `home,room=Living\ Room temp=22.5,hum=36.3,co=14i 1641163600`,
       `home,room=Kitchen temp=23.1,hum=36.6,co=22i 1641163600`,
       `home,room=Living\ Room temp=22.2,hum=36.4,co=17i 1641167200`,
       `home,room=Kitchen temp=22.7,hum=36.5,co=26i 1641167200`,
     }
   
     // Iterate over the lines array and write each line
     // separately to InfluxDB
     for _, record := range lines {
       err = client.Write(context.Background(), []byte(record))
       if err != nil {
         log.Fatalf("Error writing line protocol: %v", err)
       }
     }
   
     if err != nil {
       panic(err)
     }
   
     fmt.Println("Data has been written successfully.")
     return nil
   }
   

   该示例执行以下操作：

   1. 导入所需的包。

   2. 定义一个 WriteLineProtocol() 函数，该函数执行以下操作：

      1. 要实例化客户端，请调用 influxdb3.New(influxdb3.ClientConfig) 函数并传递以下内容：

         • Host：InfluxDB 集群 URL

         • Database：您的 InfluxDB Clustered 数据库的名称

         • Token：具有对指定数据库写入权限的数据库令牌。将其存储在密钥存储或环境变量中，以避免暴露原始令牌字符串。

         • WriteOptions：用于写入 InfluxDB 的 influxdb3.WriteOptions 选项。

           由于示例 Line Protocol 中的时间戳精度为秒，因此示例传递 Precision: lineprotocol.Second 选项以将时间戳精度设置为秒。

      2. 定义一个延迟函数，该函数在函数返回时关闭客户端。

      3. 定义 Line Protocol 字符串数组，其中每个字符串代表一条数据记录。

      4. 迭代 Line Protocol 数组，并调用写入客户端的 Write() 方法，将 Line Protocol 的每一行分别写入 InfluxDB。

5. 在编辑器中，创建一个 main.go 文件，并输入以下示例代码来调用 WriteLineProtocol() 函数：

   package main
   
   // Module main function
   func main() {
     WriteLineProtocol()
   }
   

6. 要安装依赖项并将数据写入您的 InfluxDB Clustered 数据库，请在终端中输入以下命令：

   go mod tidy && go run influxdb_go_client
   

如果成功，输出将是成功消息；否则，输出将是错误详细信息和失败消息。

1. 如果您尚未执行此操作，请按照 下载并安装 Node.js 和 npm 的说明进行操作。

2. 在您的终端中，输入以下命令为您的项目创建一个 influxdb_js_client 目录：

   mkdir influxdb_js_client && cd influxdb_js_client
   

3. 在 influxdb_js_client 中，输入以下命令以初始化包。此示例将包配置为使用 ECMAScript 模块 (ESM)。

   npm init -y; npm pkg set type="module"
   

4. 安装 @influxdata/influxdb3-client JavaScript 客户端库作为您项目的依赖项。

   npm install --save @influxdata/influxdb3-client
   

5. 在您的终端或编辑器中，创建一个 write.js 文件。

   touch write.js
   

6. 在 write.js 中，输入以下示例代码：

   // write.js
   import { InfluxDBClient } from '@influxdata/influxdb3-client';
   
   /**
    * Set InfluxDB credentials.
    */
   const host = 'cluster-host.com';
   const database = 'get-started';
   /**
    * INFLUX_TOKEN is an environment variable you assigned to your
    * WRITE token value.
    */
   const token = process.env.INFLUX_TOKEN;
   
   /**
    * Write line protocol to InfluxDB using the JavaScript client library.
    */
   export async function writeLineProtocol() {
     /**
      * Instantiate an InfluxDBClient
      */
     const client = new InfluxDBClient({ host, token });
   
     /**
      * Define line protocol records to write.
      */
     const records = [
       `home,room=Living\\ Room temp=21.1,hum=35.9,co=0i 1641124000`,
       `home,room=Kitchen temp=21.0,hum=35.9,co=0i 1641124000`,
       `home,room=Living\\ Room temp=21.4,hum=35.9,co=0i 1641127600`,
       `home,room=Kitchen temp=23.0,hum=36.2,co=0 1641127600`,
       `home,room=Living\\ Room temp=21.8,hum=36.0,co=0i 1641131200`,
       `home,room=Kitchen temp=22.7,hum=36.1,co=0i 1641131200`,
       `home,room=Living\\ Room temp=22.2,hum=36.0,co=0i 1641134800`,
       `home,room=Kitchen temp=22.4,hum=36.0,co=0i 1641134800`,
       `home,room=Living\\ Room temp=22.2,hum=35.9,co=0i 1641138400`,
       `home,room=Kitchen temp=22.5,hum=36.0,co=0i 1641138400`,
       `home,room=Living\\ Room temp=22.4,hum=36.0,co=0i 1641142000`,
       `home,room=Kitchen temp=22.8,hum=36.5,co=1i 1641142000`,
       `home,room=Living\\ Room temp=22.3,hum=36.1,co=0i 1641145600`,
       `home,room=Kitchen temp=22.8,hum=36.3,co=1i 1641145600`,
       `home,room=Living\\ Room temp=22.3,hum=36.1,co=1i 1641149200`,
       `home,room=Kitchen temp=22.7,hum=36.2,co=3i 1641149200`,
       `home,room=Living\\ Room temp=22.4,hum=36.0,co=4i 1641152800`,
       `home,room=Kitchen temp=22.4,hum=36.0,co=7i 1641152800`,
       `home,room=Living\\ Room temp=22.6,hum=35.9,co=5i 1641156400`,
       `home,room=Kitchen temp=22.7,hum=36.0,co=9i 1641156400`,
       `home,room=Living\\ Room temp=22.8,hum=36.2,co=9i 1641160000`,
       `home,room=Kitchen temp=23.3,hum=36.9,co=18i 1641160000`,
       `home,room=Living\\ Room temp=22.5,hum=36.3,co=14i 1641163600`,
       `home,room=Kitchen temp=23.1,hum=36.6,co=22i 1641163600`,
       `home,room=Living\\ Room temp=22.2,hum=36.4,co=17i 1641167200`,
       `home,room=Kitchen temp=22.7,hum=36.5,co=26i 1641167200`,
     ];
   
     /**
      * Creates an array that contains separate write request promises
      * for all the records.
      */
     const writePromises = records.map((record) => {
       return client.write(record, database, '', { precision: 's' }).then(
         () => `Data has been written successfully: ${record}`,
         () => `Failed writing data: ${record}`
       );
     });
   
     /**
      * Wait for all the write promises to settle, and then output the results.
      */
     const writeResults = await Promise.allSettled(writePromises);
     writeResults.forEach((write) => console.log(write.value));
   
     /** Close the client to release resources. */
     await client.close();
   }
   

   示例代码执行以下操作：

   1. 导入 InfluxDBClient 类。

   2. 调用 new InfluxDBClient() 构造函数并传递 ClientOptions 对象，以实例化配置了 InfluxDB 凭据的客户端。

      • host：您的 InfluxDB 集群 URL
      • token：具有对指定数据库写入权限的数据库令牌。将其存储在密钥存储或环境变量中，以避免暴露原始令牌字符串。

   3. 定义 Line Protocol 字符串列表，其中每个字符串代表一条数据记录。

   4. 为每个记录调用客户端的 write() 方法，定义要返回的成功或失败消息，并将挂起的 Promise 收集到 writePromises 数组中。每次调用 write() 都会传递以下参数：

      • record：Line Protocol 记录
      • database：要写入的 InfluxDB Clustered 数据库的名称
      • {precision}：一个 WriteOptions 对象，用于设置 precision 值。

      由于示例 Line Protocol 中的时间戳精度为秒，因此示例传递 s 作为 precision 值，以将写入时间戳精度设置为秒。

   5. 使用 Promise 数组调用 Promise.allSettled() 以暂停执行，直到 Promise 完成，然后将包含成功和失败消息的数组分配给 writeResults 常量。

   6. 迭代并打印 writeResults 中的消息。

   7. 关闭客户端以释放资源。

7. 在您的终端或编辑器中，创建一个 index.js 文件。

8. 在 index.js 中，输入以下示例代码以导入和调用 writeLineProtocol()：

   // index.js
   import { writeLineProtocol } from './write.js';
   
   /**
    * Execute the client functions.
    */
   async function main() {
     /** Write line protocol data to InfluxDB. */
     await writeLineProtocol();
   }
   
   main();
   

9. 在您的终端中，执行 index.js 以写入 InfluxDB Clustered

   node index.js
   

1. 如果您尚未执行此操作，请按照 Microsoft.com 下载说明 安装 .NET 和 dotnet CLI。

2. 在您的终端中，使用 .NET 控制台 模板创建一个可执行的 C# 项目。

   dotnet new console --name influxdb_csharp_client
   

3. 更改到生成的 influxdb_csharp_client 目录。

   cd influxdb_csharp_client
   

4. 运行以下命令以安装最新版本的 InfluxDB 3 C# 客户端库。

   dotnet add package InfluxDB3.Client
   

5. 在您的编辑器中，创建一个 Write.cs 文件，并输入以下示例代码：

   // Write.cs
   
   using System;
   using System.Threading.Tasks;
   using InfluxDB3.Client;
   using InfluxDB3.Client.Query;
   
   namespace InfluxDBv3;
   
   public class Write
   {
     /**
       * Writes line protocol to InfluxDB using the C# .NET client
       * library.
       */
     public static async Task WriteLines()
     {
       // Set InfluxDB credentials
       const string host = "https://cluster-host.com";
       string? database = "get-started";
   
       /**
         * INFLUX_TOKEN is an environment variable you assigned to your
         * WRITE token value.
         */
       string? token = System.Environment
           .GetEnvironmentVariable("INFLUX_TOKEN");
   
       // Instantiate the InfluxDB client with credentials.
       using var client = new InfluxDBClient(
           host, token: token, database: database);
   
       /**
         * Define an array of line protocol strings to write.
         * Include an additional backslash to preserve backslashes
         * and prevent interpretation of escape sequences---for example,
         * escaped spaces in tag values.
         */
       string[] lines = new string[] {
             "home,room=Living\\ Room temp=21.1,hum=35.9,co=0i 1641024000",
             "home,room=Kitchen temp=21.0,hum=35.9,co=0i 1641024000",
             "home,room=Living\\ Room temp=21.4,hum=35.9,co=0i 1641027600",
             "home,room=Kitchen temp=23.0,hum=36.2,co=0i 1641027600",
             "home,room=Living\\ Room temp=21.8,hum=36.0,co=0i 1641031200",
             "home,room=Kitchen temp=22.7,hum=36.1,co=0i 1641031200",
             "home,room=Living\\ Room temp=22.2,hum=36.0,co=0i 1641034800",
             "home,room=Kitchen temp=22.4,hum=36.0,co=0i 1641034800",
             "home,room=Living\\ Room temp=22.2,hum=35.9,co=0i 1641038400",
             "home,room=Kitchen temp=22.5,hum=36.0,co=0i 1641038400",
             "home,room=Living\\ Room temp=22.4,hum=36.0,co=0i 1641042000",
             "home,room=Kitchen temp=22.8,hum=36.5,co=1i 1641042000",
             "home,room=Living\\ Room temp=22.3,hum=36.1,co=0i 1641045600",
             "home,room=Kitchen temp=22.8,hum=36.3,co=1i 1641045600",
             "home,room=Living\\ Room temp=22.3,hum=36.1,co=1i 1641049200",
             "home,room=Kitchen temp=22.7,hum=36.2,co=3i 1641049200",
             "home,room=Living\\ Room temp=22.4,hum=36.0,co=4i 1641052800",
             "home,room=Kitchen temp=22.4,hum=36.0,co=7i 1641052800",
             "home,room=Living\\ Room temp=22.6,hum=35.9,co=5i 1641056400",
             "home,room=Kitchen temp=22.7,hum=36.0,co=9i 1641056400",
             "home,room=Living\\ Room temp=22.8,hum=36.2,co=9i 1641060000",
             "home,room=Kitchen temp=23.3,hum=36.9,co=18i 1641060000",
             "home,room=Living\\ Room temp=22.5,hum=36.3,co=14i 1641063600",
             "home,room=Kitchen temp=23.1,hum=36.6,co=22i 1641063600",
             "home,room=Living\\ Room temp=22.2,hum=36.4,co=17i 1641067200",
             "home,room=Kitchen temp=22.7,hum=36.5,co=26i 1641067200"
       };
   
       // Write each record separately.
       foreach (string line in lines)
       {
         // Write the record to InfluxDB with timestamp precision in seconds.
         await client.WriteRecordAsync(
             record: line, precision: WritePrecision.S);
         Console.WriteLine(
             "Data has been written successfully: {0,-30}", line);
       }
     }
   }
   

   该示例执行以下操作：

   1. 调用 new InfluxDBClient() 构造函数以实例化配置了 InfluxDB 凭据的客户端。

      • host：您的 InfluxDB 集群 URL
      • database：要写入的 InfluxDB Clustered 数据库的名称
      • token：具有对指定数据库写入权限的数据库令牌。将其存储在密钥存储或环境变量中，以避免暴露原始令牌字符串。

      using 语句确保程序在不再需要客户端时将其释放。

   2. 定义 Line Protocol 字符串数组，其中每个字符串代表一条数据记录。

   3. 调用客户端的 WriteRecordAsync() 方法以将每个 Line Protocol 记录写入 InfluxDB。

      由于示例 Line Protocol 中的时间戳精度为秒，因此示例将 WritePrecision.S 枚举值 传递给 precision: 选项，以将时间戳精度设置为秒。

6. 在您的编辑器中，打开 Program.cs 文件，并将其内容替换为以下内容：

   // Program.cs
   
   using System;
   using System.Threading.Tasks;
   
   namespace InfluxDBv3;
   
   public class Program
   {
     public static async Task Main()
     {
       await Write.WriteLineProtocol();
     }
   }
   

   Program 类与您在上一步中定义的 Write 类共享相同的 InfluxDBv3 命名空间，并定义了一个调用 Write.WriteLineProtocol() 的 Main() 函数。 dotnet CLI 将 Program.Main() 识别为程序的入口点。

7. 要构建和执行程序，并将 Line Protocol 写入您的 InfluxDB Clustered 数据库，请在终端中输入以下命令：

   dotnet run
   

如果成功，输出将是成功消息；否则，输出将是错误详细信息和失败消息。

本教程假设使用 Maven 版本 3.9 和 Java 版本 >= 15。

1. 如果您尚未执行此操作，请按照说明下载并安装适用于您系统的 Java JDK 和 Maven。

2. 在您的终端或编辑器中，使用 Maven 生成一个项目，例如：

   mvn org.apache.maven.plugins:maven-archetype-plugin:3.1.2:generate \
   -DarchetypeArtifactId="maven-archetype-quickstart" \
   -DarchetypeGroupId="org.apache.maven.archetypes" -DarchetypeVersion="1.4" \
   -DgroupId="com.influxdbv3" -DartifactId="influxdb_java_client"
   -Dversion="1.0"
   

   Maven 创建 <artifactId> 目录 (./influxdb_java_client)，其中包含 pom.xml 和您的 com.influxdbv3.influxdb_java_client Java 应用程序的支架。

3. 在您的终端或编辑器中，更改到 ./influxdb_java_client 目录，例如：

   cd ./influxdb_java_client
   

4. 在编辑器中，打开 pom.xml Maven 配置文件，并将 com.influxdb.influxdb3-java 客户端库添加到 dependencies 中。

   ...
   <dependencies>
     ...
     <dependency>
     <groupId>com.influxdb</groupId>
     <artifactId>influxdb3-java</artifactId>
     <version>0.1.0</version>
     </dependency>
     ...
   </dependencies>
   

5. 要检查您的 pom.xml 是否有问题，请运行 Maven 的 validate 命令，例如，在您的终端中输入以下内容：

   mvn validate
   

6. 在编辑器中，导航到 ./influxdb_java_client/src/main/java/com/influxdbv3 目录并创建一个 Write.java 文件。

7. 在 Write.java 中，输入以下示例代码：

   // Write.java
   package com.influxdbv3;
   
   import java.util.List;
   import com.influxdb.v3.client.InfluxDBClient;
   import com.influxdb.v3.client.write.WriteOptions;
   import com.influxdb.v3.client.write.WritePrecision;
   
   /**
     * Writes line protocol to InfluxDB using the Java client
     * library.
     */
   public final class Write {
       /**
       * Write data to InfluxDB 3.
       */
       private Write() {
           //not called
       }
   
       /**
         * @throws Exception
         */
       public static void writeLineProtocol() throws Exception {
   
           // Set InfluxDB credentials
           final String host = "https://cluster-host.com";
           final String database = "get-started";
   
           /**
             * INFLUX_TOKEN is an environment variable you assigned to your
             * WRITE token value.
             */
           final char[] token = (System.getenv("INFLUX_TOKEN")).
           toCharArray();
   
           // Instantiate the InfluxDB client.
           try (InfluxDBClient client = InfluxDBClient.getInstance(host,
           token, database)) {
               // Create a list of line protocol records.
               final List<String> records = List.of(
                 "home,room=Living\\ Room temp=21.1,hum=35.9,co=0i 1641024000",
                 "home,room=Kitchen temp=21.0,hum=35.9,co=0i 1641024000",
                 "home,room=Living\\ Room temp=21.4,hum=35.9,co=0i 1641027600",
                 "home,room=Kitchen temp=23.0,hum=36.2,co=0i 1641027600",
                 "home,room=Living\\ Room temp=21.8,hum=36.0,co=0i 1641031200",
                 "home,room=Kitchen temp=22.7,hum=36.1,co=0i 1641031200",
                 "home,room=Living\\ Room temp=22.2,hum=36.0,co=0i 1641034800",
                 "home,room=Kitchen temp=22.4,hum=36.0,co=0i 1641034800",
                 "home,room=Living\\ Room temp=22.2,hum=35.9,co=0i 1641038400",
                 "home,room=Kitchen temp=22.5,hum=36.0,co=0i 1641038400",
                 "home,room=Living\\ Room temp=22.4,hum=36.0,co=0i 1641042000",
                 "home,room=Kitchen temp=22.8,hum=36.5,co=1i 1641042000",
                 "home,room=Living\\ Room temp=22.3,hum=36.1,co=0i 1641045600",
                 "home,room=Kitchen temp=22.8,hum=36.3,co=1i 1641045600",
                 "home,room=Living\\ Room temp=22.3,hum=36.1,co=1i 1641049200",
                 "home,room=Kitchen temp=22.7,hum=36.2,co=3i 1641049200",
                 "home,room=Living\\ Room temp=22.4,hum=36.0,co=4i 1641052800",
                 "home,room=Kitchen temp=22.4,hum=36.0,co=7i 1641052800",
                 "home,room=Living\\ Room temp=22.6,hum=35.9,co=5i 1641056400",
                 "home,room=Kitchen temp=22.7,hum=36.0,co=9i 1641056400",
                 "home,room=Living\\ Room temp=22.8,hum=36.2,co=9i 1641060000",
                 "home,room=Kitchen temp=23.3,hum=36.9,co=18i 1641060000",
                 "home,room=Living\\ Room temp=22.5,hum=36.3,co=14i 1641063600",
                 "home,room=Kitchen temp=23.1,hum=36.6,co=22i 1641063600",
                 "home,room=Living\\ Room temp=22.2,hum=36.4,co=17i 1641067200",
                 "home,room=Kitchen temp=22.7,hum=36.5,co=26i 1641067200"
               );
   
               /**
                * Write each record separately to InfluxDB with timestamp
                * precision in seconds.
                * If no error occurs, print a success message.
                * */
               for (String record : records) {
                   client.writeRecord(record, new WriteOptions(null, null,
                   WritePrecision.S));
                   System.out.printf("Data has been written successfully:
                   %s%n", record);
               }
           }
       }
   }
   

   示例代码执行以下操作：

   1. 导入以下类：

      • java.util.List;
      • com.influxdb.v3.client.InfluxDBClient
      • com.influxdb.v3.client.write.WriteParameters
      • com.influxdb.v3.client.write.WritePrecision

   2. 调用 InfluxDBClient.getInstance() 以实例化配置了 InfluxDB 凭据的客户端。

      • host：您的 InfluxDB 集群 URL
      • database：要写入的 InfluxDB Clustered 数据库的名称
      • token：具有对指定数据库写入权限的数据库令牌。将其存储在密钥存储或环境变量中，以避免暴露原始令牌字符串。

   3. 定义 Line Protocol 字符串列表，其中每个字符串代表一条数据记录。

   4. 调用客户端的 writeRecord() 方法以将每个记录分别写入 InfluxDB。

      由于示例 Line Protocol 中的时间戳精度为秒，因此示例将 WritePrecision.S 枚举值 作为 precision 参数传递，以将写入时间戳精度设置为秒。

8. 在您的编辑器中，打开 App.java 文件（由 Maven 创建），并将其内容替换为以下示例代码：

   // App.java
   
   package com.influxdbv3;
   
   /**
   * Execute the client functions.
   *
   */
   public class App {
   
       /**
       * @param args
       * @throws Exception
       */
       public static void main(final String[] args) throws Exception {
           // Write data to InfluxDB 3.
           Write.writeLineProtocol();
       }
   }
   

   • App 类和 Write 类是同一 com.influxdbv3 包（您的项目 groupId）的一部分。
   • App 定义了一个调用 Write.writeLineProtocol() 的 main() 函数。

9. 在您的终端或编辑器中，使用 Maven 安装依赖项并编译项目代码，例如：

   mvn compile
   

10. 在您的终端或编辑器中，执行 App.main() 以写入 InfluxDB，例如使用 Maven：

    mvn exec:java -Dexec.mainClass="com.influxdbv3.App"
    

如果成功，输出将是成功消息；否则，输出将是错误详细信息和失败消息。