MongoDB多条件Lookup关联查询失败问题求助

问题背景 #

尝试按照MongoDB官方文档的「多连接条件与关联子查询」模式，在api和cpu两个集合间构建lookup聚合查询，但无法成功关联并获取目标字段。

集合数据示例 #

api集合：

[
    {
      "client": "AA",
      "msgNm": "mesg1",
      "volume": 76409,
      "month": "2024-08"
    },
    {
      "client": "AA",
      "msgNm": "mesg2",
      "volume": 33047,
      "month": "2024-08"
    }
]

cpu集合：

[
    {
      "lob": "AA",
      "msgNm": "mesg1",
      "mips": 7609,
      "month": "2024-08"
    },
    {
      "lob": "AA",
      "msgNm": "mesg2",
      "mips": 3347,
      "month": "2024-08"
    }
]

原错误查询语句 #

db.api.aggregate([
  {
    $lookup: {
      from: "cpu",
      let: {
        cpuClient: "$lob",
        cpuMsg: "$msgName",
        cpuMonth: "$yrMon",
        cpuMips: "$mips"
      },
      pipeline: [
        {
          $match: {
            $expr: {
              $and: [
                { $eq: [ "$month", "2024-08" ] },
                { $eq: [ "$$cpuMonth", "2024-08" ] },
                { $eq: [ "$client", "$$cpuClient" ] },
                { $eq: [ "$msgNm", "$$cpuMsg" ] }
              ]
            }
          }
        },
        {
          $project: {
            _id: 0
          }
        }
      ],
      as: "joined"
    }
  }
])

错误分析 #

1. let变量引用错误：let块中引用的$lob、$msgName、$yrMon均不是api集合的字段，正确的字段应为api集合的client、msgNm、month；$mips是cpu集合字段，无需在let中定义。
2. pipeline匹配字段错误：cpu集合中不存在client字段，应使用$lob匹配api的client；同时存在冗余的月份匹配条件，且变量与字段对应关系混乱。

修正后的查询语句 #

db.api.aggregate([
  {
    $lookup: {
      from: "cpu",
      // 定义api集合中用于关联的字段变量
      let: {
        apiClient: "$client",
        apiMsgNm: "$msgNm",
        apiMonth: "$month"
      },
      pipeline: [
        {
          $match: {
            $expr: {
              $and: [
                // 匹配cpu集合与api集合的关联字段
                { $eq: [ "$lob", "$$apiClient" ] },
                { $eq: [ "$msgNm", "$$apiMsgNm" ] },
                { $eq: [ "$month", "$$apiMonth" ] },
                // 可选：如果需要固定筛选某个月份，可保留此条件
                { $eq: [ "$month", "2024-08" ] }
              ]
            }
          }
        },
        {
          $project: {
            _id: 0,
            mips: 1 // 指定需要返回的cpu字段
          }
        }
      ],
      as: "cpu_data" // 关联结果的字段名
    }
  }
])

修正说明 #

• let块正确绑定api集合的client、msgNm、month字段为变量，用于后续关联匹配。
• pipeline中使用$expr关联cpu集合的lob、msgNm、month字段与api的对应变量，确保多条件匹配正确。
• $project明确指定返回cpu集合的mips字段，避免返回冗余数据。

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