聚合MongoDB中

Question

這涉及陣列字段（一個或多個）和正常字段（一個或多個）的總和是樣品收集：

{'f1': 10, '_id': 1, 'key': 'g', 'items': [{'i1': 10}, {'i1': 10}, {'i1': 10}]} 
{'f1': 10, '_id': 2, 'key': 'g', 'items': [{'i1': 10}, {'i1': 10}, {'i1': 10}]} 
{'f1': 77, '_id': 3, 'key': 'g', 'items': [{'i1': 10}, {'i1': 10}, {'i1': 10}]} 

我要像下式：$sum(f1 + Σ[items.i1])到上述收集來計算。以下是我能想出的（在pymongo）：

db.collec.aggregate([  
     { "$unwind" : "$items"}, 
    { "$group" : {  
      "_id" : {"key": "$key", "id": "$_id"},  
    "matches" : { "$sum" : "$items.i1" },  
    "extra" : { "$sum" : "$f1" },  
    "count" : {"$sum": 1}  
        }}, 
    { "$group": {  
      "_id" : "$_id.key",  
      "finalSum":{ "$sum":  
         { "$add": ["$matches", {"$divide":["$extra", "$count"]}]}}}}  
    ]); 

輸出：

{'finalSum': 187.0, '_id': 'g'} 

雖然這給正確的輸出，我希望有這個更好的，更簡單的解決方案： 任何幫助高度讚賞。

Answer 1

當您對文檔進行分組時，您可以將「f1」保存到_id字段，以便您不需要對其進行彙總並對每個文檔進行分割。

聚集操作是這樣的：

db.collec.aggregate([  
    { "$unwind" : "$items"}, 
    { "$group" : {  
      _id : {key: "$key", id: "$_id", f1 : "$f1" },  
      matches : { "$sum" : "$items.i1" },  
    }}, 
    { "$group": {  
      _id : "$_id.key",  
      finalSum : { "$sum":  
         { "$add": ["$matches", "$_id.f1"]}}}}  
    ]);