Firebase Cloud Function首次执行更新文档耗时数分钟求助

核心问题分析 #

• 异步操作未正确等待：使用forEach遍历异步函数时，forEach不会等待异步任务完成，导致云函数主线程提前结束，后续的doc.get()和更新操作可能在后台被延迟执行甚至强制终止，这是日志显示doc.get()耗时异常的主要原因。
• 非原子性更新引发并发问题：直接通过get()读取库存再set()更新的方式，在多用户同时下单时会出现库存超卖——多个请求可能同时读取到相同的库存值，再各自计算更新，最终导致库存数据错误。
• 冷启动放大延迟：云函数首次调用的冷启动会增加初始响应时间，结合代码异步处理的问题，进一步拉长了操作耗时。

修正后的代码 #

// 更新购物篮创建后的菜品库存
exports.updateDishesQuantity = functions.firestore.document('/Baskets/{documentId}').onCreate(async (snap, context) => {
  try {
    const originalBasket = snap.data();
    const orderedDishes = originalBasket.OrderedDishes;

    // 用Promise.all等待所有异步更新操作完成
    await Promise.all(orderedDishes.map(async (dish) => {
      const dishRef = db.collection('Dishes').doc(dish.DishID);
      
      // 使用事务确保库存更新的原子性
      await db.runTransaction(async (transaction) => {
        const dishDoc = await transaction.get(dishRef);
        if (!dishDoc.exists) {
          console.log(`菜品ID ${dish.DishID} 不存在`);
          return;
        }
        
        const currentAvailable = dishDoc.data().Available;
        const newAvailable = Math.max(currentAvailable - dish.Quantity, 0);
        transaction.update(dishRef, { Available: newAvailable });
        console.log(`菜品 ${dish.DishID} 库存已更新为 ${newAvailable}`);
      });
    }));

    console.log("所有菜品库存更新完成");
    return null;
  } catch (error) {
    console.error("库存更新失败:", error);
    return null;
  }
});

关键改进说明 #

• 用map替代forEach，配合Promise.all等待所有菜品的库存更新操作完成，确保云函数不会提前终止，保证所有异步任务执行完毕。
• 使用Firestore事务（runTransaction）原子执行"读取-更新"流程，彻底避免并发场景下的库存数据不一致问题。
• 统一使用async/await替代混合async/await与.then()的写法，提升代码可读性和调试效率。

内容的提问来源于stack exchange，提问作者Florent Pausé