Firebase云函数使用Promise时意外终止问题排查

我有一个使用onRequest的Firebase HTTPS函数，需要处理3800个分类并将其分批封装为Promise。函数每次执行5个HTTP请求后等待1000毫秒以让API恢复，但函数运行约6分钟后会在while循环处莫名终止，无法继续执行，且无任何报错信息。该函数为v2版本，已设置60分钟超时时间，请问是否存在未解决的Promise导致此问题？

函数代码 #

async function hideCategories(req, res) {
  try {
    const appId = req.query.id

    if (isEmpty(appId) && res) {
      // 如果函数是定时触发的，不会有响应对象
      res.status(404).send('App ID是必填参数。')
    }

    if (res) {
      res.status(200).send({ status: '任务已启动', code: 200 })
    }

    // 遍历每个分类，检查在线且有库存的商品总数
    // 如果分类为空，将其标记为hide: true存入Firebase
    const categories = await getCategoriesAndLevels(appId, 3)
    // 复制分类数组，因为后续会用splice修改原数组
    const clearanceCategories = { ...categories }

    const queryCount = clearanceCategories.length + categories.length
    const categoryIdsToHide = []
    const categoryIdsToShow = []

    let categoryCount = 0

    while (categories.length) {
      // eslint-disable-next-line no-await-in-loop
      await Promise.all([
        ...categories.splice(0, 5).map((category) => {
          const { id, level } = category
          let productCountPromise = null
          // 仅检查3级及以上分类
          if (level >= 3) {
            productCountPromise = getProductCount(appId, id)
          }
          categoryCount += 1
          return productCountPromise
            ? productCountPromise.then((productCount) => {
                // 仅对3级及以下分类进行隐藏/显示操作
                if (productCountPromise <= 0) {
                  categoryIdsToHide.push(id)
                } else if (productCountPromise > 0) {
                  categoryIdsToShow.push(id)
                }
              })
            : productCountPromise
        }),
        () => new Promise((resolve) => setTimeout(resolve, 1000)),
      ])
    }
  } catch (error) {
    console.log(`处理分类时出错: ${error}`)
  }
}

问题诊断与修复 #

1. 直接导致终止的核心原因：提前发送响应 #

Firebase HTTPS函数的生命周期规则是：一旦向客户端发送响应（res.send/res.end），函数进程会立即终止。你在分类处理逻辑开始前就调用了res.status(200).send(...)，这意味着函数在返回响应后就被强制终止，后续的while循环根本没有机会完成所有分类的处理。这是循环中途停止的最直接原因，和Promise是否解决无关。

2. 未解决的Promise确实存在隐患 #

代码里有两个会导致Promise链异常的问题：

• 未执行的setTimeout函数：你在Promise.all中传入了一个函数() => new Promise(...)，但没有调用它，这个函数永远不会返回Promise，导致整个Promise.all处于永久pending状态。如果不是提前发送响应终止了函数，这个问题也会让循环卡在第一个批次。
• null混入Promise数组：当分类level < 3时，productCountPromise为null，你直接返回null而非一个已resolve的Promise。虽然Promise.all会将非Promise值视为已resolve，但大量null存在可能导致批次处理的状态异常。

3. 其他逻辑错误 #

• 变量引用错误：在then回调中，你用productCountPromise <= 0判断，但productCountPromise是Promise对象，不是返回的商品数量数值，应该用productCount。这个错误会导致所有分类的判断逻辑失效。
• 异常捕获不完整：getProductCount如果抛出错误，虽然外层有try-catch，但Promise内部的错误如果没有被单独捕获，会导致整个批次的Promise.all reject，而当前的catch块仅打印日志，没有兜底逻辑。

修复步骤 #

步骤1：延迟发送响应

移除提前发送响应的代码，等到所有分类处理完成后再返回结果：

// 移除原有的提前res.send代码
// ... 所有分类处理逻辑完成后 ...
if (res) {
  res.status(200).send({ 
    status: '任务完成', 
    code: 200,
    hiddenCategories: categoryIdsToHide.length,
    shownCategories: categoryIdsToShow.length
  })
}

如果需要告知客户端任务已启动，可以改用Firebase Cloud Tasks，将分类处理逻辑放到后台任务中，HTTPS函数仅负责触发任务并立即返回。

步骤2：修正Promise.all中的setTimeout

将未执行的函数改为直接创建Promise：

await Promise.all([
  ...categories.splice(0, 5).map(/* ... */),
  new Promise((resolve) => setTimeout(resolve, 1000)) // 直接实例化Promise
])

步骤3：处理level < 3的情况

当分类级别不足时，返回一个已resolve的Promise，避免null混入：

return productCountPromise
  ? productCountPromise.then((productCount) => {
      // 修正变量引用为productCount
      if (productCount <= 0) {
        categoryIdsToHide.push(id)
      } else {
        categoryIdsToShow.push(id)
      }
    })
  : Promise.resolve() // 返回已resolve的空Promise

步骤4：完善异常捕获

为每个getProductCount的Promise添加单独的catch，避免单个请求失败导致整个批次终止：

productCountPromise
  .then((productCount) => {
    if (productCount <= 0) {
      categoryIdsToHide.push(id)
    } else {
      categoryIdsToShow.push(id)
    }
  })
  .catch((err) => {
    console.error(`处理分类ID ${id}失败:`, err)
    // 可记录失败的分类ID，后续重试
  })

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