GraphQL resolver中async await+Promise.all出现UnhandledPromiseRejectionWarning如何处理

问题原因 #

你遇到的UnhandledPromiseRejectionWarning警告通常由两个原因导致：

• 部分Node.js版本中，在await Promise.all执行前如果有某个Promise已经触发reject，会被暂时判定为未处理的拒绝，即使后续await时会被catch捕获，仍然会触发警告。
• 若你catch块中抛出的错误没有被GraphQL服务框架的上层错误处理逻辑捕获，也会导致异步错误成为未处理的Promise拒绝。

解决方案 #

根据你的业务需求可以选择两种处理方式： #

方案1：任意请求失败就立即终止流程（快速失败） #

适合三个请求强依赖，只要有一个失败整个操作就无效的场景，给每个单独的Promise封装统一的错误捕获逻辑，避免提前reject触发警告：

createPost: async (
  _,
  { fields: { media, text, location } }) => {
  try {
    // 封装Promise统一处理错误，避免提前reject触发警告
    const wrapRequest = (requestPromise, requestName) => {
      return requestPromise.catch(err => {
        throw new Error(`${requestName}失败：${err.message}`)
      })
    }

    const firstRequest = wrapRequest(
      languageClient.classifyText({
        document: {
          content: text,
          type: 'PLAIN_TEXT'
        }
      }),
      '文本分类接口'
    )
    const secondRequest = wrapRequest(/* 第二个请求 */, '第二个接口')
    const thirdRequest = wrapRequest(/* 第三个请求 */, '第三个接口')

    const [classifyResult, secondResult, thirdResult] = await Promise.all([
      firstRequest,
      secondRequest,
      thirdRequest
    ])

    // 后续业务逻辑
  } catch (error) {
    // 可在此处添加错误日志记录逻辑
    console.error('createPost执行失败：', error)
    throw error
  }
}

方案2：等待所有请求完成后统一处理每个请求的结果 #

适合三个请求无强依赖，单个请求失败不影响其他请求处理的场景，使用Promise.allSettled替代Promise.all，可以拿到所有请求的成功/失败结果：

createPost: async (
  _,
  { fields: { media, text, location } }) => {
  const firstRequest = languageClient.classifyText({
    document: {
      content: text,
      type: 'PLAIN_TEXT'
    }
  })
  const secondRequest = /* 第二个请求 */
  const thirdRequest = /* 第三个请求 */

  // 等待所有请求执行完成，无论成功失败
  const requestResults = await Promise.allSettled([
    firstRequest,
    secondRequest,
    thirdRequest
  ])

  const [classifyResult, secondResult, thirdResult] = requestResults

  // 单独处理每个请求的结果
  if (classifyResult.status === 'rejected') {
    // 自定义文本分类接口失败的处理逻辑，比如返回业务错误、打标记跳过分类逻辑等
    throw new Error(`文本分类失败：${classifyResult.reason.message}`)
  }
  if (secondResult.status === 'rejected') {
    // 处理第二个请求失败的逻辑
  }
  if (thirdResult.status === 'rejected') {
    // 处理第三个请求失败的逻辑
  }

  // 所有请求处理完成后的后续业务逻辑
  const classifyData = classifyResult.value
  // ...
}

额外注意事项 #

请确认你使用的GraphQL服务框架（如Apollo Server、express-graphql）的错误处理中间件配置正确，正常情况下async resolver抛出的错误会被框架自动捕获，放入GraphQL响应的errors字段中，不会触发Node.js层面的未处理Promise拒绝警告。

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