मोंगोडीबी एकत्रीकरण पाइपलाइन

Question

में पूरे दस्तावेज़ का संदर्भ देने से मैं '$' ऑपरेटर का उपयोग करके मोंगो डीबी एकत्रीकरण पाइपलाइन में विशेषताओं के व्यक्तिगत मानों के मानों का संदर्भ दे सकता हूं। लेकिन, मैं पूरे दस्तावेज़ (संदर्भ) का उपयोग कैसे करूं?

---

अद्यतन: परिदृश्य समझाने के लिए प्रदान की एक उदाहरण।

यहां एक उदाहरण है जो मैं करने की कोशिश कर रहा हूं। मेरे पास ट्वीट्स का संग्रह है। और प्रत्येक ट्वीट में एक सदस्य 'क्लस्टर' होता है, जो कि एक विशेष ट्वीट से संबंधित क्लस्टर का संकेत है।

{ 
    "_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 अधिक उपयोगी है।

जैसा कि अस्या कामस्की की टिप्पणियों में लिखा गया है, मेरा उदाहरण मोंगोडब के लिए गलत है, कृपया official docs का उपयोग mongoDB के लिए करें।

Answer 2

वर्तमान में एकत्रीकरण ढांचे में पूर्ण दस्तावेज़ तक पहुंचने का कोई तंत्र नहीं है, यदि आप केवल क्षेत्रों का एक सबसेट की जरूरत है, तुम कर सकते हो:

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

में कुछ लाख ट्वीट्स साथ मत भूलना, योग पूरा दस्तावेज़ आपको लौटाए गए समेकन ढांचे के परिणाम दस्तावेज़ के लिए 16 एमबी सीमा में चलाएगा। प्रलेखन मैंने पाया कि $$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

:

आप इस तरह MapReduce के माध्यम से ऐसा कर सकते हैं।

डॉक्टर से: http://docs.mongodb.org/manual/reference/operator/aggregation/group/#group-documents-by-author