我在理解如何使用join.inner()函数时遇到了一个问题。如果我对要使用join.iner函数的流使用limit()函数,我似乎只能得到一个结果(并且是正确的结果)。
如果不限制这个左流,我不会得到任何错误,只是没有结果。这是因为我如何得到左流?你知道我在这里做错了什么吗?
我对使用InfluxDB很熟悉,因此使用的是flux语言,所以必须是我。
谢谢大家的回答!
import "array" import "join" left = from(bucket: "TestBucket") |> range(start: 0) |> filter(fn: (r) => r["_measurement"] == "TestMeasurement") |> limit(n : 1000000000000000000) |> group() //|> yield(name: "LEFT") right = array.from( rows: [ {arrayValue: "123", _time: 2023-01-11T03:00:04.000Z}, ], ) //|> yield(name: "RIGHT") result = join.inner( left: left, right: right, on: (l, r) => l._time == r._time, // I made sure that there is indeed a common time as: (l, r) => ({l with rightValue: r.arrayValue}), ) |> yield(name: "RESULT")