带有子集合的 Firestore 查询

Question

这是对 Firebase 的限制，还是我做错了？一切正常，直到我在代码中间添加db.collection('users').doc(friendId).get()...。提前致谢。

const db = admin.firestore();
const friendRef = db.collection('users').doc(id).collection('friends');

friendsList = [];

friendRef.get().then((onSnapshot) => {
    if (!onSnapshot.empty) {
        onSnapshot.forEach((friend) => {

            const friendId = String(friend.data().person_id);

            db.collection('users').doc(friendId).get().then((result) => {
                const firstName = String(result.data().name.first);
                const lastName = String(result.data().name.last);
            })

            const data = {
                personId: friendId,
                firstName: firstName,
                lastName: lastName,
            }

            friendsList.push(data);
        })

        res.send(friendsList);
    } else {
        res.send({
            'message': 'no friends'
        });
    }
}).catch((e) => {
    res.send({
        'error': e
    });
})

Answer 1

数据从 Firestore 异步加载。这意味着当您将响应发送回客户端时，尚未从 Firestore 加载数据。

查看这一点的最简单方法是使用一些放置良好的日志语句：

console.log("Before getting friend");
db.collection('users').doc(friendId).get().then((result) => {
  console.log("Got friend");
})
console.log("After getting friend");

当你只运行这段代码时，它会打印：

交朋友之前

交朋友后

有朋友

这可能不是您期望的日志顺序。原因是数据可能需要一些时间才能从 Firestore 中返回。因此，它不会阻塞线程，而是继续运行线程，然后在数据可用时调用您的回调函数。不幸的是，这意味着您的 res.send(friendsList) 最终会向客户端发送一个空列表，因为数据尚未加载。

解决这个问题的方法是使用一堆嵌套回调，使用Promise.all()，或者ES6 的新async/await 关键字。使用 Promise，代码如下所示：

const db = admin.firestore();
const friendRef = db.collection('users').doc(id).collection('friends');

friendRef.get().then((onSnapshot) => {
  var promises = [];

  onSnapshot.forEach((friend) => {
    const friendId = String(friend.data().person_id);    
    promises.push(db.collection('users').doc(friendId).get());
  });

  Promise.all(promises).then((snapshots) => {
    friendsList = [];
    snapshots.forEach((result) => {
      friendsList.push({
        personId: result.id,
        firstName: result.data().name.first,
        lastName: result.data().name.last,
      });
    });
    res.send(friendsList);
  });
}).catch((e) => {
  res.send({
    'error': e
  });
})

因此，我们首先构建所有好友读取操作的列表，然后在所有这些操作完成后，我们构建响应并将其发回。