MongoDB $lookup使用条件化localField报错求助

问题原因 #

你碰到的错误是因为$lookup的localField参数只能填字段名字符串，不能用$fieldResult这种字段引用语法。而且你当前$set阶段的fieldResult存的是字段名（"RequesterId"或"ReceiverId"），不是实际的好友ID值，就算语法正确也拿不到对应的数据。

解决方案 #

这里提供两种可行的修改方式：

方法一：直接存储好友ID值，简化lookup逻辑

修改$set阶段，让fieldResult直接存储好友的ID值，而不是字段名，之后lookup直接使用这个字段：

const activities = await friendModel.aggregate([
  { $match: {
    $or: [
      { ReceiverId: ActorId, Status: 1 },
      { RequesterId: ActorId, Status: 1 }
    ]
  }},
  { $set: {
    fieldResult: {
      $cond: {
        if: { $eq: ["$ReceiverId", ActorId] },
        then: "$RequesterId", // 返回RequesterId的实际值，而非字段名字符串
        else: "$ReceiverId"  // 返回ReceiverId的实际值
      }
    }
  }},
  { $lookup: {
    from: "activities",
    localField: "fieldResult", // 直接写字段名，不带$
    foreignField: "ActorId",
    as: "activity"
  }},
  // 注意：activity是数组，直接排序数组字段可能不符合预期，建议先展开再排序
  { $unwind: { path: "$activity", preserveNullAndEmptyArrays: true } },
  { $sort: { "activity._Date": -1 } },
  { $skip: request.pageindex * 3 },
  { $limit: 3 }
]);

方法二：用lookup的let+pipeline参数，内部处理匹配逻辑

不需要提前$set字段，直接在lookup内部定义变量并完成匹配，还能在lookup阶段直接对活动排序：

const activities = await friendModel.aggregate([
  { $match: {
    $or: [
      { ReceiverId: ActorId, Status: 1 },
      { RequesterId: ActorId, Status: 1 }
    ]
  }},
  { $lookup: {
    from: "activities",
    let: {
      friendId: {
        $cond: {
          if: { $eq: ["$ReceiverId", ActorId] },
          then: "$RequesterId",
          else: "$ReceiverId"
        }
      }
    },
    pipeline: [
      { $match: {
        $expr: { $eq: ["$ActorId", "$$friendId"] }
      }},
      { $sort: { "_Date": -1 } } // 先在lookup内部对好友活动排序
    ],
    as: "activity"
  }},
  { $sort: { "activity._Date": -1 } },
  { $skip: request.pageindex * 3 },
  { $limit: 3 }
]);

补充说明 #

如果部分好友没有任何活动，activity字段会是空数组，你可以根据需求选择用$unwind的preserveNullAndEmptyArrays参数保留这些记录，或者用$match过滤掉空数组的条目。

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