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

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

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

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

开始之前

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

使用客户端库写入数据

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

   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. 要将一个或多个 tags 应用到所有点，请使用 useDefaultTags() 方法。以键/值对的对象形式提供标签。

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

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

   1. Call the constructor and provide a measurement.
   2. To add one or more tags, chain the tag() method to the constructor. Provide a name and value.
   3. To add a field of type float, chain the floatField() method to the constructor. Provide a name and value.

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

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

   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 写入文档。