时间戳

首页 > 解决方案 > nodejs中的递归重试功能

node.js - nodejs中的递归重试功能

问题描述

我是 nodejs 和 ES6 的新手，并试图了解承诺。如果结果不可接受，我需要在特定时间间隔（在这种情况下为 5 秒）重试 dynamodb 查询函数！所以我有这样的功能：

const retryFunc = (ddbParams, numberOfRetry) => {
return new Promise((resolve, reject) => {
  return DDBUtils.query(ddbParams).then(result => {
    //need to return a specific number of rows from the ddb table
    if(numberOfRetry > 0){
      if(result.length !== 100){
        numberOfRetry = numberOfRetry - 1
        setTimeout(() => {
          retryFunc(ddbParams, numberOfRetry)
        }, 5000)
      }
    }
    resolve(result)
  }).catch(error => {
    reject(error)
  })
})

}

当 dynamodb 查询在第一次调用中返回可接受的结果（100 条记录）时，该函数工作正常并将结果返回给调用者。但是如果函数需要重试以满足 100 条件，那么它不会在满足时将结果返回给调用者！任何人都可以帮助我了解正在发生的事情吗？

标签： node.jspromisesettimeout

解决方案

首先，避免显式的 promise 构造反模式——.query已经返回 a Promise，所以没有必要构造另一个。然后，你在你的内部if(result.length !== 100){，你需要能够将递归调用链接在一起retryFunc；您不能直接return从 (asynchronous, callback-based) setTimeout，就像您当前的代码一样。

一种选择是创建一个delay函数，该函数返回Promise在所需时间后解析的 a - 然后，您可以使用它return delay(5000).then(() => retryFunc(ddbParams, numberOfRetry - 1))来返回递归调用。

const delay = ms => new Promise(res => setTimeout(res, ms));
const retryFunc = (ddbParams, numberOfRetry) => {
  return DDBUtils.query(ddbParams).then(result => {
    if(numberOfRetry > 0 && result.length !== 100) {
      return delay(5000).then(() => retryFunc(ddbParams, numberOfRetry - 1));
    }
  });
}

推荐阅读