嵌套数组中的$lookup

Question

我需要一个MongoDB查询来从事件、用户和确认的集合中返回聚合结果。

db.events.aggregate([
  {
    "$match": {
      "_id": "1"
    }
  },
  {
    "$lookup": {
      "from": "confirmations",
      "as": "confirmations",
      "let": {
        "eventId": "$_id"
      },
      "pipeline": [
        {
          "$match": {
            "$expr": {
              "$eq": [
                "$eventId",
                "$$eventId"
              ]
            }
          }
        },
        {
          "$lookup": {
            "from": "users",
            "as": "user",
            "let": {
              "userId": "$confirmations.userId"
            },
            "pipeline": [
              {
                "$match": {
                  "$expr": {
                    "$eq": [
                      "$_id",
                      "$$userId"
                    ]
                  }
                }
              },
              
            ]
          },
          
        },
        
      ]
    }
  }
])

所需

[
  {
    "_id": "1",
    "confirmations": [
      {
        "_id": "1",
        "eventId": "1",
        "user": {
          "_id": "1",
          "name": "X"
        },
        "userId": "1"
      },
      {
        "_id": "2",
        "eventId": "1",
        "user": {
          "_id": "2",
          "name": "Y"
        },
        "userId": "2"
      }
    ],
    "title": "foo"
  }
]

除了确认数组中的嵌入式用户之外，一切都可以正常工作。我需要输出来显示confirmations.user，而不是一个空数组。

Playgound：https://mongoplayground.net/p/jp49FW59WCv

Answer 1

您在内部$lookup的变量声明中出错。尝试此解决方案：

db.events.aggregate([
    {
        "$match": {
            "_id": "1"
        }
    },
    {
        $lookup: {
            from: "confirmations",
            let: { "eventId": "$_id" },
            pipeline: [
                {
                    $match: {
                        "$expr": {
                            $eq: ["$eventId", "$$eventId"]
                        }
                    }
                },
                {
                    $lookup: {
                        from: "users",
                        let: { "userId": "$userId" },
                        pipeline: [
                            {
                                $match: {
                                    $expr: {
                                        $eq: ["$_id", "$$userId"]
                                    }
                                }
                            }
                        ],
                        as: "user"
                    }
                },
                { $unwind: "$user" }
            ],
            as: "confirmations"
        }
    }
])

此外，您可以在内部$lookup中使用$unwind代替user的：

{
    $addFields: {
        user: { $arrayElemAt: ["$user", 0] }
    }
}

因为默认情况下，$unwind不会保留来自上一阶段空结果。