如何使用 Node.js 从 InfluxDB 查询数据

Question

我正在做一个项目，我有一个 InfluxDB 桶，它的测量值为 elapsedtime，标签为 service。我想查询 Influx 以获取最近 1 小时内 foobar 的所有数据点作为服务。理想情况下，我稍后会添加一个时间测量值，我可以用它来计算我的 1 小时休息时间，因为获取经过时间的系统和将它写入 Influx 的系统是不同的，并且它们之间有大约 1-2 分钟的延迟。

我从 here 中获取了一些示例代码并且我得到了这个几乎相同的代码，因为我不确定需要更改什么并且无法理解文档（头脑不清楚？）。

这样做的最终目标是能够在我查询我的应用程序（查询 Influx）时获得显示服务 elapsedtime 的图表。我希望能够根据预设的服务和时间列表进行查询，但这是应用程序方面的事情，我在这里给出了我希望最终产生的结果的上下文。

...
variables that define bucket, url, org and token
...
const queryApi = new InfluxDB({url, token}).getQueryApi(org)
const fluxQuery =
  `from(bucket:"${bucket}") |> range(start: 0) |> filter(fn: (r) => r._measurement == "elapsedTime")`

console.log('*** QUERY ROWS ***')
// Execute query and receive table metadata and rows.
// https://v2.docs.influxdata.com/v2.0/reference/syntax/annotated-csv/
queryApi.queryRows(fluxQuery, {
  next(row: string[], tableMeta: FluxTableMetaData) {
    const o = tableMeta.toObject(row)
    console.log(
      `${o._time} ${o._measurement} in '${o.location}' (${o.example}): ${o._field}=${o._value}`
    )
  },
  error(error: Error) {
    console.error(error)
  },
  complete() {
    console.log('\nFinished SUCCESS')
  },
})

当我运行执行此操作时，我收到有关其中一个额外值的错误，但我希望该示例具有正确的代码，所以也许我遗漏了一些我需要更新的内容？

  next(row: string[], tableMeta: FluxTableMetaData) {
          ^

SyntaxError: Unexpected token ':'
    at wrapSafe (internal/modules/cjs/loader.js:992:16)
    at Module._compile (internal/modules/cjs/loader.js:1040:27)
    at Object.Module._extensions..js (internal/modules/cjs/loader.js:1097:10)
    at Module.load (internal/modules/cjs/loader.js:941:32)
    at Function.Module._load (internal/modules/cjs/loader.js:782:14)
    at Function.executeUserEntryPoint [as runMain] (internal/modules/run_main.js:72:12)
    at internal/main/run_main_module.js:17:47

Answer 1

问题最终是我复制的代码是 TypeScript，您可以想象它在 JavaScript 文件中不起作用。我犯了个愚蠢的错误

如何使用 Node.js 从 InfluxDB 查询数据

How to query data from InfluxDB using Node.js

time-series

node.js

influxdb

influxdb-2