Jak radzić sobie z sytuacjami, gdy model odczytu nie był zsynchronizowany z dziennikami zdarzeń?

Question

Gdy migawki agregatów nie są zsynchronizowane z dziennikiem zdarzeń, mogę po prostu odtworzyć moje zdarzenia z wczesnych migawek (które powinny być zsynchronizowane). To samo mogę zrobić, dodając/usuwając nowe pola lub modyfikując logikę istniejących procedur obsługi.

Jeśli potrzebuję dodać nowy model odczytu (np. Nowy widok raportu), mogę zrobić to samo jeszcze raz - powtórzę swoje zdarzenia.

Ale jak mam sobie radzić z sytuacją, gdy model odczytu nie jest zsynchronizowany z dziennikiem zdarzeń? Przechowywanie zdarzeń i publikowanie odbywa się w jednej transakcji, ale aktualizacja modelu odczytu wystąpiła w innej transakcji, która może się nie powieść. Powtarzanie wydarzeń od samego początku może pomóc, ale może trwać wieczność. Czy potrzebuję koncepcji migawek dla całego przeczytanego modelu?

Jak rozwiązać ten problem? Dziękuję.

Answer 1

Jaki byłby powód niepowodzenia w obsłudze zdarzenia? Jak długo trwa "wieczność"?

Odczytywanie aktualizacji modelu rzadko kończy się niepowodzeniem (w przeciwieństwie do procedur obsługi komend), ponieważ logika wewnątrz jest niezwykle prosta. Awarie mogą być spowodowane przejściowymi problemami (przerwa w sieci IO/sieci) i będą obsługiwane automatycznie przez magistralę komunikatów.

Jeśli jednak model odczytu ulegnie uszkodzeniu z jakiegoś powodu, najprościej będzie go zresetować i przeskanować zdarzenia. Nawet miliony zdarzeń zajęłyby stosunkowo mało czasu. Ponadto możesz zawsze zastosować metodę Map-Reduce.

Polecam przeciwko wprowadzaniu migawek do odczytu modeli. Myślę, że to po prostu komplikuje architekturę bez żadnych znaczących zysków.