Javascript/Node.js非同期ループ

Question

一般的にノードの非同期性に問題があります。誰かがこのコードブロックで私を助けることができますか？いろいろな理由で、私は作業しているデータベースに一度に1行しか挿入できません。そして、実際には、短い遅延を追加して1秒間に1行だけをデータベースに挿入することができればさらに良いでしょう。

ここに私のjsコードの短いセクションです。

console.log('*** Inserting Records ***') 
insertPromises = [] 
_.each(dbRecords, function (item) { 
    var insertItem = buildRecord(item) 
    insertPromises.push(conn.create(insertItem)) 
}) 
Promise.all(insertPromises).then(function (res) { 
    _.each(res, function (item) { 
     if (!item.success) { 
      console.log("### Error ### " + JSON.stringify(res[i].errors)) 
     } 
    }) 
    console.log('*** Inserted ' + res.length + ' Contacts') 
}) 

私の主な質問は、ループを続行する前にconn.createの約束を待つように強制する方法です。そして、1秒間に1回の繰り返しにループを遅らせる方法はありますか？

Answer 1

上記の再帰コードを使用する代わりに、async/awaitモデルを確認することができます。

これを使用する例は次のようになります。

async function processRecords(dbRecords) { 

    for (let item of dbRecords) { 
     try { 
      let insertItem = buildRecord(item) 
      await conn.create(insertItem) 
      await delay(1000) 
     } catch (e) { 
      //handle error... 
     } 
    } 

} 

function delay(ms) { 
    return new Promise((resolve) => setTimeout(resolve, ms)) 
} 

processRecords(dbRecords) 

これはES7コードであり、あなたはそれを変換するためにbabelコンパイラが必要です。

約束に追いついておらず、同期のようなコードに固執したい場合は、このようなものを使用する方が良いでしょう。

Answer 2

簡単な解決策は、「挿入カウント」、つまり正常に挿入されたレコードの数を記録することです。これはあなたの配列ポインタになります。メソッドを使用して個々の約束を作成し、成功した応答ごとに「挿入カウント」を1ずつ増やします。

let insertCount = 0; 

function insertNextRecord() { 
    conn.create(buildRecord(dbRecords[insertCount]).then(function(res){ 
     insertCount += 1; 
     insertNextRecord(); 
    }).catch(function() { 
     console.log('Error while inserting record ' + insertCount); 
    }); 
} 

insertNextRecord(); 

これはテストされていないと私はあなたが表示されていないしているコードに関するいくつかの仮定を作ってるんです。

この例では想定しています

• dbRecordsは、アレイ
• conn.createが明示的に遅延を追加することを約束オブジェクト

を返し、あなたはそのようthenメソッド内でタイムアウトを使用することができています：

let insertCount = 0; 

function insertNextRecord() { 
    conn.create(buildRecord(dbRecords[insertCount]).then(function(res){ 
     insertCount += 1; 
     setTimeout(function() { 
      insertNextRecord(); 
     }, 500); 
    }).catch(function() { 
     console.log('Error while inserting record ' + insertCount); 
    }); 
} 

insertNextRecord(); 

このようにしなければならないのは残念です。多くのインサートを扱う場合、これは非常に遅くなります。