MongoDB：如何用$lookup关联嵌套子文档中的公交站点信息

你原来的查询卡壳在嵌套数组的匹配上，核心问题是不能直接用$going_trips.$stops._id这种写法访问嵌套数组的元素，MongoDB需要用数组操作符逐层遍历嵌套层级才能匹配到目标站点。下面是完整的解决方案：

完整聚合查询代码 #

db.guests.aggregate([
  {
    $lookup: {
      from: "buses",
      let: { stop_id: "$bus_stop" },
      pipeline: [
        // 1. 筛选出包含目标站点的bus文档
        {
          $match: {
            $expr: {
              $anyElementTrue: {
                $map: {
                  input: "$trips", // 这里如果你的字段是going_trips就改成$going_trips
                  as: "trip",
                  in: {
                    $in: ["$$stop_id", "$$trip.stops._id"]
                  }
                }
              }
            }
          }
        },
        // 2. 精准提取匹配的站点（含location子文档）
        {
          $project: {
            matched_stop: {
              $arrayElemAt: [
                {
                  $reduce: {
                    input: "$trips", // 同样，字段名不对就改成going_trips
                    initialValue: [],
                    in: {
                      $concatArrays: [
                        "$$value",
                        {
                          $filter: {
                            input: "$$this.stops",
                            cond: { $eq: ["$$this._id", "$$stop_id"] }
                          }
                        }
                      ]
                    }
                  }
                },
                0
              ]
            }
          }
        },
        // 3. 把站点信息转为根文档，去掉无关的bus字段
        { $replaceRoot: { newRoot: "$matched_stop" } }
      ],
      as: "bus_stop_info"
    }
  },
  // 把$lookup返回的数组转为单个对象（一个guest对应一个站点）
  { $set: { bus_stop_info: { $arrayElemAt: ["$bus_stop_info", 0] } } },
  // 可选：过滤掉未匹配到站点的guest
  // { $match: { bus_stop_info: { $ne: null } } }
])

关键步骤解释 #

1. 筛选包含目标站点的bus：
   用$map遍历bus的所有trips，再用$in检查当前trip的stops里是否存在目标stop_id，最后通过$anyElementTrue判断是否有任意一个trip包含该站点，以此筛选出符合条件的bus文档。

2. 提取目标站点信息：
   用$reduce把所有trips里的stops合并成一个数组，再用$filter精准筛选出_id匹配stop_id的站点，最后用$arrayElemAt取出第一个匹配项（确保返回单个站点对象）。

3. 整理输出结构：
   通过$replaceRoot把站点信息转为根文档，再用$arrayElemAt把$lookup返回的数组转为单个对象，最终每个guest文档会带上完整的bus_stop_info字段（包含location子文档）。

注意事项 #

• 如果你的bus集合里的出行计划字段是going_trips（原代码里写的），记得把代码中所有的$trips替换成$going_trips。
• 如果需要保留bus的其他信息（比如线路名、bus ID），可以修改$project步骤，同时保留bus的字段和matched_stop。

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