我使用 Flux 查询从 InfluxDB 2 查询数据,例如:
from(bucket: "first")
|> range(start: time(v: 0))
|> filter(fn: (r) => r["_measurement"] == "test" and r._field == "volume")
|> keep(columns: ["_time", "_value"])
|> last()
这给了我一个正确的结果,但它给了我_time
列作为人类可读的日期。我需要一个时间戳。秒,毫秒,纳秒,没关系。
我尝试|> map(fn: (r) => ({ r with timestamp: uint(v: r._time) }))
在之前添加keep(...
并修改keep(...
以保留新字段。这仍然可以正常工作,但它显着增加了响应时间(这是可以理解的,为什么)。
我很确定我做错了,那么我该怎么做呢?
更新:我设法不增加响应时间。我搬到了|> map
下面last()
,但我仍然认为这不是最好的方法。