求助：使用Cloud Functions删除Firestore文档及子集合时代码报错

错误原因 #

你遇到的TypeError: subcollections.forEach is not a function，核心问题是doc.ref.listCollections()和subcollection.listDocuments()都是异步方法，返回的是Promise对象而非直接的数组，因此无法直接调用forEach。同时原代码未正确等待异步操作完成，回调嵌套也导致Promise未被妥善处理。

修正后的代码 #

改用async/await风格重构代码，正确处理所有异步操作：

const firebase = require("firebase-admin");
const functions = require("firebase-functions"); // 补全原代码遗漏的模块引入
firebase.initializeApp();
const firestore = firebase.firestore();

exports.deleteOldRounds = functions.pubsub
    .schedule("every 1 minute")
    .onRun(async function(context) {
      const oneHourAgo = new Date(Date.now() - (1 * 60 * 1000));
      try {
        const snapshot = await firestore
            .collection("Rounds")
            .where("createDate", "<", oneHourAgo)
            .get();

        if (snapshot.empty) {
          console.log("No old rounds to delete.");
          return null;
        }

        const batch = firestore.batch();
        // 遍历主文档，用for...of支持异步操作
        for (const doc of snapshot.docs) {
          batch.delete(doc.ref);
          // 等待获取子集合列表
          const subcollections = await doc.ref.listCollections();
          // 遍历每个子集合
          for (const subcollection of subcollections) {
            // 等待获取子集合内所有文档
            const subDocs = await subcollection.listDocuments();
            subDocs.forEach(subDoc => batch.delete(subDoc));
          }
        }

        await batch.commit();
        console.log("Old rounds and their subcollections deleted successfully.");
        return null;
      } catch (error) {
        console.error("Error deleting old rounds:", error);
        throw error; // 抛出错误让Cloud Functions记录完整信息
      }
    });

关键修改点 #

• 将onRun回调改为async函数，用await处理所有Firestore异步操作，避免回调嵌套
• 用for...of循环替代forEach，因为forEach无法正确处理内部的await逻辑
• 补全原代码遗漏的functions模块引入
• 等待listCollections()和listDocuments()返回Promise，拿到实际数组后再执行遍历
• 在catch块中抛出错误，确保Cloud Functions能捕获并记录完整错误日志
• 确保所有异步操作完成后再结束函数，避免提前返回导致操作中断

注意事项 #

Firestore批量操作最多支持500个写入动作，如果你的主文档+子文档总数超过500，需要拆分多个batch或用递归方式分批处理，避免触发限制。

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