如何用$lookup替换嵌套文档中的distributor_uid为匹配的分销商文档？

你的需求核心是处理多层嵌套数组的关联替换，直接用顶层$lookup会把所有匹配的分销商堆到一个数组里，没法对应到每个区域。正确的做法是先把嵌套结构拆平，关联后再重新组装回原有的嵌套格式，具体步骤如下：

假设集合结构 #

先明确下你的集合大概结构（方便后续示例）：

• Shops集合文档：

{
  "_id": "shop_001",
  "shop_name": "XX连锁",
  "countries": [
    {
      "country_name": "中国",
      "cities": [
        {
          "city_name": "上海",
          "districts": [
            {
              "district_name": "黄浦区",
              "distributor_uid": "dist_001"
            },
            {
              "district_name": "浦东新区",
              "distributor_uid": "dist_002"
            }
          ]
        }
      ]
    }
  ]
}

• Distributors集合文档：

{
  "_id": "dist_001",
  "dist_name": "上海黄浦分销商",
  "phone": "13xxxxxxxxx",
  "address": "XX路XX号"
}

完整聚合管道 #

以下是实现需求的聚合代码，每个阶段都加了注释：

db.Shops.aggregate([
  // 1. 逐层展开嵌套数组，先拆国家
  { $unwind: "$countries" },
  // 2. 拆城市
  { $unwind: "$countries.cities" },
  // 3. 拆区域——这一步把每个区域变成单独的文档条目，才能单独关联分销商
  { $unwind: "$countries.cities.districts" },

  // 4. 关联Distributors集合，匹配当前区域的distributor_uid
  {
    $lookup: {
      from: "Distributors",
      localField: "countries.cities.districts.distributor_uid",
      foreignField: "_id",
      as: "countries.cities.districts.distributor"
    }
  },

  // 5. 把lookup返回的单元素数组展开成单个文档（因为每个uid只匹配一个分销商）
  { $unwind: "$countries.cities.districts.distributor" },

  // 6. 可选：如果不需要保留distributor_uid，可以删掉这个字段
  {
    $unset: "countries.cities.districts.distributor_uid"
  },

  // 7. 重新组装区域数组——按店铺ID、国家、城市分组，把区域聚合回去
  {
    $group: {
      _id: {
        shop_id: "$_id",
        shop_name: "$shop_name",
        country_name: "$countries.country_name",
        city_name: "$countries.cities.city_name"
      },
      districts: { $push: "$countries.cities.districts" }
    }
  },

  // 8. 重新组装城市数组——按店铺ID、国家分组，把城市聚合回去
  {
    $group: {
      _id: {
        shop_id: "$_id.shop_id",
        shop_name: "$_id.shop_name",
        country_name: "$_id.country_name"
      },
      cities: { $push: { city_name: "$_id.city_name", districts: "$districts" } }
    }
  },

  // 9. 重新组装国家数组——按店铺ID分组，把国家聚合回去，恢复原结构
  {
    $group: {
      _id: "$_id.shop_id",
      shop_name: { $first: "$_id.shop_name" },
      countries: { $push: { country_name: "$_id.country_name", cities: "$cities" } }
    }
  },

  // 10. 可选：重命名_id字段为shop_id（如果需要）
  {
    $project: {
      _id: 0,
      shop_id: "$_id",
      shop_name: 1,
      countries: 1
    }
  }
])

关键逻辑说明 #

1. 拆平嵌套数组：通过三次$unwind把国家、城市、区域逐层拆成单条文档，确保每个区域都能单独和分销商关联，而不是在顶层批量关联。
2. 精准关联：在拆到区域后执行$lookup，此时localField指向的是单个区域的distributor_uid，关联后只会返回该区域对应的分销商。
3. 重组嵌套结构：通过三次$group从区域往上逐层聚合，恢复原来的国家->城市->区域的嵌套格式。

如果你的集合字段名和示例有差异，只需要对应修改$unwind、$lookup、$group里的字段路径即可。

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