Riferimento dell'intero documento in MongoDB Aggregation Pipeline

Question

È possibile fare riferimento ai valori dei singoli valori degli attributi nella pipeline di aggregazione MongoDB utilizzando l'operatore '$'. Ma come posso accedere (riferimento) all'intero documento?

---

UPDATE: Un esempio fornito per spiegare scenario.

Ecco un esempio di ciò che sto cercando di fare. Ho una collezione di tweet. E ogni tweet ha un membro 'cluster', che è un'indicazione di a quale cluster appartiene un particolare 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 
} 

Dal momento che, ci sono alcuni paio di centinaia di migliaia di tweet nella mia collezione, voglio gruppo tutti i tweet di 'clusters.clusterID'. Fondamentalmente, vorrei scrivere una query come segue:

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

voglio accedere al documento attualmente elaborazioni ed è dove ho messo nella query precedente. Qualcuno sa come farlo?

Answer 1

Penso che MapReduce più utile per questa attività.

Come scritto nei commenti di Asya Kamsky, il mio esempio non è corretto per mongodb, si prega di utilizzare official docs per mongoDB.

Answer 2

Non ci sono attualmente meccanismo per accedere al documento completo nel quadro di aggregazione, se avevi bisogno di solo un sottoinsieme di campi, si potrebbe fare:

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

Non dimenticare con poche centinaia di migliaia tweets, aggregando il documento completo ti porterà al limite di 16 MB per il documento dei risultati del framework di aggregazione restituito.

È possibile farlo attraverso MapReduce in questo modo:

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

Nella documentazione ho trovato che l'espressione $$ROOT risolve questo problema.

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