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