节点：Promise 链中的 For 循环延迟 [重复]

Question

我的 Node 应用程序将发票数据发送到 API，我希望我的应用程序在每次发票发布后按顺序发送数据/等待一段时间，因为如果一秒钟内有超过 20 个请求，API 服务器会阻止请求。

我认为一种方法是在每次迭代后暂停 for 循环，但我不确定如何实现。

下面是我目前将“发票生成”-promises 推送到 for 循环中的数组，然后使用 Promise.all 解决它们的代码。

感谢所有 cmets。

    // First, get access token from the service API
    serviceAPI.auth().then((token) => {

    // Array for the invoice promises
    let invoicePromises = [];

    // Push promises to the array
    for (let i = 0; i < rowAmount; i++) {
        invoicePromises.push(serviceAPI.generate(i, sheetData[i], token));
    }

    return Promise.all(invoicePromises);

    }).then((results) => {
    console.log(results);
    return utils.sortReport(results); // Return sorted results
    }).catch((e) => { console.error(e)});

Answer 1

而不是完全创建它们：

 for (let i = 0; i < rowAmount; i++) {
    invoicePromises.push(serviceAPI.generate(i, sheetData[i], token));
}
return Promise.all(invoicePromises);

可以建立一个接一个调用的 Promise 链：

 sheetData.reduce((promise, data, i) => promise.then(result => serviceAPI.generate(i, data, token).then(res => result.concat(res))), Promise.resolve([]));

不过，这有点像 Promise 地狱，所以让我们使用 async await 来代替：

return (async function(){
  const result;
  for (let i = 0; i < rowAmount; i++) {
    result.push(await serviceAPI.generate(i, sheetData[i], token));
   //optionally sth like await timer(1000);
  } 
 return result;
})();

Answer 2

要让 nodejs 应用稍等片刻然后继续运行，您可以使用 sleep 模块轻松完成此操作。

第一：npm install sleep --save

然后将其添加到代码中的 require 部分： const sleep = require('sleep');

然后在你的 for 循环中： sleep.sleep(5); // sleep for 5 seconds sleep.msleep(5); // sleep for 5 milliseconds