如何在MongoDB聚合$lookup中使用动态对象键作为localField？

定义的Schema #

// mongoose schema
const MySchema = new Schema({ objWithDynamicKeys: { type: Map, of: String } });

const OtherSchema = new Schema({
  limit: Number,
  refToMySchema: { type: Schema.Types.ObjectId, ref: 'MyModel' },
  name: String,
});

示例文档 #

MySchema模型文档示例：

const doc = {
  _id: new ObjectId("some-string"),
  objWithDynamicKeys: {
    "62f74bcfd4aa7ff5c45c7fe3": 2,
    "62f74bcfd4aa7ff5c45c7fe4": 5,
    "62f74bcfd4aa7ff5c45c7fe5": 1,
  }
};

OtherSchema模型文档示例：

const otherDoc1 = {
  _id: new ObjectId("62f74bcfd4aa7ff5c45c7fe3"),
  limit: 5,
  name: "First",
};
const otherDoc2 = {
  _id: new ObjectId("62f74bcfd4aa7ff5c45c7fe4"),
  limit: 5,
  name: "Second",
};
const otherDoc3 = {
  _id: new ObjectId("62f74bcfd4aa7ff5c45c7fe5"),
  limit: 3,
  name: "Third",
};

需求 #

需要构建聚合查询，找出所有满足以下条件的OtherSchema文档：

• 其_id是MySchema文档objWithDynamicKeys中的键
• 该键对应的值小于对应OtherSchema文档的limit字段

期望输出：

[
  {
    _id: new ObjectId("62f74bcfd4aa7ff5c45c7fe3"), // doc1
    limit: 5,
    name: "First",
  },
  {
    _id: new ObjectId("62f74bcfd4aa7ff5c45c7fe5"), // doc3
    limit: 3,
    name: "Third",
  },
];

已知数组类型字段的实现方式，但不确定Map类型如何处理，询问是否可行及实现方案。

完全可行，核心思路是先将Mongoose的Map类型字段转换为键值对数组，再通过$lookup关联目标集合，最后过滤符合条件的文档。以下是两种实现思路：

思路一：从OtherModel发起聚合查询 #

// 假设MySchema对应集合名为'mymodels'，OtherSchema对应集合名为'othermodels'
OtherModel.aggregate([
  // 关联MyModel，获取目标文档的键值对数据
  {
    $lookup: {
      from: 'mymodels',
      pipeline: [
        // 可选：指定目标MyModel文档，若需全局查询可移除此$match
        { $match: { _id: new ObjectId("some-string") } },
        // 将Map转为[{k: 键, v: 值}]格式的数组
        { $project: { keyValuePairs: { $objectToArray: "$objWithDynamicKeys" } } },
        // 展开数组，便于逐个处理键值对
        { $unwind: "$keyValuePairs" },
        // 类型转换：键转ObjectId，值转数字（原Map值为String类型）
        {
          $project: {
            _id: 0,
            otherId: { $toObjectId: "$keyValuePairs.k" },
            value: { $toInt: "$keyValuePairs.v" }
          }
        }
      ],
      as: 'myModelData'
    }
  },
  // 展开关联后的数组
  { $unwind: "$myModelData" },
  // 匹配_id对应关系，且数值满足小于limit的条件
  {
    $match: {
      $expr: {
        $and: [
          { $eq: ["$_id", "$myModelData.otherId"] },
          { $lt: ["$myModelData.value", "$limit"] }
        ]
      }
    }
  },
  // 移除临时字段，保留原OtherModel文档结构
  { $project: { myModelData: 0 } }
])

思路二：从MyModel发起聚合查询 #

MyModel.aggregate([
  // 指定目标MyModel文档
  { $match: { _id: new ObjectId("some-string") } },
  // Map转键值对数组
  { $project: { keyValuePairs: { $objectToArray: "$objWithDynamicKeys" } } },
  { $unwind: "$keyValuePairs" },
  // 类型转换
  {
    $project: {
      otherId: { $toObjectId: "$keyValuePairs.k" },
      value: { $toInt: "$keyValuePairs.v" },
      _id: 0
    }
  },
  // 关联OtherModel并过滤条件
  {
    $lookup: {
      from: 'othermodels',
      localField: 'otherId',
      foreignField: '_id',
      as: 'otherDoc',
      let: { value: "$value" },
      pipeline: [
        {
          $match: {
            $expr: { $lt: ["$$value", "$limit"] }
          }
        }
      ]
    }
  },
  { $unwind: "$otherDoc" },
  // 将关联结果作为根文档输出
  { $replaceRoot: { newRoot: "$otherDoc" } }
])

关键步骤说明 #

1. Map转数组：使用$objectToArray将Map类型字段转为可遍历的键值对数组，这是处理动态键的核心操作。
2. 类型对齐：由于Map的键是字符串格式的ObjectId、值是String类型，必须通过$toObjectId和$toInt转换类型，才能与OtherModel的_id（ObjectId）、limit（Number）进行正确比较。
3. 关联与过滤：通过$lookup拉取关联数据后，利用$match同时校验ID匹配和数值大小条件，最终得到目标结果。

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