firebase批量更新和onWrite触发器同步

Question

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

举例来说，假设我有两个文档A和B(在两个单独的集合中)。

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

是否有一种方法来确保onWrite函数被触发只有在两个文档都写完后

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

Answer 1

批处理写入确保写入自动完成:如果一个写操作失败，则不执行其他写操作。另一方面，要回答您上面的一个评论，批处理写入并不能确保所有的写入都是"即时的"，顺便说一下，这是一个很难在IT中定义的概念，恕我直言:)。据我所知，批处理写操作并不能保证写操作按照它们被推送到批处理中的顺序进行。

所以，如果你想在所有组成批处理写的写完成时触发第二个云函数，你可以使用一个由Pub/Sub触发的云函数。

具体来说，在index.jsCloud 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);
// ...

编写一个pub/sub触发的云函数，执行所需的业务逻辑。如果需要使用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触发的云函数在执行批处理写时被执行，你可以通过批处理写用唯一的云函数eventId标记文档A和文档B。如果此标志在A和B中相同，则不执行onWrite触发的云功能中的业务逻辑，因为它将由pub处理。sub Cloud Function.

---

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