如何一次性获取Firestore多个集合组文档？查询结果不稳定排查

我的Firestore数据结构为：不同grade文档下包含多个subject子集合，每个subject子集合中存储着question文档。我希望一次性获取所有subject子集合中的question文档，因此尝试使用Collection group queries实现，但遇到问题：代码有时能返回所有question文档，有时却不能。

我尝试的代码 #

const getAllQuestions = (request,response)=>{
    const subjects = ['Maths','English']
    const questionsArray = []
    subjects.forEach((subject,index)=>{
        
     db.collectionGroup(subject)
                       .get()
                       .then((querySnapshot)=>{
                        querySnapshot.forEach((doc) => {
                            questionsArray.push({...doc.data(),id:doc.id})
                        })
                        if(index==subjects.length-1){
                            response.status(200).json({
                                    status:200,
                                    data:questionsArray,
                                    length:questionsArray.length
                          })
                         }
      })
    })
 }

问题原因 #

问题出在同步遍历和异步请求的冲突上：forEach是同步执行的，但db.collectionGroup(subject).get()是异步操作。当最后一次forEach循环触发时，前面的集合查询可能还没完成，这时候返回的questionsArray就会缺少未完成查询的数据，导致结果时好时坏。

解决方案1：用Promise.all统一处理异步请求 #

把每个集合组查询包装成Promise，等待所有请求完成后再返回结果：

const getAllQuestions = async (request, response) => {
  try {
    const subjects = ['Maths', 'English'];
    // 生成所有集合组查询的Promise数组
    const queryPromises = subjects.map(subject => 
      db.collectionGroup(subject).get()
    );
    
    // 等待所有查询完成
    const querySnapshots = await Promise.all(queryPromises);
    
    const questionsArray = [];
    querySnapshots.forEach(snapshot => {
      snapshot.forEach(doc => {
        questionsArray.push({ ...doc.data(), id: doc.id });
      });
    });
    
    response.status(200).json({
      status: 200,
      data: questionsArray,
      length: questionsArray.length
    });
  } catch (error) {
    response.status(500).json({
      status: 500,
      error: error.message
    });
  }
};

解决方案2：优化集合结构（可选） #

如果后续会新增更多科目，每次修改subjects数组很繁琐。可以把所有科目子集合统一命名为questions，这样一次集合组查询就能获取所有数据：
调整后的数据结构：grade/{gradeId}/questions/{questionId}
简化后的查询代码：

const getAllQuestions = async (request, response) => {
  try {
    const querySnapshot = await db.collectionGroup('questions').get();
    const questionsArray = querySnapshot.docs.map(doc => ({ ...doc.data(), id: doc.id }));
    
    response.status(200).json({
      status: 200,
      data: questionsArray,
      length: questionsArray.length
    });
  } catch (error) {
    response.status(500).json({
      status: 500,
      error: error.message
    });
  }
};

注意事项 #

• 确保已为目标集合组（比如Maths、English或调整后的questions）创建对应的集合组索引，否则查询会报错。
• 必须做好错误捕获，避免请求因异常挂起。

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