firebase批量更新和onWrite触发同步

Question

我在同步两个 Firebase 云功能时遇到问题，第一个对多个文档执行批量更新，第二个由其中一个文档的 onWrite 触发器触发。

为了说明，假设我有两个文档 A 和 B(在两个单独的集合中)。

• 第一个云函数使用 firestore WriteBatch 更新文档 A 和 B(两个文档都已成功更新)；
• 写入文档 B 会触发另一个云函数(使用 onWrite 触发器)。该函数需要读取文档A;
• 我在第二个函数中有一个错误，那是因为它读取了文档 A 的旧版本(在第一个函数写入批处理之前)。

有没有办法确保 onWrite 函数被触发只有在两个文档都被写入之后？

我可以分别更新它们并等待 A 在第一个函数中写入 B 之前写入，但我想在一个事务中保持两者的更新，因为这些文档是链接在一起的，我不想冒险只更新一个而没有更新另一个。

Answer 1

批处理写入可确保写入以原子方式完成:如果一个写入失败，则不会执行其他写入。另一方面，为了回答您上面的一条评论，批量写入并不能确保所有写入都是“瞬时的”，顺便说一下，这是一个很难在 IT 中定义的概念，恕我直言:- ). AFAIK，批处理写入并不能确保写入将按照它们被推送到批处理的顺序完成。

因此，如果您想在组成批处理写入的所有写入完成时触发第二个 Cloud Function，您可以使用通过 Pub/Sub 触发的 Cloud Function。

具体来说，在您的index.js Cloud Functions 文件中执行以下操作:

声明一个发布消息的函数:

async function publishMessage(messageConfig) {
    try {
        const pubSubClient = new PubSub();

        const topicName = messageConfig.topicName;
        const pubSubPayload = messageConfig.pubSubPayload;

        let dataBuffer = Buffer.from(JSON.stringify(pubSubPayload));
        await pubSubClient.topic(topicName).publish(dataBuffer);

    } catch (error) {
        throw error;
    }
}

在提交批处理的 Cloud Function 中，在批处理写入完成时发布一条消息:

    await batch.commit();
    
    messageConfig = {
          topicName: 'your-topic',
          pubSubPayload: {
              docA_Id: '..........',  // Id of doc A
              docB_Id: '..........'   // Id of doc B
          }
    }
    await publishMessage(messageConfig);
    // ...

编写一个发布/订阅触发的云函数来执行所需的业务逻辑。如果需要用onWrite触发器来触发相同的业务逻辑，共享两个函数之间的代码

    exports.updateDocB = functions.pubsub.topic('your-topic').onPublish(async (message) => {

       const docA_Id = message.json.docA_Id;   
       const docB_Id = message.json.docB_Id;   

       await updateDocB(docA_Id, docB_Id);
       // ...
    
    })


    async function updateDocB(docA_Id, docB_Id)  {
       // ......
    }
    // Call this function from the onWrite CF

如果您想避免在执行批量写入时执行 onWrite 触发的 Cloud Function，您可以使用唯一的 Cloud Function eventId 标记文档 A 和 B。通过批量写入。如果此标志在 A 和 B 中相同，则您不会在 onWrite 触发的 Cloud Function 中执行业务逻辑，因为它将由 pub.sub Cloud Function 处理。

---

当然，这是基于几个假设并且必须处理事件流，但这可能是一个可能的解决方案!