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

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

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

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

开始之前

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

使用客户端库写入数据

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

   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_BUCKET)

3. To apply one or more [tags](/influxdb3/cloud-serverless/reference/glossary/#tag) to all points, use the `useDefaultTags()` method.
Provide tags as an object of key/value pairs.

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

4. Use the `Point()` constructor to create a [point](/influxdb3/cloud-serverless/reference/glossary/#point).
1. Call the constructor and provide a [measurement](/influxdb3/cloud-serverless/reference/glossary/#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`.

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

5. Use the `writePoint()` method to write the point to your InfluxDB bucket.
Finally, use the `close()` method to flush all pending writes.
The example logs the new data point followed by "WRITE FINISHED" to stdout.

 ```js
 writeApi.writePoint(point1)

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

### Complete example

```js
'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.
* Provide your InfluxDB URL and API token.
**/
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 bucket.
**/
const writeApi = influxDB.getWriteApi(process.env.INFLUX_ORG,
                                   process.env.INFLUX_BUCKET)

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