您如何避免使用 firebase 云功能可能出现的竞争情况？

Question

我有一个由 Firestore 数据库写入触发的云功能。它执行可能需要很长时间的异步操作（从某些 3rd 方 API 获取数据），也可能不会。完成后，它将结果写入“搜索结果”字段。

可能存在竞争条件，即来自较新触发器的结果被稍后完成的较旧操作覆盖。我应该如何在 Firebase 云函数和 Firestore 的上下文中解决这个问题？

Answer 1

这里一般有两种方法：

1. 确保您的操作是幂等的
2. 确保您的操作检测到冲突更新并重试

确保您的操作是幂等的

这通常是最可扩展且架构最简单的。当您对相同的输入执行相同的幂等操作时，它具有相同的结果。这意味着如果多次执行该操作并不重要，因为结果将是相同的。

Firestore documentation on arrays and sets 就是一个很好的例子。想象一下，您正在用类别标记博客文章。一个简单的模型是：

{
    title: "My great post",
    categories: [
        "technology",
        "opinion",
        "cats"
    ]
}

但现在想象一下，两个用户几乎同时将同一个帖子标记为关于猫的帖子。你最终可能会得到 ​​p>

{
    title: "My great post",
    categories: [
        "technology",
        "opinion",
        "cats",
        "cats"
    ]
}

这显然不是你想要的。但是由于数据结构允许，这可能会发生。这里理想的解决方案是使用一种使这成为不可能的数据结构：添加cat 是幂等操作的数据结构。用数学术语来说，这将是一个集合，在 Firestore 中，您可以将其建模为：

{
    title: "My great post",
    categories: {
        "technology": true,
        "opinion": true,
        "cats": true
    }
}

现在在这种结构中，无论您将cats 设置为true 的频率如何，结果都将始终相同。

确保您的操作检测到冲突更新并重试

有时不可能（或不可行）使您的操作具有幂等性。在这种情况下，您还可以考虑使用比较和设置策略。

例如，假设第 3 方 API 以某种方式更改数据，并且您只想在数据库中的原始数据未修改的情况下将结果写回数据库。在这种情况下，您需要在函数中执行以下步骤：

1. 读取原始数据
2. 使用数据调用第 3 方 API
3. 等待结果
4. 开始交易
5. 重新加载原始数据
6. 如果数据被修改，返回#2
7. 如果数据未修改，则从第 3 方 API 写入结果

这种类型的比较和设置操作实际上是 Firebase 的实时数据库实现事务的方式，“第 3 方 API”是您的应用程序事务处理程序。

正如您可能看到的，第二种方法比具有幂等操作的方法更复杂。所以如果可能的话，我总是推荐这种方法。

Answer 2

虽然不是直接回答 OP 关于等待第 3 方响应的问题，但对于那些从 Google 搜索到通用 Firestore 竞争条件解决方案的人来说，Firestore 支持事务和批量写入：

Cloud Firestore 支持读取和写入数据的原子操作。在一组原子操作中，要么所有操作都成功，要么一个都不应用。 Cloud Firestore 中有两种原子操作：

• 事务：事务是对一个或多个文档的一组读写操作。

• 批处理写入：批处理写入是对一个或多个文档的一组写入操作。

更多详情请见：https://firebase.google.com/docs/firestore/manage-data/transactions

Answer 3

Firebase 云函数提供了 transact() 函数，可以用来将一些数据原子地保存到数据库中。