如何用MongoDB聚合lookup查询解析对象列表中每个external_id

要实现对数组中每个元素的external_id进行关联查询，并将结果嵌入对应数组对象中，可以通过$unwind、$lookup、$addFields和$group这几个聚合阶段组合完成，具体操作如下：

步骤拆解 #

1. 拆分数组元素 #

使用$unwind将example_list数组拆分为单个文档，让每个数组元素都能独立进行关联查询：

{ $unwind: "$example_list" }

2. 关联外部集合 #

通过$lookup从example_collection集合中，根据拆分后每个文档的example_list.external_id匹配对应数据，结果存入临时字段external_data_temp：

{
  $lookup: {
    from: "example_collection",
    localField: "example_list.external_id",
    foreignField: "_id",
    as: "external_data_temp"
  }
}

3. 将关联结果嵌入原数组元素 #

由于$lookup返回的是数组格式（即使只匹配到一条数据），用$arrayElemAt取出第一个匹配项，将其合并到example_list对象中，命名为external_data：

{
  $addFields: {
    "example_list.external_data": { $arrayElemAt: ["$external_data_temp", 0] }
  }
}

如果只需要关联文档中的特定字段（比如目标集合的data字段），可以直接指定：

{
  $addFields: {
    "example_list.external_data": { $arrayElemAt: ["$external_data_temp.data", 0] }
  }
}

4. 重组数组 #

最后用$group按原文档的_id分组，将处理后的example_list元素重新组合成数组：

{
  $group: {
    _id: "$_id",
    example_list: { $push: "$example_list" }
  }
}

完整聚合管道代码 #

db.your_target_collection.aggregate([
  { $unwind: "$example_list" },
  {
    $lookup: {
      from: "example_collection",
      localField: "example_list.external_id",
      foreignField: "_id",
      as: "external_data_temp"
    }
  },
  {
    $addFields: {
      "example_list.external_data": { $arrayElemAt: ["$external_data_temp", 0] }
    }
  },
  {
    $group: {
      _id: "$_id",
      example_list: { $push: "$example_list" }
    }
  }
])

注意事项 #

• 确保example_collection的_id字段与example_list.external_id类型一致（均为ObjectId），否则会匹配失败。
• 如果external_id可能匹配多个文档，需根据业务需求调整结果处理逻辑（比如用$first、$last或保留数组形式）。

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