आप async आज़माना चाह सकते हैं इसके लिए मॉड्यूल। इसमें संग्रह में प्रत्येक आइटम को संसाधित करने के लिए कुछ बहुत ही उपयोगी तरीके हैं, और सभी प्रसंस्करण समाप्त होने पर कार्यक्षमता प्रदान करता है।
मैं आपको विशेष रूप से कतार के लिए संदर्भित करता हूं फ़ंक्शन, जो आपको कार्यों को एक कतार में जोड़ने देता है, फिर एक बार सभी आइटम संसाधित हो जाने के बाद, कुछ करें।
उदाहरण के लिए, आप कुछ ऐसा कर सकते हैं:
var q = async.queue(function(task, callback) {
// task.doc would contain your individual doc to process
// your insert / update logic goes here...
// Callback signifies you're done with this task
callback();
}, 2) // <--- this number specifies the number of tasks to run in parallel
q.drain = function() {
// this is the queue's callback, called when the queue is empty,
// i.e. when all your documents have been processed.
res.send(statusCode, message);
}
फिर, यदि हम मान लें कि आपके पास दस्तावेज़ . नामक चर में आपके दस्तावेज़ों की सूची है , उन सभी को संसाधित करने के लिए आपको बस इतना करना है कि उन्हें कतार में धकेल दिया जाए।
for (var doc in docs) {
q.push({ doc: docs[doc] }, function(err) {
if (err) console.log(err);
})
}
प्रोटिप:आपको युक्त . ऑब्जेक्ट को पुश करने की आवश्यकता है कतार पर दस्तावेज़। यदि आप किसी अलिखित वस्तु में प्रवेश करने का प्रयास करते हैं तो एक अजीब त्रुटि होती है।
अब, यदि आप मोंगो में आपके द्वारा संसाधित किए जाने वाले प्रत्येक दस्तावेज़ के लिए विशिष्ट स्थिति चाहते हैं, तो यह इस तरह पूरी तरह से संभव है। जब तक आप कतार के बाहर एक डेटा संरचना को त्वरित करते हैं, तब तक आप इसमें स्थिति कोड (आदि) जोड़ सकते हैं क्योंकि प्रत्येक आइटम संसाधित होता है, और ग्राहक को संरचना को कतार के नाली में भेज सकते हैं। समारोह। ज्यादा परेशानी नहीं होनी चाहिए।
