将有关成功插入数据库的事件发送到事件中心时如何确保可靠发布？

问题描述

上下文：

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

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

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

有什么建议吗？

解决方法

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

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

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