Firebase事务不会在失败时重复

如何解决Firebase事务不会在失败时重复

更新：

这是我收到的console.error(err)消息：

Error: 6 ALREADY_EXISTS: Document already exists: projects/projectOne-e3999/databases/(default)/documents/storage/AAAAAAAAAA1111111111

我知道为什么会得到错误。因为并行运行的事务处理更快地执行了事务的else部分。因此，返回错误的事务不必创建而是要更新文档。如果交易可以重新运行就足够了。但这并没有说明Transactions are committed once 'updateFunction' resolves and attempted up to five times on failure。

这就是问题的全部。在文档已经存在的情况下，由于它是并行创建的，或者如何重新运行该交易，如何防止交易失败？

原始问题：

我具有云功能，每当创建另一个集合中的文档时，该功能就会更新另一个文档。由于可以并行创建多个文档，而所有文档都可以访问同一文档（将作为事务运行），因此可以确保幂等。

该函数的结构如下所示。问题是第一次写入（因此创建了存储文档）。正如我所说的，可以并行创建两个文档。但是现在，该事务读取了一个不存在的文档并尝试创建该文档，但是当另一个事务（并行运行一个）已创建该文档时，该事务将失败。（首先我不理解，因为我认为该事务将在执行时阻止所有访问）

这根本不是问题，但是它不会重试（尽管它声明最多可以自动重试5次）。我认为这与异步功能的try＆catch块有关。

如果重试，它将检测到该文档是否存在并自动更新现有文档。

让我们简单点。此事务绝不能失败。如果没有一种可能的自动恢复方法，它将使数据库不一致。

.onCreate(async (snapshot,context) => {
        //Handle idempotence
        const eventId = context.eventId;
        try {
            const process = await shouldProcess(eventId)
            if (!process) {
                return null
            }

            const storageDoc = admin.firestore().doc(`storage/${snapshot.id}`)

           
            await admin.firestore().runTransaction(async t => {
                    const storageDbDoc = await storageDoc.get()
                    const dataDb = storageDbDoc.data()

                    if (dataDb) {
                        //For sake of testing just rewrite it
                        t.update(storageDoc,dataDb )
                    } else {
                        //Create new     
                        const storage = createStorageDoc()
                        t.create(storageDoc,storage )    
                    }
            })
            return markProcessed(eventId)
        } catch (err) {
            console.error(`Execution of ${eventId} Failed: ${err}`)
            throw new Error(`Transaction Failed.`);
        }

解决方法

您的交易坚持要能够创建新文档：

t.create(storageDoc,storage)

由于create()在文档已存在的情况下失败，因此整个事务都将失败，无法恢复。

如果必须能够恢复交易，则应在尝试编写该文档之前检查该文档是否存在，并确定在这种情况下要执行的操作。