循环内Promise.all批量请求的异常捕获及未处理Promise疑问

核心结论 #

1. 推入requests数组的writeRecords Promise发生错误时，不会产生未处理Promise错误——因为这些Promise都被传入了Promise.all，Promise.all会监听它们的状态变化，包括reject状态。
2. 你当前代码中的外层try/catch无法捕获这些错误，因为Promise.all的reject是异步触发的，而该try/catch仅包裹同步的return语句，异步错误不会进入这个catch块。

详细解释 #

1. 关于未处理Promise错误的问题

当你执行writeClient.writeRecords(timestreamParams).promise()时，请求立即发起，返回的Promise对象被加入requests数组。无论这个Promise后续成功还是失败，它的状态都会被Promise.all跟踪。只要Promise被某个消费者（比如Promise.all）处理，即使它reject了，也不会被标记为“未处理Promise”。

2. 外层try/catch的无效性分析

你的代码中，try块内的代码是同步执行的：

try {
  return Promise.all(requests).then((res) => ok(res))
} catch (error) {
  return err({ error, params })
}

return Promise.all(...)这行代码同步执行后，函数就返回了一个Promise实例，此时try/catch的同步执行流程已经结束。而Promise.all的reject是异步发生的，这个异步错误无法被同步的try/catch捕获。

3. 正确的错误捕获方式

要捕获Promise.all的错误，有两种可行方式：

• 方式一：使用Promise链的.catch()

  return Promise.all(requests)
    .then(res => ok(res))
    .catch(error => err({ error, params }))
  

• 方式二：在async函数中用await配合try/catch
  如果你的代码所在函数是async函数，可以改成：

  try {
    const res = await Promise.all(requests)
    return ok(res)
  } catch (error) {
    return err({ error, params })
  }
  

4. 循环中静默catch的影响

你循环里先执行await writeClient.writeRecords(...).promise().catch(() => {})，这个操作会静默忽略首次请求的错误，循环会继续执行并将新的请求Promise推入数组。首次请求的失败不会影响后续请求的发起，后续请求的错误会被上述正确的捕获方式处理。

内容的提问来源于stack exchange，提问作者Ilijanovic