1npm install --save-exact @influxdata/influxdb3-client@2.3.0

1pnpm add --save-exact @influxdata/influxdb3-client@2.3.0

1import {InfluxDBClient} from '@influxdata/influxdb3-client'
2
3const client = new InfluxDBClient({
4  host: process.env.TSDB_HOST_URL,
5  token: process.env.TSDB_AUTH_TOKEN,
6  database: process.env.TSDB_DATABASE_NAME,
7  writeOptions: {useV2Api: false},
8})
9
10try {
11  await client.write('cpu,host=server01 usage=42.5')
12
13  // 首次写入创建 Table 后，等待新表可查询。
14  await new Promise(resolve => setTimeout(resolve, 5000))
15
16  const sql =
17    "SELECT time, host, usage FROM cpu " +
18    "WHERE host = 'server01' ORDER BY time DESC LIMIT 1"
19  const rows = client.query(sql)
20  for await (const row of rows) {
21    console.log(row)
22  }
23} finally {
24  client.close()
25}