InfluxDB Inner Join未返回预期数据，请求排查问题

核心问题：yield()截断数据流 #

你的left和right查询末尾都使用了yield()，这个函数的作用是输出当前数据流的结果并终止数据流，导致后续join.inner()无法获取到任何输入数据，自然返回空结果。

其他潜在问题：时间戳匹配精度 #

即使去掉yield()，如果两个流的_time存在毫秒级精度差异，内连接也会匹配失败。不过先解决yield()的问题，再验证时间对齐情况：

• aggregateWindow默认会将窗口的_stop时间设为新的_time，确保两个查询的窗口参数（every:1h）完全一致，且时间范围（start:-1d）对齐。

修正后的代码 #

移除两个查询中的yield()，确保数据流能传入join.inner()：

import "join"

// 左流查询：移除yield()
left =
from(bucket: "IoT_Prod")
  |> range(start: -1d)
  |> filter(fn: (r) => r["_field"] == "aanvoer_temp")
  |> filter(fn: (r) => r["CV_status"] == "hwc")
  |> aggregateWindow(every: 1h, fn: last, createEmpty: false)

// 右流查询：移除yield()
right =
from(bucket: "IoT_Prod")
  |> range(start: -1d)
  |> filter(fn: (r) => r["_field"] == "geleverd gas")
  |> aggregateWindow(every: 1h , fn: mean, createEmpty: false)

// 执行内连接
join.inner(
  left: left,
  right: right,
  on: (l,r) => l._time == r._time,
  as: (l,r) => ({
    join_time: r._time,
    join_value: r._value,
    join_field: r._field,
    join_CV_status: l.CV_status
  })
)

验证步骤 #

1. 先单独运行left和right查询（临时加上yield()），确认各自都有数据返回。
2. 运行修正后的连接查询，检查是否返回匹配结果。
3. 如果仍无结果，可在连接前给两个流添加map()函数打印_time，确认时间戳是否完全一致：

// 左流添加时间打印
left = ... |> map(fn: (r) => ({r with _time: string(v: r._time)}))
// 右流添加时间打印
right = ... |> map(fn: (r) => ({r with _time: string(v: r._time)}))

内容的提问来源于stack exchange，提问作者H Doucet