如何在scala akka persistence中查看和查询事件日志?

How to view and query event journal in scala akka persistence?

我还没有任何代码可以展示,因为它还没有准备好,但是从我读到的关于 scala akka persistence 的内容来看,我不清楚如何聚合所有事件并将它们暴露在json 通过 http.

在 Akka 2.3 中,PersistentViews 用于 CQRS 的 Q 端(查询或 "read side"),它们允许 actor 遵循由 PersistentActor(即 C边 - 命令或 "write side").

这在即将发布的 Akka 2.4 中发生了很大变化,其中 PersistentView 被 Persistent Query 取代,后者具有 Akka Streams API 而不是作为演员的要求。

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

希望对您有所帮助。