在递归承诺中处理异常

Question

我正在尝试既能够处理分页 API，又能够在因过多请求而受到限制时重试。如果响应对象中存在“nextToken”，则通过递归处理分页。我希望能够捕获一个限制异常，并通过在不传递令牌的情况下递归有效地重新启动整个请求。这是我当前的代码：

function getAllExecHist(execArn) {
  var sfn = new AWS.StepFunctions();
  sfn = Promise.promisifyAll(sfn); 
  execHists = [];
  return new Promise(function(resolve, reject) {
    function getExecHist(nextToken) {
      params = {};
      params.executionArn = execArn;
      if (nextToken !== undefined) {
        params.nextToken = nextToken;
      }
      sfn.getExecutionHistoryAsync(params)
        .then(function(results) {
          execHists = execHists.concat(results.events);
          if (!results.nextToken) {
            resolve(execHists);
          }
          else {
            getExecHist(results.nextToken);
          }
        })
        .catch(function(e) {
          console.log('caught this: ', e);
          console.log('retrying');
          return new Promise(function(res, rej) {
          console.log('Sleeping');
          setTimeout(function() {
            execHists = [];
            res(getExecHist()); 
          }, random(100,10000));
          });         
        })
    }
    getExecHist();
  });
}

递归处理分页没有问题，但自从添加了catch，它就永远不会返回。任何想法我做错了什么/如何解决？

Answer 1

AWS SDK supports promises，您可以将 Bluebird 配置为它的 Promise 库。

const Promise = require('bluebird');
const AWS = require('aws');
AWS.config.setPromisesDependency(Promise);
const sfn = new AWS.StepFunctions();

使用Promise.delay() 代替setTimeout。

如果函数已经返回它们，请尽量避免创建新的 Promise。仅当您有很多可能引发错误或需要尽早解决承诺的同步代码时，才将承诺包装在 new Promise 中。

以下还通过在函数调用之间传递值来避免额外的函数和嵌套范围。

function getExecHist(execArn, execHists, nextToken) {
  let params = {};
  params.executionArn = execArn;
  if ( nextToken !== undefined ) params.nextToken = nextToken;
  if ( execHists === undefined ) execHists = [];
  return sfn.getExecutionHistory(params).promise()
    .then(results => {
      execHists = execHists.concat(results.events);
      if (!results.nextToken) return execHists;
      return getExecHist(execArn, execHists, results.nextToken);
    })
    .catch(e => {
      console.log('caught this: ', e);
      console.log('retrying');
      return Promise.delay(random(100,10000))
        .then(() => getExecHist(execArn));
    })
}

最终，您应该具体说明重试的错误，并包括计数或时间限制。

另请注意，这是重试速率限制问题的错误方法，因为它会从头开始。速率限制重试应该从它停止的地方继续，否则你只是增加了速率限制问题。