我在同步两个 Firebase 云功能时遇到问题,第一个对多个文档执行批量更新,第二个由其中一个文档的 onWrite
触发器触发。
为了说明,假设我有两个文档 A
和 B
(在两个单独的集合中)。
- 第一个云函数使用 firestore
WriteBatch
更新文档A
和B
(两个文档都已成功更新); - 写入文档
B
会触发另一个云函数(使用onWrite
触发器)。该函数需要读取文档A
; - 我在第二个函数中有一个错误,那是因为它读取了文档
A
的旧版本(在第一个函数写入批处理之前)。
有没有办法确保 onWrite
函数被触发只有在两个文档都被写入之后?
我可以分别更新它们并等待 A
在第一个函数中写入 B
之前写入,但我想在一个事务中保持两者的更新,因为这些文档是链接在一起的,我不想冒险只更新一个而没有更新另一个。
最佳答案
批处理写入可确保写入以原子方式完成:如果一个写入失败,则不会执行其他写入。另一方面,为了回答您上面的一条评论,批量写入并不能确保所有写入都是“瞬时的”,顺便说一下,这是一个很难在 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 处理。
当然,这是基于几个假设并且必须处理事件流,但这可能是一个可能的解决方案!
关于firebase批量更新和onWrite触发同步,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/65809665/