MongoDB聚合$lookup关联对象数组问题求助

首先看你当前的聚合管道存在几个关键问题：

• $unwind的路径写错了，应该是"$merchantList"而不是"$merchant.merchantList"（此时还未关联出merchant字段）
• 执行$lookup后，关联返回的merchant是数组格式，需要转换成单个对象
• 拆分数组后没有重新分组恢复merchantList的数组结构，会导致最终结果是扁平化的单条数据

下面是修正后的聚合管道，完全匹配你期望的输出格式：

pipe := []bson.M{
    // 拆分merchantList数组，保留空数组的情况
    {"$unwind": bson.M{
        "path": "$merchantList",
        "preserveNullAndEmptyArrays": true,
    }},
    // 关联merchant集合，直接将结果绑定到merchantList的子字段中
    {"$lookup": bson.M{
        "from":         "merchant",
        "localField":   "merchantList.merchantId",
        "foreignField": "_id",
        "as":           "merchantList.merchant",
    }},
    // 将lookup返回的数组转为单个对象（取第一个匹配项）
    {"$addFields": bson.M{
        "merchantList.merchant": bson.M{"$arrayElemAt": []interface{}{"$merchantList.merchant", 0}},
    }},
    // 重新按原文档_id分组，恢复merchantList的数组结构，保留其他字段
    {"$group": bson.M{
        "_id":          "$_id",
        "merchantList": bson.M{"$push": "$merchantList"},
        "createdAt":    bson.M{"$first": "$createdAt"},
        "updatedAt":    bson.M{"$first": "$updatedAt"},
    }},
    // 字段映射，把MongoDB默认的_id转为你期望的id字段
    {"$project": bson.M{
        "id":           "$_id",
        "merchantList": 1,
        "_id":          0,
    }},
}

关键步骤说明： #

1. $unwind：把merchantList数组拆分成独立文档，让每个数组元素都能单独关联merchant集合
2. $lookup：直接将关联结果写入merchantList.merchant字段，避免后续还要手动合并到数组元素中
3. $addFields：由于$lookup默认返回数组（哪怕只有一个匹配项），用$arrayElemAt取第一个元素转换成单个对象，符合你要的merchant: {...}格式
4. $group：按原文档的_id重新分组，用$push把拆分后的元素重新组合成merchantList数组，用$first保留createdAt、updatedAt等非数组字段
5. $project：调整字段名，把MongoDB原生的_id映射成你期望的id，并隐藏原_id字段

执行这个管道后，你会得到和预期一致的输出结构：

{
  "items": [
    {
      "id": "5af8bdb20b0aa02928514a00",
      "merchantList": [
        {
          "merchantId": "5ad79c500b0aa07ed040fe4b",
          "merchant": { "name": "Merchant 1" },
          "merchantRevenue": 126500.0,
          "merchantFee": 25
        }
      ],
      "createdAt": ...,
      "updatedAt": ...
    }
  ]
}

如果不需要返回merchantRevenue和merchantFee，可以在$project里添加"merchantList.merchantRevenue": 0和"merchantList.merchantFee": 0来排除这些字段。

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