マングースJSは約束しますか？またはバッチ保存を管理する方法

Question

Mongooseでバッチ保存を管理するにはどうすればよいですか？私はそれがまだできないことがありました：マングースでpromisesが

• How can I save multiple documents concurrently in Mongoose/Node.js?

はqのようないくつかのフロー制御ライブラリの使用方法について、いくつかの言及をtheresのが、私にも気づく、それを使用することができますか？ jQueryので繰延ように私にできること/並列に複数のマングースのドキュメントを保存するには

$.when(obj1.save(), obj2.save(), obj3.save()).then -> 
    # do something? 

Answer 1

asyncモジュールのparallel機能を試してください。

var functions = []; 

for (var i=0; i < docs.length; i++) { 
    functions.push((function(doc) { 
     return function(callback) { 
      doc.save(callback); 
     }; 
    })(docs[i])); 
} 

async.parallel(functions, function(err, results) { 
    console.log(err); 
    console.log(results); 
}); 

Answer 2

を約束、あなたはこのような単純な何かを行うことができます（あなたが保存する文書のdocsという名前の配列を持っていると仮定します）：

var count = docs.length; 
docs.forEach(function(doc) { 
    doc.save(function(err, result) { 
     if (--count === 0) { 
      // All done; call containing function's callback 
      return callback(); 
     } 
    }); 
}); 

Answer 3

async parallelを使用する方法の洗練された例は次のようになります。

async.parallel([obj1.save, obj2.save, obj3.save], callback); 

大会は非同期のようにマングースでも同じであるので（ERR、コールバック）あなたはそれらをラップする必要はありません。あなた自身のコールバックは、あなたのセーブコールを配列に追加するだけで、すべてが終了したらコールバックを得るでしょう。

Answer 4

はい、これは約束で行うことができます。あなたはQ約束ライブラリを使用していた場合、あなたは可能性があり、再書き込みする@ matz3のようなコード：私たちは、ループ内の時間ですべての操作1を開始

var tasks = []; 

for (var i=0; i < docs.length; i++) { 
    tasks.push(docs[i].save()); 
} 

Q.all(tasks) 
    .then(function(results) { 
    console.log(results); 
    }, function (err) { 
    console.log(err); 
    }); 

が、我々はそれらのいずれかのを待つことはありません完了したので、それらは並行して実行されます。配列に結果のプレースホルダーのように働く約束事を追加します。私たちは、一連の約束がすべて完了するのを待っています。

ほとんど良いPromises/A+互換ライブラリがasync.queue程度Q.all

Answer 5

何にいくつかの同等のものを持っています。
簡単な例：

var queue = async.queue(function(obj, callback) { 
    return obj.save(callback); 
}); 

for (var i in objs) { 
    var obj = objs[i]; 
    // Some changes on object obj 
    queue.push(obj); 
} 

あなたはキューが空にされた後にコールバックが必要な場合：

var emptyQueue = true; 
var queue = async.queue(function(obj, callback) { 
    return obj.save(callback); 
}); 
queue.drain = function() { 
    // Every callbacks are finished 
    // bigCallback(); 
}; 

for (var i in objs) { 
    var obj = objs[i]; 
    // Some changes on object obj 
    queue.push(obj); 
    emptyQueue = false; 
} 
if (emptyQueue) { 
    // Call manually queue drain in case of the queue is empty 
    // and we need to call bigCallback() for example 
    return queue.drain(); 
} 

Answer 6

@ForbesLindesayをなぜあなたは約束のマングースの実装を使用して、独自に作成することができたときに外部ライブラリをロードしますすべて ？

すべてでmongoose約束を強化するモジュールを作成します。

var Promise = require("mongoose").Promise; 

Promise.all = function(promises) { 
    var mainPromise = new Promise(); 
    if (promises.lenght == 0) { 
    mainPromise.resolve(null, promises); 
    } 

    var pending = 0; 
    promises.forEach(function(p, i) { 
    pending++; 
    p.then(function(val) { 
     promises[i] = val; 
     if (--pending === 0) { 
     mainPromise.resolve(null, promises); 
     } 
    }, function(err) { 
     mainPromise.reject(err); 
    }); 
    }); 

    return mainPromise; 
} 

module.exports = Promise; 

そして、マングースとそれを使用します。

require('./promise') 

... 

var tasks = []; 

for (var i=0; i < docs.length; i++) { 
    tasks.push(docs[i].save()); 
} 

mongoose.Promise.all(tasks) 
    .then(function(results) { 
    console.log(results); 
    }, function (err) { 
    console.log(err); 
    }); 

Answer 7

マングースは今、あなたが実施を約束かを選択することができます。

ここではノードを使用しています。JSデフォルトのシステムの約束（ES6）は

var mongoose = require('mongoose'); 
    mongoose.Promise = global.Promise; // use system implementation 

Promise.all(obj1.save(), obj2.save(), obj3.save()) 
.then(function(resultSaves) { 

    console.log('parallel promise save result :'); 
    console.log(resultSaves); 
    mongoose.disconnect(); 

}).catch(function(err) { 

    console.log('ERROR on promise save :'); 
    console.log(err); 
    mongoose.disconnect(); 
}); 

ノード--version V4.1.1

mongoose@4.1.8 mongoose以来

Answer 8

は、今あなたがPromise.all().then()を使用することが約束をサポートしていますので、それnodejsに焼きすべての約束が解決されたときに戻ります。あなたはいつもsave()メソッドを呼び出している場合

Promise.all([ 
    obj1.save(), 
    obj2.save(), 
    obj3.save() 
]) 
.then(console.log) 
.catch(console.error) 

実際には、あなたはArray.map()ここに使用することができます。

Promise.all([ obj1, obj2, obj3 ].map(obj => obj.save()) 

AAANDも結果の配列destructureするES6の構文を使用します。

を

Promise.all([ obj1, obj2, obj3 ].map(obj => obj.save()) 
.then(([ savedObj1, savedObj2, savedObj3 ]) => { 
    // do something with your saved objects... 
})