如何在相同的结果中将两个单独的聚合组合在一起

Question

我想采用两个聚合并将它们组合在一起。 “Blakes Seven”通过几次查询帮助我检索第一个和第二个数组元素值，但我需要将这两者结合在一起。

第一招：

db.getCollection('anothertest').aggregate([ 
{ "$unwind": "$a" }, 
{ "$group": { 
    "_id": "$_id", 
    "first": { "$first": "$a" } 
}} 
]) 

给出的结果是：

{ 
"result" : [ 
    { 
     "_id" : ObjectId("565cc5261506995581569439"), 
     "first" : 4 
    } 
], 
"ok" : 1.0000000000000000 
} 

第二个：

db.getCollection('anothertest').aggregate([ 
{ "$unwind": "$a" }, 
// Keeps the first element 
{ "$group": { 
    "_id": "$_id", 
    "first": { "$first": "$a" }, 
    "a": { "$push": "$a" } 
}}, 
{ "$unwind": "$a" } 
, 
// Removes the first element 
{ "$redact": { 
"$cond":{ 
"if": { "$ne": [ "$first", "$a" ] }, 
"then": "$$KEEP", 
    "else": "$$PRUNE" 
} 
}} 

给出结果：

{ 
"result" : [ 
    { 
     "_id" : ObjectId("565cc5261506995581569439"), 
     "second" : 2 
    } 
], 
"ok" : 1.0000000000000000 
} 

我需要的是的结果：

{ 
"result" : [ 
    { 
     "_id" : ObjectId("565cc5261506995581569439"), 
     "first" : 4 
     "second" : 2 
    } 
], 
"ok" : 1.0000000000000000 
} 

除此之外，它是基于该文件是只是其中的值坐为数组中的元素的例子。我将如何在嵌套数组上使用它？如果这对Aggregation来说很复杂，那么使用Map Reduce可能会有更简单的方法来实现这一点？感谢您提供的任何帮助。

对上述文件是下面：

{ 
"_id" : ObjectId("565cc5261506995581569439"), 
"a" : [ 
    4, 
    2, 
    8, 
    71, 
    21 
] 
} 

更新到我原来的职位 我现在已经成功地采取真棒脚本，使之成为我的文档已嵌套阵列工作 - 高达一个点。

{ "$match": {objectOriginAPI : "Profit & Loss"}}, 
{ "$unwind": "$objectRawOriginData.Reports" }, 
     { "$unwind": "$objectRawOriginData.Reports.Rows" }, 
     { "$unwind": "$objectRawOriginData.Reports.Rows.Rows" }, 
     { "$unwind": "$objectRawOriginData.Reports.Rows.Rows.Cells" }, 
{ "$group": { 
    "_id": "$_id", 
    "first": { "$first": "$objectRawOriginData.Reports.Rows.Rows.Cells.Value" }, 
    "a": { "$push": "$objectRawOriginData.Reports.Rows.Rows.Cells.Value" } 
}}, 
{ "$unwind": "$a" }, 
{"$skip":1}, 
{ "$group": { 
    "_id": "$_id", 
    "BalanceName": { "$first": "$first" }, 
    "BalanceValue": { "$first":  "$objectRawOriginData.Reports.Rows.Rows.Cells.Value" }, 
}} 
]) 

其实，我忘了更新第二个$ unwind，所以它仍然是“$ a”。而实际情况是，我得到了以下结果：

{ 
"result" : [ 
    { 
     "_id" : ObjectId("564d12da1506995581569428"), 
     "BalanceName" : "Sales", 
     "BalanceValue" : null 
    } 
], 
"ok" : 1.0000000000000000 
} 

但是，当我改变了$开卷匹配$放松的第一个值，我没有得到任何结果的。我无法理解为什么，有什么想法？谢谢，Matt

Answer 1

您可以按照与您发布的第一个聚合相同的逻辑来执行此操作。请注意，我使用$skip来跳过第一个数组元素并获得第二个数组元素。

db.collection.aggregate([ 
    { "$match": { 
     "_id": ObjectId("565cc5261506995581569439") 
    }}, 
    { "$unwind": "$a" }, 
    { "$group": { 
     "_id": "$_id", 
     "first": { "$first": "$a" }, 
     "a": { "$push": "$a" } 
    }}, 
    { "$unwind": "$a" }, 
    {"$skip":1}, 
    { "$group": { 
     "_id": "$_id", 
     "first": { "$first": "$first" }, 
     "second": { "$first": "$a" }, 
    }} 
]) 

结果：

{ 
    "_id" : ObjectId("565cc5261506995581569439"), 
    "first" : 4, 
    "second" : 2 
} 

你的第二个聚集也相当接近所需的输出：

db.collection.aggregate([ 
    { "$match": { 
     "_id": ObjectId("565cc5261506995581569439") 
    }}, 
    { "$unwind": "$a" }, 
    { "$group": { 
     "_id": "$_id", 
     "first": { "$first": "$a" }, 
     "a": { "$push": "$a" } 
    }}, 
    { "$unwind": "$a" }, 
    { "$redact": { 
     "$cond":{ 
     "if": { "$ne": [ "$first", "$a" ] }, 
      "then": "$$KEEP", 
      "else": "$$PRUNE" 
    }}}, 
    { "$limit": 1}, 
    { "$project": { 
     "_id":1, 
     "first":1, 
     "second":"$a" 
    }} 
]) 

编辑：此外，因为它们是，无论是聚合只为工作单个文件，因此必须添加最初的步骤$match。