Event Sourcing - Event-Wiedergabe

Question

Ich habe über das Ereignis Sourcing-Muster gelesen, die sehr nützlich sein kann, wenn Sie Ihr System neu aufbauen möchten. Was ist jedoch, wenn ich die Ereignisrekonstruktion ausführen muss, während neue eingehende Anforderungen bearbeitet werden? Gibt es ein bestimmtes Muster oder eine Best Practice für dieses Szenario? Also, anstatt eine Systemausfallzeit zu planen, wie stelle ich sicher, dass die neuen eingehenden Anfragen mein System während der Wiedergabe nicht vermasseln, da die Synchronisation und Sequenz der Ereignisse für mein System wirklich wichtig ist. Es beinhaltet das Aktualisieren der DB-Sätze, die von der Ereignisfolge abhängig sind. Irgendwelche Gedanken?

Answer 1

Mit den Einschränkungen, die Sie beschrieben haben, klingt es wie Live Wiederaufbau von Null kann nicht Teil Ihrer Pläne sein. Sie könnten stattdessen ein A/B-Setup haben, die Ereignisse auf einem neuen System durchspielen, das zu diesem Zeitpunkt offline ist, und dann zu dem neuen System wechseln, wenn es einmal aufgeholt hat. Der Schlüssel ist, dass sowohl das alte als auch das neue System gleichzeitig den Ereignisstrom einstellen können.

Wenn Sie verschiedene Systeme abonniert haben, die Teilmengen der Ereignisse abonniert haben, müssen Sie möglicherweise nur Ereignisse für eines dieser Subsysteme wiedergeben, und Ihre Synchronisations-/Sequenzanforderungen können weiterhin erfüllt werden, ohne dass dieses Subsystem in Betrieb ist.

Sie können verhindern, dass veraltete Informationen verarbeitet werden, indem Sie Ereignissequenznummern in die Daten einschließen und die sequenzabhängige Service-Defer-Verarbeitung haben, wenn dieses Ereignis noch nicht erkannt wurde.

Answer 2

Um Ihre Ereignisse in das Lesemodell zu projizieren, müssen Sie eine Art Catch-Up-Abonnement verwenden, wie es EventStore bietet. In diesem Fall werden Ihre neuen Ereignisse im Geschäft gespeichert, aber nicht sofort projiziert.

Sie müssen jedoch feststellen, dass Ihre Benutzer stark veraltete Daten sehen und Aktionen basierend auf dem inkonsistenten Lesemodell ausführen. Ich würde das lieber vermeiden und das System neu aufbauen lassen.

Ich stimme der ersten Antwort, dass Sie ein neues Lesemodell parallel zur Aktualisierung der alten und das Umschalten an einem bestimmten Punkt erstellen möchten, möglicherweise nicht für alle Benutzer zuerst.

Answer 3

Ich habe CQRS + ES in ähnlichen Fall verwendet. Ich erstellte eine Projektion mit vorbereiteten Daten, die ich nur aktualisieren, aber nicht wiederherstellen konnte. Und auf jeder Abfrage baute ich Ergebnis-Informationen von diesem schnell.

Wenn Sie einige lange Operationen ausführen müssen (wie ein Update in db), verwenden Sie sagas. Generiere event -> saga -> aktualisiere die Projektion, nachdem die saga beendet ist und erstelle event2.

Natürlich wird es etwas Verzögerung zwischen Ereignis Einkommen und Projektion Update geben.

Es ist sehr interessant, mehr über Ihr System zu erfahren, und wenn eine solche Variante für Sie gut genug ist.