etl - 使用 Akka.net / Actor System 进行 ETL 过程

Question

我是演员模特界的新手，我爱上了这个想法。但是是否存在一些模式来处理一批消息，以安全的方式进行批量存储？

恐怕如果我阅读了预期 500 条的 400 条消息并将它们放在一个列表中，如果系统关闭，我不想从（持久）邮箱中丢失这 400 条消息。在服务总线世界中，您可以请求一批消息，并且只有在处理后，才提交所有消息。谢谢你。

Answer 1

您可能希望将您的参与者系统与一些服务总线/可靠队列（如 RabbitMQ 或 Azure 服务总线）结合起来，仅将参与者系统用于消息处理。

在 Akka.NET 内部，您拥有持久性扩展，可用于将参与者状态存储在您选择的持久性后端中。它还包含一种专用的actor，AtLeastOnceDeliveryActor可用于重新发送消息，直到它们被确认。

Answer 2

你可以在你的 ESB 中扩展拆分和聚合来做到这一点，我很久以前就用 mule ESB 做了类似的事情。