mongodbに複数のレコードを挿入するmongodbドライバとasync.js

Question

現在、nodejsドライバを使用してmongodbにいくつかのエントリを実行しようとしている間、コールバック地獄に直面しています。すべてのレコード（配列内）が挿入されている場合にのみ実行する必要があるタスクがあります。 async.each method をチェックアウトしましたが、主な問題は、エラーが発生した場合にコールバックを呼び出すことです。したがって、コレクションの残りのアイテムは処理されません。

このような問題をasync.jsで処理する正しい方法は何ですか？

PS：私がasync.jsを使い始めたばかりであり、apiを使ってmongodbにバッチインサートするためにこれを使う例は非常に少ないので、非常に参考にしてください。

Answer 1

問題を説明しましょう。

1. あなたは、いくつかのライブラリ（例：AsyncJS）
2. 非同期フローはあなたが確認したいいくつかの反復
3. で中断することが可能と反復ベースのフローを持っているすべてのMongoDBでoperatiosnが正しく に保存されていますか、たぶん私はあなたが一括操作を使用することをお勧めすることができ、この場合には、その操作が起こるべきか、将来の意思決定、あるいは全く

を取る

// array of operations 
let batch = yourCollection.initializeUnorderedBulkOp(); 

async.each (yourArrayToIterate, function (item, next) { 
    // add some Operation that will be execute lated 
    batch.insert({firstName:"Daniele"}); 
    batch.find({firstName: "Daniele"}).updateOne({$set: {lastName:"Tassone"}}); 
    // other code to do...some Old Library 
     try { 
     someOldLibrary.doSomethingThatCanCreateAnExpection(); 
     } catch (e) { 
     //some error happen 
     } 
    // more modern approach with New Library 
     someNewLibrary 
     .then(function (result){ 
     }) 
     .catch(function (err) { 
      // some error happen 
     } 

}, function (err, result) { 

     // Flow is now completed, take a decision 
    if (err) { 
     // do nothing, maybe? 
    } else { 
     // execute all the Ordered Bulk 
     batch.execute().then(function(executionResult) { 
      // done, you can 
     }); 
    } 
}); 

注： 1）BulkOperationは、OrderedおよびUnOrderedにすることができます。 UnOrderedは何らかのエラーが発生してもパフォーマンスが向上し、作業を続ける 2）秩序が順番に実行され、何らかのエラーが発生した場合、MongoDはバルクの次の要素に進むことはありません。

ドキュメント： http://mongodb.github.io/node-mongodb-native/2.0/api/Collection.html#initializeOrderedBulkOp