MongoDB聚合lookup阶段let变量如何嵌入以动态访问属性？

我创建了一个MongoPlayground用于理解问题。

一、现有架构 #

我有包含Filter实体ID的Category Schema。Filter Schema中有一个targetProperty属性，存储产品详情的属性名。Product Schema的details是键值映射，targetProperty的值作为该映射的键；产品的variations实体也包含同样的details键值映射。

例如，若Filter实体的targetProperty为"memory"，则产品实体的details中会有"memory"键，对应值为{"title": "Memory", "value": "256 GB"}，或部分产品variations的details中包含"memory"键。

const categorySchema = new Schema<ICategory>({
  filters: [{ type: Schema.Types.ObjectId, ref: filterModelName }],
  // some other properties unrelated to the issue...
});

const filterSchema = new Schema<IFilter>({
  targetProperty: {
    type: String,
    required: true
  }
  // some other properties...
});

const productSchema = new Schema<IProduct>({
  details: {
    type: Map,
    of: {
      title: { type: String, required: true },
      value: { type: Schema.Types.Mixed, required: true }
    },
    required: true
  },
  variations: [variationSchema],
  categories: [Schema.Types.ObjectId],
  // some other properties...
});

const variationSchema = new Schema<IProductVariation>({
  details: {
    type: Map,
    of: {
      title: { type: String, required: true },
      value: { type: Schema.Types.Mixed, required: true }
    }
  }
  // some other properties...
});

二、需求目标 #

我希望通过聚合获取某分类下相关过滤器的所有可选值。例如，若iPhone分类包含内存过滤器，需遍历所有属于该分类的产品，收集其details中"memory"键对应的value值（如"128gb"、"256 gb"等）作为该过滤器的可选值。

我尝试的聚合管道如下：

db.categories.aggregate([
  {
    "$lookup": {
      "from": "filters",
      "localField": "filters",
      "foreignField": "_id",
      "as": "filters",
      "let": {
        "category_id": "$_id"
      },
      "pipeline": [
        {
          "$lookup": {
            "from": "products",
            "let": {
              "target_property": "$targetProperty"
            },
            "as": "options",
            "pipeline": [
              {
                "$match": {
                  "$and": [
                    {
                      "$expr": {
                        "$in": [
                          "$$category_id",
                          "$categories"
                        ]
                      }
                    },
                    {
                      "$expr": {
                        "$or": [
                          {
                            "$ne": [
                              {
                                // ######## SOURCE OF THE PROBLEM ########
                                "$getField": "details.$$target_property"
                              },
                              null
                            ]
                          },
                          {
                            "$ne": [
                              {
                                // ######## SOURCE OF THE PROBLEM ########
                                "$getField": "variations.details.$$target_property"
                              },
                              null
                            ]
                          }
                        ]
                      }
                    }
                  ]
                }
              },
              {
                "$unwind": {
                  "path": "$variations",
                  "preserveNullAndEmptyArrays": true
                }
              },
              {
                "$group": {
                  "_id": {
                    "$ifNull": [
                      {
                        // ######## SOURCE OF THE PROBLEM ########
                        "$getField": "details.$$target_property.value"
                      },
                      {
                        // ######## SOURCE OF THE PROBLEM ########
                        "$getField": "variations.details.$$target_property.value"
                      }
                    ]
                  }
                }
              },
              {
                "$group": {
                  "_id": null,
                  "options": {
                    "$push": "$_id"
                  }
                }
              },
              {
                "$project": {
                  "_id": 0
                }
              }
            ]
          }
        }
      ]
    }
  }
])

三、遇到的问题 #

注意聚合查询中标记为// ######## SOURCE OF THE PROBLEM ########的代码行。我尝试的lookup阶段let变量嵌入方式无法生效，请问如何正确嵌入let变量值，以实现动态访问details的嵌套属性？是否可行？

解决方案 #

问题出在$getField的使用方式上：你直接将变量拼接到字符串路径中，但MongoDB不会解析字符串里的变量。要动态访问Map或对象的键，需要使用$getField的对象语法，或者通过$objectToArray转换后匹配键名。

方法1：使用$getField的对象语法 #

$getField支持传入对象参数，其中field可以是表达式（比如变量），input是要访问的文档/Map。这样就能动态获取目标属性：

修改后的聚合管道如下：

db.categories.aggregate([
  {
    "$lookup": {
      "from": "filters",
      "localField": "filters",
      "foreignField": "_id",
      "as": "filters",
      "let": {
        "category_id": "$_id"
      },
      "pipeline": [
        {
          "$lookup": {
            "from": "products",
            "let": {
              "target_property": "$targetProperty"
            },
            "as": "options",
            "pipeline": [
              {
                "$match": {
                  "$expr": {
                    "$and": [
                      { "$in": ["$$category_id", "$categories"] },
                      {
                        "$or": [
                          {
                            "$ne": [
                              {
                                "$getField": {
                                  "field": "$$target_property",
                                  "input": "$details"
                                }
                              },
                              null
                            ]
                          },
                          {
                            "$ne": [
                              {
                                "$getField": {
                                  "field": "$$target_property",
                                  "input": "$variations.details"
                                }
                              },
                              null
                            ]
                          }
                        ]
                      }
                    ]
                  }
                }
              },
              {
                "$unwind": {
                  "path": "$variations",
                  "preserveNullAndEmptyArrays": true
                }
              },
              {
                "$group": {
                  "_id": {
                    "$ifNull": [
                      {
                        "$getField": {
                          "field": "value",
                          "input": {
                            "$getField": {
                              "field": "$$target_property",
                              "input": "$details"
                            }
                          }
                        }
                      },
                      {
                        "$getField": {
                          "field": "value",
                          "input": {
                            "$getField": {
                              "field": "$$target_property",
                              "input": "$variations.details"
                            }
                          }
                        }
                      }
                    ]
                  }
                }
              },
              {
                "$group": {
                  "_id": null,
                  "options": { "$push": "$_id" }
                }
              },
              { "$project": { "_id": 0 } }
            ]
          }
        },
        // 扁平化options数组，避免嵌套
        { "$addFields": { "options": { "$arrayElemAt": ["$options.options", 0] } } }
      ]
    }
  }
])

方法2：使用$objectToArray转换Map #

如果你的MongoDB版本不支持$getField的对象语法，也可以将details转换为键值对数组，再筛选匹配target_property的项：

// 先添加转换步骤
{ "$addFields": { 
  "details": { "$objectToArray": "$details" },
  "variations.details": { "$objectToArray": "$variations.details" }
} },
// 匹配阶段的写法示例
{
  "$ne": [
    {
      "$arrayElemAt": [
        "$details.v.value",
        { "$indexOfArray": ["$details.k", "$$target_property"] }
      ]
    },
    null
  ]
}

关键说明 #

• $getField的对象语法支持动态字段名，field参数可以是任意表达式（包括变量），这是解决动态属性访问的最佳方式。
• 最后添加的$addFields是为了将嵌套的options数组扁平化，让结果更直观。

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