scala - 有没有办法通过 PersistenceQuery 使用快照

Question

PersistentView已在 akka 2.4 中弃用。文档建议PersistenceQuery改用。然而PersistenceQuery，似乎仅限于事件日志，没有查询快照存储的能力。

从大量事件中恢复状态需要一些时间，因此使用快照的能力对我来说很重要。

这里的弃用是不是有点超前了？我应该继续工作PersistentView还是我错过了什么？如何使用仅使用快照PersistenceQuery？

谢谢

Answer 1

一种方法：

• 使您用作“PersistentView”的 Actor 扩展为 PersistentActor。
• 将您的 PersistentQuery 偏移量存储在 PersistentActor 的状态中并定期保存快照。
• 最初将查询偏移量设置为最早的偏移量。
• 在 receiveRecover 中，将查询偏移量设置为存储在 PersistentActor 快照中的偏移量。

示例：https ://github.com/benniekrijger/todo-service/blob/master/src/main/scala/com/todos/repository/TodoRepositoryView.scala