使用 InfluxDB v2 JavaScript 客户端库写入数据

使用 InfluxDB v2 JavaScript 客户端库 从 Node.js 环境向 InfluxDB 写入数据。

JavaScript 客户端库包括以下便捷功能，用于向 InfluxDB 写入数据

• 将默认标签应用于数据点。
• 将点缓冲到批次中以优化数据传输。
• 在失败时自动重试请求。
• 为您的网络设置可选的 HTTP 代理地址。

开始之前

• 安装客户端库和其他依赖项.

使用客户端库写入数据

1. 通过使用您的 InfluxDB URL 和数据库令牌（您已在安装部分中设置的环境变量）调用 new InfluxDB() 构造函数来实例化客户端。

   import {InfluxDB, Point} from '@influxdata/influxdb-client'
   
   const influxDB = new InfluxDB({url: process.env.INFLUX_URL,
                                  token: process.env.INFLUX_TOKEN})
   

2. 使用客户端的 getWriteApi() 方法创建一个写入客户端。提供您的 InfluxDB 组织 ID 和数据库名称。

   const writeApi = influxDB.getWriteApi(process.env.INFLUX_ORG,
                                          process.env.INFLUX_DATABASE)
   

3. 要将一个或多个标签应用于所有点，请使用 useDefaultTags() 方法。以键/值对的对象形式提供标签。

   writeApi.useDefaultTags({region: 'west'})
   

4. 使用 Point() 构造函数创建一个点。

   1. 调用构造函数并提供一个measurement。
   2. 要添加一个或多个标签，请将 tag() 方法链接到构造函数。提供 name 和 value。
   3. 要添加 float 类型的字段，请将 floatField() 方法链接到构造函数。提供 name 和 value。

   const point1 = new Point('temperature')
     .tag('sensor_id', 'TLM010')
     .floatField('value', 24.0)
   

5. 使用 writePoint() 方法将点写入您的 InfluxDB bucket。最后，使用 close() 方法刷新所有待处理的写入。该示例将新数据点，然后是 “WRITE FINISHED” 记录到 stdout。

   writeApi.writePoint(point1)
   
   writeApi.close().then(() => {
     console.log('WRITE FINISHED')
   })
   

完整示例

'use strict'
/** @module write
 * Writes a data point to InfluxDB using the JavaScript client library with Node.js.
**/

import {InfluxDB, Point} from '@influxdata/influxdb-client'

/**
 * Instantiate the InfluxDB client
 * with a configuration object.
 **/
const influxDB = new InfluxDB({url: process.env.INFLUX_URL,
                              token: process.env.INFLUX_TOKEN})

/**
 * Create a write client from the getWriteApi method.
 * Provide your org and database.
 **/
const writeApi = influxDB.getWriteApi(process.env.INFLUX_ORG,
                                      process.env.INFLUX_DATABASE)

/**
 * Apply default tags to all points.
 **/
writeApi.useDefaultTags({region: 'west'})

/**
 * Create a point and write it to the buffer.
 **/
const point1 = new Point('temperature')
  .tag('sensor_id', 'TLM01')
  .floatField('value', 24.0)
console.log(` ${point1}`)

writeApi.writePoint(point1)

/**
 * Flush pending writes and close writeApi.
 **/
writeApi.close().then(() => {
  console.log('WRITE FINISHED')
})

在您的终端中使用环境变量或已设置的 env.js，运行以下命令以执行 JavaScript 文件

node write.js

响应代码

有关 InfluxDB API 响应代码的信息，请参阅 InfluxDB API 写入文档。