Firebase云功能错误：“超过截止日期”和“错误代码16”

Question

最近我的Firebase云函数经常出错。特别是当用户发布帖子并将帖子复制到用户所有追随者的提要集合时触发的功能。

我的代码是这样的：

exports.onCreatePost = functions.firestore
    .document("/Posts/{userId}/UserPosts/{postId}")
    .onCreate(async (snapshot, context) => {
    const postCreated = snapshot.data();
    const userId = context.params.userId;
    const postId = context.params.postId;

    // 1) Get all the followers of the user who made the post
    const followerRef = admin
        .firestore()
        .collection("Followers")
        .doc(userId)
        .collection("FollowerIds");

    return followerRef.get().then((querySnapshot) => {
        querySnapshot.forEach((doc) => {
                const followerId = doc.id;

                admin
                    .firestore()
                    .collection("Feed")
                    .doc(followerId)
                    .collection("FeedPosts")
                    .doc(postId)
                    .set(postCreated);
                });
                return null;
    });

});

直到最近，函数一直运行良好，但现在有些人有100个追随者，函数经常失败，有2个错误：

错误：进程已退出，代码为16

错误：超过4个截止日期：超过截止日期

我知道第一个错误意味着已经发送了一些类似头的信息，但我不知道我的函数有什么问题。我也知道firebase有一些写限制，但功能基本上只是向每个关注者提要集合中添加一个文档，所以我认为写限制不应该受到影响。

要总结我的数据库结构：

>

Feed（集合）userId（文档）FeedPosts（子集合）postId（文档）

Followers（集合）userId（文档）FollowerIds（子集合）FollowerIds（文档）

Posts（集合）userId（文档）UserPosts（子集合）postId（文档）

Answer 1

exports.onCreatePost = functions.firestore.document("/Posts/{userId}/UserPosts/{postId}").onCreate(async (snapshot, context) => {
    const postCreated = snapshot.data();
    const userId = context.params.userId;
    const postId = context.params.postId;
    // 1) Get all the followers of the user who made the post
    const followerRef = await admin.firestore().collection("Followers").doc(userId).collection("FollowerIds").get();
    const promises = [];
    followerRef.forEach((doc) => {
         const followerId = doc.id;
         promises.push(admin.firestore().collection("Feed").doc(followerId).collection("FeedPosts").doc(postId).set(postCreated)}));
    });
    await Promise.all(promises);
    });

});

一旦请求得到满足，云功能就会收回资源。因此，必须先使用wait来检索数据。请阅读有关async/Wait的更多信息

Answer 2

您错误地管理了云功能的生命周期。在调用异步方法的后台云函数中返回promise，会告诉云函数平台在清理函数之前，等待promise得到履行或拒绝。看见https://firebase.google.com/docs/functions/terminate-functions更多细节。

由于在foreach（）循环中，您正在执行对异步set（）方法的可变数量的调用，因此需要使用Promise.all（）以获得唯一的Promise（当调用set（）方法返回的所有promise都已解决时，该方法将解析，然后您可以返回这些promise，如下所示：

exports.onCreatePost = functions.firestore.document("/Posts/{userId}/UserPosts/{postId}").onCreate(async (snapshot, context) => {
    const postCreated = snapshot.data();
    const userId = context.params.userId;
    const postId = context.params.postId;

    const followersQuerySnapshot = await admin.firestore().collection("Followers").doc(userId).collection("FollowerIds").get();
    const promises = followersQuerySnapshot.docs.map(  // followersQuerySnapshot.docs is an Array of QueryDocumentSnapshots
      doc => admin
       .firestore()
       .collection("Feed")
       .doc(doc.id)
       .collection("FeedPosts")
       .doc(postId)
       .set(postCreated)
      );

    return Promise.all(promises);  // <= Important, here return the promise returned by Promise.all()
    });

});