我正在做一个项目,我有一个 InfluxDB 存储桶,其尺寸elapsedtime
为service
. 我想查询 Influx 以获取过去 1 小时内的所有数据点foobar
作为服务。理想情况下,我稍后会添加一个时间测量值,我可以用它来确定我的 1 小时休息时间,因为获取经过时间的系统和将其写入 Influx 的系统是不同的,它们之间有大约 1-2 分钟的延迟。
我从这里获取了一些示例代码,并且得到了几乎相同的代码,因为我不确定需要更改什么并且无法理解文档(头部多云?)。
这样做的最终目标是能够elapsedtime
在我查询我的应用程序时显示一个服务的图表 - 它查询 Influx。我希望能够根据预设的服务和时间列表进行查询,但这是应用程序方面的事情,我在这里给出我希望最终产生的结果的上下文。
...
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