Feuer bei Änderung, nicht bei Uhr

Ereignisgetriebene Konzepte entfachen, wenn etwas geändert hat. Der Zustandswechsel ist das Ereignis. Das Ereignis ist der Auslöser.

Form 1: Der atomare Übergang ersetzt den Reparaturjob.

Wenn ein Zustandsübergang den Systemzustand in einem defekten Zwischenzustand lassen kann, befindet sich der Fehler im Übergang und nicht in seiner Abwesenheit eines Reparaturjobs. Beheben Sie den Übergang, um vollständig atomar (oder transaktional) zu sein. Wenn der Übergang vollständig atomar ist, existiert defekter Zustand nie. Der Reparaturjob hat nichts zu reparieren.

# Fehlertyp: nicht-atomarer Übergang lässt defekten Zustand zurück
def close_pr_on_repo_private(pr_id):
    pr = PR.get(pr_id)
    pr.status = 'branch-forced-closed'   # Schritt 1: partieller Zustand
    pr.save()                             # sichtbar für Benutzer NUN
    # ... möglicherweise fehlgeschlagene Schritte ...
    pr.merge_status = 'not_applicable'
    pr.save()                             # Schritt 2: jetzt konsistent
    # Sidekiq-Job stellt im Falle eines Schritt-2-Fehlers die Vereinbarung her

# KORREKTUR: atomarer Übergang; kein intermediäres Zustand sichtbar
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()   # beide Felder werden atomar geschrieben; nie halb geschrieben

Form 2: Die inkrementelle Aktualisierung ersetzt die vollständige Neuberechnung.

Ein Bericht, der von vorne losrechnet, wird ausgelöst, weil alte Daten + neue Daten = neue Ergebnisse. Aber die alten Ergebnisse + Deltas = das gleiche neue Ergebnis, berechnet inkrementell. Der Ereignis: neue Daten sind eingegangen. Der Auslöser: Aktualisieren des Aggregats nur für die neuen Daten.

# FEHLER: vollständige Neuberechnung nach Zeitplan
def nightly_totals_job():
    for user in all_users():
        total = sum(o.amount for o in user.orders)  # Durchsuchen aller Zeit
        user.total_purchases = total
        user.save()

# KORREKTUR: ereignsgetriebene inkrementelle Aktualisierung
def on_order_placed(order):
    order.user.total_purchases += order.amount   # nur Delta
    order.user.save()

Die inkrementelle Aktualisierung wird nicht um 2 Uhr früh ausgelöst, sondern wenn eine Bestellung eingegangen ist. Sie aktualisiert nur den betroffenen Benutzer. Sie liest nur die neue Bestellung und nicht alle Bestellungen von alters her. Die Nachtjob verschwindet.

Warum Form 1 einen gebrochenen Übergang zeigt

Ein Form-1-Metered-Heart zeigt an, dass ein Zustandsübergang unvollständig blieb. Die Reparatur-Job existiert, weil ein Ingenieur einen gebrochenen Zustand bemerkt hat und anstelle des Zustandsübergangs eine Wiederherstellungsmechanismus hinzugefügt hat. Der Reparatur-Job: ein Patch über eine gebrochene architektonische Entscheidung.

MOAD-0009 als Verstärker

MOAD-0009 verstärkt andere MOADs. Ein Zustands-Reparatur-Job, der alle Datensätze durchsucht, um gebrochenen Zustand zu finden: MOAD-0001 (O(N) oder O(N²) Scan pro Jobausführung). Eine Berichterstellung, die alles kalt neu berechnet: MOAD-0005 (Cache-Stampede, wenn die Jobausführung losgeht und eine warme Quelle trifft). MOAD-0009 schädigt nicht nur selbst; sie liefert andere MOADs termingerecht.

Diagnose & Umgestaltung

Eine Mannschaft führt eine tägliche cron-Job-Ausführung um 2 Uhr morgens durch. Das Job scannet alle Bestellungen für alle Benutzer und berechnet jeden Benutzers Gesamtkaufbetrag von vorne. Das Job dauert 4 Stunden. Bis 6 Uhr morgens zeigt das Dashboard frische Gesamtbeträge. Zwischen 2 Uhr morgens und 6 Uhr morgens zeigt das Dashboard die Gesamtbeträge von gestern.