MongoDB集約パイプラインで文書全体を参照する

Question

'$'演算子を使用して、MongoDB集約パイプラインの属性の個々の値の値を参照できます。しかし、文書全体にどのようにアクセス（参照）するのですか？

---

UPDATE：シナリオを説明するために提供される例。

ここに私がしようとしているものの例があります。私はつぶやきのコレクションを持っています。また、すべてのツイートにはメンバー 'クラスタ'があり、これは特定のツイートがどのクラスタに属しているかを示します。

{ 
    "_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 
} 

私のコレクションには何千ものツイートがありますので、すべてのツイートを 'clusters.clusterID'でグループ化したいと思います。基本的に、私は次のようなクエリを記述するとよいでしょう：

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

私は、現在の処理、ドキュメントにアクセスして、私は上記のクエリに入れているところ、それを参照するようにしたいです。誰もこれを行う方法を知っていますか？

Answer 1

私はMapReduceがこのタスクにもっと役立つと思います。

Asya Kamskyのコメントで書いたように、私の例はmongodbには間違っています。mongoDBにはofficial docsを使ってください。

Answer 2

集約フレームワークに完全なドキュメントにアクセスするメカニズムは、あなたが唯一のフィールドのサブセットを必要に応じて、あなたが行うことができ、現在ありません：

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

は集約、数十万ツイートを忘れてはいけません完全なドキュメントは、返された集約フレームワークの結果ドキュメントの16MBの制限にあなたを実行します。

あなたはこのようにMapReduceのを経由してこれを行うことができます：私は$$ROOT式は、この問題に対処することがわかったドキュメントで

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

。 DOCから

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