मोंगोस का उपयोग करके मोंगोडीबी में कई रिकॉर्ड अपडेट करने का सही तरीका क्या है

इसके लिए सबसे अच्छा तरीका यह होगा कि इसके लिए बल्क एपीआई का उपयोग किया जाए जो कि बल्क में अपडेट को प्रोसेस करने में बेहद कुशल है। कई दस्तावेज़ों में से प्रत्येक पर अपडेट ऑपरेशन को कॉल करने के प्रदर्शन में अंतर यह है कि प्रत्येक पुनरावृत्ति के साथ सर्वर को अपडेट अनुरोध भेजने के बजाय, बल्क एपीआई प्रत्येक 1000 अनुरोधों (बैच) में एक बार अनुरोध भेजता है।

नेवला संस्करणों के लिए >=4.3.0 जो MongoDB सर्वर का समर्थन करता है 3.2.x , आप उपयोग कर सकते हैं bulkWrite() अपडेट के लिए। निम्न उदाहरण दिखाता है कि आप इस बारे में कैसे जा सकते हैं:

const bulkUpdateCallback = function(err, r){
  console.log(r.matchedCount);
  console.log(r.modifiedCount);
}

// Initialize the bulk operations array
const bulkUpdateOps = [], counter = 0;

processedIds.forEach(function (id) {
  bulkUpdateOps.push({
    updateOne: {
      filter: { _id: id },
      update: { $set: { status: "processed" } }
    }
  });
  counter++;

  if (counter % 500 == 0) {
    // Get the underlying collection via the Node.js driver collection object
    Model.collection.bulkWrite(bulkUpdateOps, { ordered: true, w: 1 }, bulkUpdateCallback);
    bulkUpdateOps = []; // re-initialize
  }
})

// Flush any remaining bulk ops
if (counter % 500 != 0) {
  Model.collection.bulkWrite(bulkOps, { ordered: true, w: 1 }, bulkUpdateCallback);
}

नेवला संस्करणों के लिए ~3.8.8.8 , ~3.8.22 , 4.x जो MongoDB सर्वर का समर्थन करते हैं >=2.6.x , आप बल्क एपीआई का उपयोग निम्नानुसार कर सकते हैं

var bulk = Model.collection.initializeOrderedBulkOp(),
    counter = 0;

processedIds.forEach(function(id) {
    bulk.find({ "_id": id }).updateOne({ 
        "$set": { "status": "processed" }
    });

    counter++;
    if (counter % 500 == 0) {
        bulk.execute(function(err, r) {
           // do something with the result
           bulk = Model.collection.initializeOrderedBulkOp();
           counter = 0;
        });
    }
});

// Catch any docs in the queue under or over the 500's
if (counter > 0) {
    bulk.execute(function(err,result) {
       // do something with the result here
    });
}