Odwoływanie się do całego dokumentu w Pipeline agregacji MongoDB

Question

Mogę odwoływać się do wartości poszczególnych wartości atrybutów w potoku agregacji MongoDB za pomocą operatora "$". Ale jak mam uzyskać dostęp do (odniesienia) całego dokumentu?

---

UPDATE: Przykład warunkiem wyjaśnić scenariusz.

Oto przykład tego, co próbuję zrobić. Mam zbiór tweetów. I każdy tweet ma element "klastrów", co jest wskazówką do jakiego klastra należy dany tweet.

{ 
    "_id" : "5803519429097792069", 
    "text" : "The following vehicles/owners have been prosecuted by issuing notice on the basis of photographs on dated... http://t.co/iic1Nn85W5", 
    "oldestts" : "2013-02-28 16:11:32.0", 
    "firstTweetTime" : "4 hours ", 
    "id" : "307161122191065089", 
    "isLoc" : true, 
    "powertweet" : true, 
    "city" : "new+delhi", 
    "latestts" : "2013-02-28 16:35:05.0", 
    "no" : 0, 
    "ts" : 1362081807.9693, 
    "clusters" : [ 
     { 
      "participationCoeff" : 1, 
      "clusterID" : "5803519429097792069" 
     } 
    ], 
    "username" : "dtptraffic", 
    "verbSet" : [ 
     "date", 
     "follow", 
     "prosecute", 
     "have", 
     "be" 
    ], 
    "timestamp" : "4 hours ", 
    "entitySet" : [ ], 
    "subCats" : { 
     "Generic" : [ ] 
    }, 
    "lang" : "en", 
    "fns" : 18.35967, 
    "url" : "url|109|131|http://fb.me/2CeaI7Vtr", 
    "cat" : [ 
     "Generic" 
    ], 
    "order" : 7 
} 

Ponieważ istnieją pewne kilkaset tysięcy tweetów w mojej kolekcji, chcę grupy wszystkie tweets przez „clusters.clusterID”. Zasadniczo chciałbym napisać zapytanie jak następuje:

db.tweets.aggregate (
{ $group : { _id : '$clusters.clusterID', 'members' : {$addToSet : <????> } } } 
) 

Chcę uzyskać dostęp do dokumentu obecnie przetwarzanie i odwoływać gdzie mam umieścić w powyższym zapytaniu. Czy ktoś wie, jak to zrobić?

Answer 1

Myślę, że MapReduce jest bardziej przydatna w tym zadaniu.

Jak napisano w komentarzach Asy Kamsky, mój przykład jest niepoprawny dla mongodb, proszę użyć official docs dla mongoDB.

Answer 2

Obecnie nie ma mechanizmu dostęp do pełnego dokumentu w ramach agregacji, jeśli potrzebne tylko podzbiór pól, można zrobić:

db.tweets.aggregate([ {$group: { _id: '$clusters.clusterID', 
            members: {$addToSet : 
             { user: "$user", 
             text: "$text", // etc for subset 
                 // of fields you want 
             } 
            } 
           } 
         } ]) 

Nie zapomnij z kilkuset tysięcy tweetów, sumując pełny dokument spowoduje przejście do limitu 16 MB dla zwróconego dokumentu wynikowego agregacji.

Można to zrobić poprzez MapReduce tak:

var m = function() { 
    emit(this.clusters.clustersID, {members:[this]}); 
} 

var r = function(k,v) { 
    res = {members: [ ] }; 
    v.forEach(function (val) { 
    res.members = val.members.concat(res.members); 
    }); 
    return res; 
} 

db.tweets.mapReduce(m, r, {out:"output"}); 

Answer 3

W dokumentacji znalazłem, że wyrażenie $$ROOT rozwiązuje ten problem.

Z Doc: http://docs.mongodb.org/manual/reference/operator/aggregation/group/#group-documents-by-author