mongodb聚合嵌套嵌套数组

Question

如何在位置 3 上找到具有 $match 的文档（仅数组“ndr”中的最后一项）。需要只在ndr的最后一个数组项中进行聚合搜索。

 {
    "_id" : ObjectId("58bd5c63a3d24b4a2e4cde03"),
    "name" : "great document",
    "country" : "us_us",
    "cdate" : ISODate("2017-03-06T12:56:03.405Z"),
    "nodes" : [ 
        {
            "node" : 3244343,
            "name" : "Best Node ever",
            "ndr" : [ 
                {
                    "position" : 7,
                    "cdate" : ISODate("2017-03-06T10:55:20.000Z")
                }, 
                {
                    "position" : 3,
                    "cdate" : ISODate("2017-03-06T10:55:20.000Z")
                }
            ]
        }
    ],
}

聚合后我需要这个结果

{
    "name" : "great document",
    "country" : "us_us",
    "cdate" : ISODate("2017-03-06T12:56:03.405Z"),
    "nodes" : [ 
        {
            "node" : 3244343,
            "name" : "Best Node ever",
            "ndr" : [ 
                {
                    "position" : 3,
                    "cdate" : ISODate("2017-03-06T10:55:20.000Z")
                }
            ]
        }
    ]
}

希望有人能帮助我。

Answer 1

您将需要展开两个嵌套数组。

 db.<collection>.aggregate([
      { $unwind: '$nodes' },
      { $unwind: '$nodes.ndr'},
      { $group: {'_id':{'_id':'$_id', 'nodeID', '$nodes.node' },
                 'name':{'$last':'$name'},
                 'country':{'$last':'$country'},
                 'cdate':{'$last':'$cdate'},
                 'nodes':{'$last':'$nodes'}
                }
      },
      { $match : { nodes.ndr.position: 3 } }
  ]);

您可以在此处使用 $group 重新组合聚合结果并进行投影。我不确定你的最终结果应该是什么。

Answer 2

您可以尝试使用 Mongo 3.4 版本进行以下聚合。

以下查询使用$arrayElemAt 运算符在ndr 数组中找到最后一项(-1)，并将变量存储在last 中，使用$let 运算符为每个nodes 并比较last 变量@ 987654328@ 值使用$$ 表示法到3 并在数组[] 中包装nbr 元素，如果找到条目，否则返回空数组。

$map 运算符到达 nodes 数组内的 nbr 数组并投影更新后的 nbr 数组，同时映射其余的 nodes 字段。

$addFields 阶段将用新的nodes 覆盖现有的nodes，同时保留所有其他字段。

db.collection.aggregate([{
    $addFields: {
        nodes: {
            $map: {
                input: "$nodes",
                as: "value",
                in: {
                    node: "$$value.node",
                    name: "$$value.name",
                    ndr: {
                        $let: {
                            vars: {
                                last: {
                                    $arrayElemAt: ["$$value.ndr", -1]
                                }
                            },
                            in: {
                                $cond: [{
                                        $eq: ["$$last.position", 3]
                                    },
                                    ["$$last"],
                                    []
                                ]
                            }
                        }
                    }
                }
            }
        }
    }
}]);

更新：

您可以尝试$redact，如果它从给定的过滤器中找到匹配的位置，它将保留整个文档。

$map 投影true、false 值基于每个节点的过滤器nbr 位置值和$anyElementTrue 将检查每个文档的先前布尔值并返回true或false 值和$redact 将使用上述比较中的布尔值； true 值保留，false 值移除文档。

db.collection.aggregate([{
    $redact: {
        $cond: [{
            $anyElementTrue: {
                $map: {
                    input: "$nodes",
                    as: "value",
                    in: {
                        $let: {
                            vars: {
                                last: {
                                    $arrayElemAt: ["$$value.ndr", -1]
                                }
                            },
                            in: {
                                $cond: [{
                                        $eq: ["$$last.position", 3]
                                    },
                                    true,
                                    false
                                ]
                            }
                        }
                    }
                }
            }
        }, "$$KEEP", "$$PRUNE"]
    }
}]);