在 promise.allSettled() 中强制进行受控拒绝

Question

我试图以受控方式强制拒绝 promise.allSettled() 函数。 这个想法是通过 API 批量运行一系列 url，这个 API 不时为给定请求返回 500 错误，并且可以安全地重试。所以我想在 promise.allSettled() 上触发拒绝，我可以在其中收集失败的 url，然后在递归时重新运行。

批量请求功能

export async function batchRequest(poolLimit, array, iteratorFn, exception) {
  const promises = []
  const racers = new Set()

  for (const item of array) {
    const pro = Promise.resolve().then(() => iteratorFn(item, array))
    promises.push(pro)
    racers.add(pro)
    const clean = () => racers.delete(pro)
    pro.then(clean).catch(clean)

    if (racers.size >= poolLimit) await Promise.race(racers)
  }


  const results = await Promise.allSettled(promises)

  // Collect errors rejected by iteratorFn,
  const rejected = results
    .filter(({ status, reason }) => status === 'rejected' && reason.name === exception)
    .map(({ reason }) => reason.error)

  // Recurse the array of rejected urls
  if (rejected.length) {
    await batchRequest(poolLimit, rejected, iteratorFn, exception)
  }
}

在这里，我们正常运行承诺，但收集所有被拒绝的 url，我试图使用 exception 'timeout' 作为规则来确定它是否需要重新运行，因为它只是一个超时错误。

迭代函数

async function runRequest(url) {
  try {
    const { data } = await axios('https://exampleAPI.com')
    // Take the data and write it somewhere...
  
  } catch (error) {

    if (error.response.status === 500) {
      throw { name: 'timeout', url }
    }
  }
})

const urls = [...many urls]
await batchRequest(100, urls, runRequest, 'timeout')

我收到一条错误消息

This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). The promise rejected with the reason "#<Object>".] { code: 'ERR_UNHANDLED_REJECTION' }

我如何强制对promise.allSettled() 进行受控拒绝？

更新------

我发现未处理的拒绝是在我开始 batchrequest 的时候

await batchRequest(100, urls, runRequest, 'timeout')

我需要在那里尝试捕获，但重点是使用 promise.allSettled() 来吸收错误而不是脱离 batchrequest

Answer 1

在我看来，您没有处理 runRequest 或第一次调用 iteratorFn 抛出的异常。这就是导致“未处理的异常”错误的原因。

我建议通过调试器运行此代码并逐行执行，直到找到导致抛出该异常的行。

Answer 2

只需手动处理每个承诺并收集错误和结果，并在所有承诺都解决后返回或抛出：

const errors = [];
const results = [];

Promise.all(
  promises.map(p => p.then(r => results.push(r)).catch(e => errors.push(e))
).then(() => {
  if (errors.length) throw errors;

  return results;
});