MongoDB：在构面内加入集合的有效方法

Question

我有一个聚合可以概括为：

db.getCollection('originalCollection').aggregate([
    $match: { //some filters }
    $project: { //some transformations}
    $facet: {
        "collectionA": [ //some transformation steps ],
        "collectionB": [ //some other transformation steps ]
    }
...

现在我想使用id 字段与集合A 和B 进行类似SQL 的连接。例如，如果我在集合 A 中有此文档：

{
    id: "A"
    property1: "a value"
}

这个文档在集合B:

{
    id: "A"
    property2: "other value"
}

生成的集合必须包含：

{
   id: "A",
   property1: "a value",
   property2: "other value"
}

我尝试作为下一个聚合步骤在集合 A 上使用 $map，它使用 $filter 来匹配集合 B 中具有相同 ID 的文档，但速度非常慢：

{
    "$project": {
        "tmpResult": {
            "$map": {
                "input": "$collectionA",
                "as": "collectionADocument",
                "in": {
                    "property1": "$$collectionADocument.property1",
                    "property2": {
                        "$arrayElemAt": [
                            {
                                "$filter": {
                                    "input": "$collectionB",
                                    "cond": {
                                        "$eq": [
                                            "$$collectionADocument.id",
                                            "$$this.id"
                                        ]
                                    }
                                }
                            },
                            0
                        ]
                    }
                }
            }
        }
    }
}

在构面中实现两个集合连接的最快方法是什么？提前致谢！

Answer 1

为什么不使用 $lookup，添加到聚合管道的 $lookup 运算符本质上与左外连接相同：

https://docs.mongodb.org/master/reference/operator/aggregation/lookup/#pipe._S_lookup

来自文档，

{
   $lookup:
     {
       from: <collection to join>,
       localField: <field from the input documents>,
       foreignField: <field from the documents of the "from" collection>,
       as: <output array field>
     }
}

对于您的示例，可能如下所示，

db.B.aggregate({
   $lookup:
     {
       from: "A",
       localField: "id",
       foreignField: "id",
       as: "AB"
     }
})