将有关成功插入数据库的事件发送到事件中心时如何确保可靠发布？
How to secure reliable publication when send event about successful db insertion to Event Hub?
上下文：
- 在带有 EventHubTrigger 的 Azure 函数中，我保存从已处理事件映射到数据库的数据（通过 Entity framework）。此操作同步执行
- 使用事件中心生成器触发有关成功插入数据的新事件。此操作是 async
- 在其他地方处理触发的事件
我想在保存数据的过程中可能会发生某些事情失败，所以我想知道如何防止不一致并确保不发送不应该发送的事件。
据我所知，Azure 事件中心尚未实现 outbox pattern，所以我想我需要以某种方式模仿它。
我也在考虑替代和有点臭的解决方案，使这个发布事件方法在步骤 2 中同步（即使事件驱动的本质是异步的）并在步骤 1 和步骤 1 之间添加附加检查第 2 步 - 确保所有内容都保存在数据库中。只有满足该条件，才会触发事件（第 3 步）。
有什么建议吗？
SDK 中没有任何内容可以代表您管理分布式事务。最简单的方法可能是在你的数据库中有一个列，允许你标记事件发布的时间，然后让你的函数流：
- 在未设置“事件已发布”标志的情况下写入数据库；失败中止。
- 发布活动；失败中止。 （数据保持写入状态）
- 写入数据库以设置“事件已发布”标志。
您需要计时器上的第二个函数 运行，它可以扫描您的数据库以查找早于 XX 分钟前但仍需要事件的行，然后执行初始流程中的第 2 步和第 3 步。在失败的情况下，您将在写入数据和发布事件之间有一些潜在的延迟，或者可能会看到重复的事件。 （事件中心有至少一次保证，因此无论如何您都需要能够处理重复项。）
上下文：
- 在带有 EventHubTrigger 的 Azure 函数中，我保存从已处理事件映射到数据库的数据（通过 Entity framework）。此操作同步执行
- 使用事件中心生成器触发有关成功插入数据的新事件。此操作是 async
- 在其他地方处理触发的事件
我想在保存数据的过程中可能会发生某些事情失败，所以我想知道如何防止不一致并确保不发送不应该发送的事件。 据我所知，Azure 事件中心尚未实现 outbox pattern，所以我想我需要以某种方式模仿它。
我也在考虑替代和有点臭的解决方案，使这个发布事件方法在步骤 2 中同步（即使事件驱动的本质是异步的）并在步骤 1 和步骤 1 之间添加附加检查第 2 步 - 确保所有内容都保存在数据库中。只有满足该条件，才会触发事件（第 3 步）。
有什么建议吗？
SDK 中没有任何内容可以代表您管理分布式事务。最简单的方法可能是在你的数据库中有一个列，允许你标记事件发布的时间，然后让你的函数流：
- 在未设置“事件已发布”标志的情况下写入数据库；失败中止。
- 发布活动；失败中止。 （数据保持写入状态）
- 写入数据库以设置“事件已发布”标志。
您需要计时器上的第二个函数 运行，它可以扫描您的数据库以查找早于 XX 分钟前但仍需要事件的行，然后执行初始流程中的第 2 步和第 3 步。在失败的情况下，您将在写入数据和发布事件之间有一些潜在的延迟，或者可能会看到重复的事件。 （事件中心有至少一次保证，因此无论如何您都需要能够处理重复项。）