0

语境：

  1. 在带有 EventHubTrigger 的 Azure 函数中，我保存了从已处理事件映射到数据库的数据（通过实体框架）。此动作同步执行
  2. 使用事件中心生产者触发有关成功插入数据的新事件。此操作是异步的
  3. 在其他地方处理触发的事件

我想在保存数据期间可能会发生某些事情失败，所以我想知道如何防止不一致并确保如果不应该发送事件则不会发送。据我所知，Azure 事件中心还没有实现发件箱模式，所以我想我需要以某种方式模仿它。

我还在考虑替代且有点臭的解决方案，以使此发布事件方法在步骤 2 中同步（即使事件驱动的性质是异步的）并在步骤 1 和步骤 2 之间添加附加检查 - 使确保所有内容都保存在数据库中。只有满足该条件，才会触发事件（步骤 3）。

有什么建议吗？

4

1 回答 1

0

SDK 中没有任何内容可以代表您管理分布式事务。最简单的方法可能是在数据库中有一个列，允许您标记事件的发布时间，然后让您的函数流程：

  1. 在未设置“事件发布”标志的情况下写入数据库；失败中止。
  2. 发布活动；失败中止。 （数据保持写入状态）
  3. 写入数据库以设置“事件发布”标志。

您需要在计时器上运行第二个函数，该函数可以扫描您的数据库以查找早于 XX 分钟前仍需要事件的行，然后执行初始流程中的步骤 2 和 3。在失败的情况下，您将在正在写入的数据和发布的事件之间存在一些潜在的延迟，或者可能会看到重复的事件。 （事件中心至少有一次保证，因此无论如何您都需要能够处理重复项。）

于 2021-06-11T19:52:08.673 回答