如何组合两个MongoDB聚合管道查询的结果，并在不使用$facet的情况下对组合结果执行另一个聚合查询？

Question

在各种聚合管道阶段之后，我的第一个查询返回以下结果：

{ 
    "group" : "A",
    "count" : 6, 
    "total" : 20
},
{
    "group" : "B",
    "count" : 2,
    "total" : 50
}

在各种聚合管道阶段之后，我的第二个查询返回以下结果：

{
    "group": "A",
    "count": 4,
    "total": 80
},
{
    "group": "C",
    "count": 12,
    "total": 60
}

这两个查询都在同一个集合上执行，但是根据管道阶段对数据进行不同的分组和转换。

我的两个查询都使用不同的$match条件，具有不同的管道阶段，包括$facet、$unwind、$group、$project和$map、$reduce、$zip、$subtract等操作符。。。

db.collection.aggregate([
{ $unwind...},
{ $match....},
{ $facet...},
...
])

当我使用$facet以并行查询的方式运行查询时，会出现以下错误（因为我已经在现有查询中使用$facet）：

$facet is not allowed to be used within a $facet stage

预期产出：

我需要找到每个组的平均值。

为此，我需要组合两个查询的结果，并对组合的结果执行查询。

我的组合阶段应该如下所示：

{ 
    "group" : "A",
    "count" : 10, 
    "total" : 100 
},
{
    "group" : "B",
    "count" : 2,
    "total" : 50
},
{
    "group": "C",
    "count": 12,
    "total": 60
}

每组平均值的预期最终结果：

{
    "group" : "A",
     "avg" : 10 
},
{
    "group" : "B",
    "avg" : 25
},
{
    "group": "C",
    "avg": 5
}

MongoDB聚合管道中是否有任何操作符可以在不修改现有查询的情况下实现这一点？

如何实现这个用例？

谢谢！




Answer 1

有不同的方法来组合结果，包括$merge，它是在4.2中引入的

但我使用了以下方法，因为我使用的是4.0版

将两个聚合查询结果保存在一个变量中，然后将其插入新的临时集合：

var result  = db.collection.aggregate(...); //query1 here
db.temp.insert(result.toArray());

var result  = db.collection.aggregate(...); //query2 here
db.temp.insert(result.toArray());

// Find out average
db.temp.aggregate([
    {
        $group: {
            _id: "$group",
            count: { $sum: "$count" },
            total: { $sum: "$total" }
        }
    },
    {
        $project: {
            _id: 0,
            group: "$_id",
            avg: { $divide: [ "$total", "$count" ] }
        }
    }
]).pretty()

Answer 2

您可以使用$facet单独运行查询，然后通过group使用以下转换到group组合结果，并计算平均值：

db.collection.aggregate([
    {
        $facet: {
            first: [ { $match: { "_": true } } ], // your first query
            second: [ { $match: { "_": false } } ], // your second query
        }
    },
    {
        $project: {
            all: {
                $concatArrays: [ "$first", "$second" ]
            }
        }
    },
    {
        $unwind: "$all"
    },
    {
        $group: {
            _id: "$all.group",
            count: { $sum: "$all.count" },
            total: { $sum: "$all.total" },
        }
    },
    {
        $project: {
            _id: 0,
            group: "$_id",
            count: 1,
            total: 1,
            avg: { $divide: [ "$total", "$count" ] }
        }
    }
])

蒙哥游乐场

注意：我使用\u字符来指示文档来自哪个查询。显然，您不需要它，您可以用自己的查询替换$facet查询