Reaguj na zmianę, nie na zegar

Projekt sterowany zdarzeniami uruchamia się, gdy coś się zmienia. Zmiana stanu jest zdarzeniem. Zdarzenie jest wyzwalaczem.

Forma 1: atomowe przejście zastępuje zadanie naprawcze.

Jeśli przejście stanu może pozostawić system w uszkodzonym stanie pośrednim, wada tkwi w samym przejściu, a nie w braku zadania naprawczego. Napraw przejście tak, aby było atomowe (lub transakcyjne). Gdy przejście zakończy się atomowo, uszkodzony stan nigdy nie występuje. Zadanie naprawcze nie ma nic do naprawienia.

# DEFEKT: nieatomowe przejście pozostawia uszkodzony stan
def close_pr_on_repo_private(pr_id):
pr = PR.get(pr_id)
pr.status = 'branch-forced-closed'   # krok 1: stan częściowy
pr.save()                             # widoczne dla użytkowników TERAZ
# ... inne kroki mogą się nie powieść ...
pr.merge_status = 'not_applicable'
pr.save()                             # krok 2: teraz spójny
# Zadanie Sidekiq naprawia stan, jeśli krok 2 nie powiedzie się

# POPRAWKA: atomowe przejście; brak widocznego stanu pośredniego
def close_pr_on_repo_private(pr_id):
with db.transaction():
pr = PR.get(pr_id)
pr.status = 'branch-forced-closed'
pr.merge_status = 'not_applicable'
pr.save()   # oba pola zapisywane atomowo; nigdy częściowo zapisane

Forma 2: aktualizacja przyrostowa zastępuje pełne przeliczanie.

Raport, który przelicza wszystko od zera, uruchamia się, ponieważ stare dane + nowe dane = nowy wynik. Ale stary wynik + delta = ten sam nowy wynik, obliczony przyrostowo. Zdarzenie: nadeszły nowe dane. Wyzwalacz: zaktualizuj agregat tylko dla nowych danych.

# DEFECT: pełne przeliczanie według harmonogramu
def nightly_totals_job():
for user in all_users():
total = sum(o.amount for o in user.orders)  # skanuj wszystkie rekordy
user.total_purchases = total
user.save()

# POPRAWKA: przyrostowa aktualizacja zdarzeniowa
def on_order_placed(order):
order.user.total_purchases += order.amount   # tylko delta
order.user.save()

Aktualizacja przyrostowa uruchamia się w momencie złożenia zamówienia, a nie o 2 w nocy. Aktualizuje tylko dotkniętego użytkownika. Odczytuje tylko nowe zamówienie, a nie wszystkie zamówienia ze wszystkich czasów. Zadanie nocne znika.

Dlaczego Formularz 1 ujawnia uszkodzony przejście

Formularz 1 Metered Heart ujawnia, że przejście stanu zostało pozostawione niekompletnym. Zadanie naprawcze istnieje, ponieważ inżynier zauważył uszkodzony stan i dodał mechanizm uzgadniania zamiast naprawić przejście. Zadanie naprawcze: łatka na zepsutą decyzję architektoniczną.

MOAD-0009 jako wzmacniacz

MOAD-0009 wzmacnia inne MOAD-y. Zadanie naprawy stanu, które skanuje wszystkie rekordy w poszukiwaniu uszkodzonego stanu: MOAD-0001 (skan O(N) lub O(N²) przy każdym uruchomieniu zadania). Zadanie raportowe, które przelicza wszystko od zera: MOAD-0005 (burza pamięci podręcznej, gdy zadanie się uruchamia i trafia na ciepły upstream). MOAD-0009 nie tylko szkodzi samodzielnie; dostarcza inne MOAD-y według harmonogramu.

Diagnoza i przeprojektowanie

Zespół uruchamia nocne zadanie cron o 2 w nocy. Zadanie skanuje wszystkie zamówienia wszystkich użytkowników i przelicza od zera całkowitą kwotę zakupów każdego użytkownika. Zadanie trwa 4 godziny. O 6 rano pulpit pokazuje świeże sumy. Między 2 a 6 rano pulpit pokazuje wczorajsze sumy.