【发布时间】:2021-10-08 12:50:25
【问题描述】:
【问题讨论】:
标签: firebase google-cloud-firestore google-cloud-functions firebase-extensions
【问题讨论】:
标签: firebase google-cloud-firestore google-cloud-functions firebase-extensions
通过检查code,我们可以看到扩展程序已经处理了对文档的所有写入:
export const processQueue = functions.handler.firestore.document.onWrite(
...
从further 的角度看,似乎扩展对写入的操作取决于文档中delivery.state 字段的值。
async function processWrite(change) {
...
const payload = change.after.data() as QueuePayload;
...
switch (payload.delivery.state) {
case "SUCCESS":
case "ERROR":
return null;
case "PROCESSING":
if (payload.delivery.leaseExpireTime.toMillis() < Date.now()) {
// Wrapping in transaction to allow for automatic retries (#48)
return admin.firestore().runTransaction((transaction) => {
transaction.update(change.after.ref, {
"delivery.state": "ERROR",
error: "Message processing lease expired.",
});
return Promise.resolve();
});
}
return null;
case "PENDING":
case "RETRY":
// Wrapping in transaction to allow for automatic retries (#48)
await admin.firestore().runTransaction((transaction) => {
transaction.update(change.after.ref, {
"delivery.state": "PROCESSING",
"delivery.leaseExpireTime": admin.firestore.Timestamp.fromMillis(
Date.now() + 60000
),
});
return Promise.resolve();
});
return deliver(payload, change.after.ref);
}
}
我的猜测是,如果您清除该字段,扩展程序将接收该更改并尝试再次邮寄文档。
【讨论】:
delivery.state。你试过了吗?