Comment et où traiter les événements AkkaPersistence persistés pour rendre l'information utile et significative pour l'interface utilisateur réactive?

Question

Je connais bien la façon dont le PersistentActor et travail PersistentView en mettant en œuvre Akka persistance.

Considérons l'exemple suivant avec l'idée autant que je comprends.

Une classe de boîtier Scala Contactez.

case class Contact(id: String, version: Int, fName: String, lName: String, age: Int) 

Le PersistentActor a persisté des événements dans le journal sont:

ContactCreated("123af-232ff-232d", 1, "john", "doe", 25) 
FirstNameChanged("123af-232ff-232d", 2, "jan") 
AgeChanged("123af-232ff-232d", 3, 27) 
FirstNameChanged("123af-232ff-232d", 4, "janet") 

Chaque fois que les commandes sont envoyées à partir de l'interface utilisateur réactive, ces nouveaux événements persités si la validation réussit 202 CommandAccepted ou tout CommandValidationError étant riposté .

Mais sans retard important dans l'environnement réactif, l'interface utilisateur doit pouvoir interroger le back-end API REST et montrer la dernière objet Contact après le backend Websocket pousser informe l'interface utilisateur qui UUID « 123af-232ff -232d » est disponible pour la lecture:

Contact("123af-232ff-232d", 4, "janet", "doe", 27) 

Ce résultat devrait se produire après la fusion de tous les événements avec les dernières données disponibles que je comprends. Donc, ma préoccupation actuelle est: Comment et où dans cette application backend je fais le traitement de ces événements dès qu'ils sont générés, fusionner ces données, et stocker les données fusionnées pour la lecture par le côté de la requête.

Merci beaucoup à l'avance si certains pourraient faire la lumière sur la mise en œuvre ou la correction de ma pensée.

Answer 1

L'état actuel de Contact peut ne pas être une vue en tant qu'état réel et, dans la vue, vous n'accepterez pas la cohérence éventuelle, ce qui sera le cas avec une vue.

Je garderais cela comme l'état à l'intérieur de l'acteur persistant et permettre une requête contre l'acteur pour obtenir le Contact actuel et l'utiliser.