nodejs mongoose bulk update

Question

У меня есть набор данных, и мне нужно добавить для каждого документа новое поле. Если я выполнить запрос, чтобы получить все документы и обновление каждого один node.js останавливается, может быть для памяти утечки

Это мой код

var express = require('express'); 

var geocoderProvider = 'google'; 
var httpAdapter = 'http'; 

var People = require("./models/people").collection.initializeOrderedBulkOp(); 

var app = express(); 

var geocoder = require('node-geocoder').getGeocoder(geocoderProvider, httpAdapter, {}); 

app.get('/', function (req, res) { 
    People.find({}, function (err, docs) { 
    if (err) { 
     res.send(err); 
    }else{ 
     docs.forEach(function (doc){ 
     geocoder.geocode({address: doc.address, country: 'Italy', zipcode: doc.cap}, function(error, value) { 
      doc.loc.coordinates[0]=value[0].latitude; 
      doc.loc.coordinates[1]=value[0].longitude; 
      People.update({ _id: doc._id }, { $set: { loc: doc.loc }}, { multi: true }, function (error){ 
      if(error){ 
       console.error('ERROR!'); 
      } 
      }); 
     }); 
     }); 
    } 
    }); 
}); 

var server = app.listen(3000, function() { 
    var host = server.address().address 
    var port = server.address().port 
    console.log('Example app listening at http://%s:%s', host, port) 
}); 

Существует ли способ массового обновления с мангустом ? Заранее спасибо

Answer 1

Вы можете опуститься до уровня коллекции и выполнить массовое обновление. Это действие не будет атомарным - некоторые из записей могут выйти из строя, а другие могут преуспеть - но это позволит вам сделать эти записи за один раунд в вашу базу данных.

Это выглядит следующим образом:

var bulk = People.collection.initializeUnorderedBulkOp(); 
bulk.find({<query>}).update({<update>}); 
bulk.find({<query2>}).update({<update2>}); 
... 
bulk.execute(function(err) { 
    ... 
}); 

Заканчивать Документов здесь: http://docs.mongodb.org/manual/core/bulk-write-operations/

Answer 2

Более подробная информация о запросе и обновления запроса.

var bulk = People.collection.initializeOrderedBulkOp(); 
    bulk.find(query).update(update); 
    bulk.execute(function (error) { 
     callback();     
    }); 

Запрос выполняется с помощью массива.
Update требуется $ набора

var bulk = People.collection.initializeOrderedBulkOp(); 
    bulk.find({'_id': {$in: []}}).update({$set: {status: 'active'}}); 
    bulk.execute(function (error) { 
     callback();     
    }); 

запроса является поиск идентификатора

var bulk = People.collection.initializeOrderedBulkOp(); 
    bulk.find({'_id': id}).update({$set: {status: 'inactive'}}); 
    bulk.execute(function (error) { 
     callback();     
    });