如何在scala akka持久性中查看和查询事件日志？

Question

我还没有任何代码可以显示,因为它还没有准备好,但是从我读到的有关scala akka持久性的内容来看,我不清楚如何聚合所有事件并通过http在json中公开它们.

Answer 1

在Akka 2.3中,PersistentViews适用于CQRS的Q侧(查询或"读取侧"),它们允许actor遵循PersistentActor写入的域事件(即C侧 - 命令或"写入侧").

这在Akka 2.4中发生了相当大的变化,很快就会发布,其中PersistentView被Persistent Query取代,后者具有Akka Streams API,而不是成为actor的要求.

为查询端提供专门的数据存储通常是个好主意,这允许适合查询类型的持久性解决方案以及您想要的任何聚合.通过HTTP将其作为JSON提供将超出Akka Persistence的范围,但可以使用Play Framework或Akka HTTP轻松完成(后者可能不足以进行生产,具体取决于您的需求).

希望这可以帮助.