scala – 有没有办法在PersistenceQuery中使用快照

发布时间：2020-12-16 18:47:32 所属栏目：安全来源：网络整理

导读：PersistentView 已在akka 2.4中弃用.文档建议切换到 PersistenceQuery .但是,PersistenceQuery似乎仅限于事件日志,但没有查询快照存储的功能. 从大量事件中恢复状态需要一些时间,因此使用快照的能力对我来说很重要. 折旧是否超过了它的时间？我应该继续使用P

PersistentView已在akka 2.4中弃用.文档建议切换到 PersistenceQuery.但是,PersistenceQuery似乎仅限于事件日志,但没有查询快照存储的功能.

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

折旧是否超过了它的时间？我应该继续使用PersistentView还是我错过了什么？如何仅使用PersistenceQuery处理快照？

谢谢

解决方法

一种方法：

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

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

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!