Fire on Change, Not on Clock

Event-driven design triggar när något ändras. Tillståndsändringen är händelsen. Händelsen är triggaren.

Form 1: den atomära övergången ersätter reparationsjobbet.

Om en tillståndsövergång kan lämna systemet i ett trasigt mellanläge, ligger felet i övergången, inte i avsaknaden av ett reparationsjobb. Fixa övergången så att den slutförs atomiskt (eller transaktionellt). När övergången slutförs atomiskt existerar aldrig trasigt tillstånd. Reparationsjobbet har inget att reparera.

# DEFECT: non-atomic transition leaves broken state
def close_pr_on_repo_private(pr_id):
pr = PR.get(pr_id)
pr.status = 'branch-forced-closed'   # steg 1: partiellt tillstånd
pr.save()                             # synlig för användare NU
# ... andra steg kan misslyckas ...
pr.merge_status = 'not_applicable'
pr.save()                             # steg 2: nu konsekvent
# Sidekiq-job stämmer av om steg 2 misslyckas

# FIX: atomisk övergång; inget mellanliggande tillstånd synligt
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()   # båda fälten sparas atomiskt; aldrig halvt skrivna

Form 2: den inkrementella uppdateringen ersätter den fullständiga omberäkningen.

En rapport som beräknas om från början triggas eftersom gammal data + ny data = nytt resultat. Men det gamla resultatet + delta = samma nya resultat, beräknat inkrementellt. Händelsen: ny data anlände. Triggaren: uppdatera aggregeringen endast för den nya datan.

# FEL: fullständig omberäkning på schema
def nightly_totals_job():
for user in all_users():
total = sum(o.amount for o in user.orders)  # skanna alla tidpunkter
user.total_purchases = total
user.save()

# FIX: händelsedriven inkrementell uppdatering
def on_order_placed(order):
order.user.total_purchases += order.amount   # endast delta
order.user.save()

Den inkrementella uppdateringen triggas när en order anländer, inte klockan 02:00. Den uppdaterar endast den berörda användaren. Den läser endast den nya ordern, inte alla ordrar från all tid. Det nattliga jobbet försvinner.

Varför Form 1 avslöjar en trasig övergång

En Form 1 Metered Heart avslöjar att en tillståndsövergång lämnades ofullständig. Reparationsjobbet finns eftersom en ingenjör upptäckte trasigt tillstånd och lade till en avstämningsmekanism istället för att åtgärda övergången. Reparationsjobbet: en lapp över ett trasigt arkitektoniskt beslut.

MOAD-0009 som förstärkare

MOAD-0009 förstärker andra MOAD:er. Ett tillståndsreparationsjobb som skannar alla poster för att hitta trasigt tillstånd: MOAD-0001 (O(N) eller O(N²)-skanning per körning). Ett rapportjobb som beräknar om allt från grunden: MOAD-0005 (cache stampede när jobbet startar och träffar en varm uppströmskälla). MOAD-0009 skadar inte bara i sig själv; det levererar andra MOAD:er enligt schema.

Diagnostisera & redesigna

Ett team kör ett nattligt cron-jobb klockan 02:00. Jobbet skannar alla ordrar för alla användare och beräknar om varje användares totala köpbelopp från grunden. Jobbet tar 4 timmar. Klockan 06:00 visar instrumentpanelen färska totaler. Mellan 02:00 och 06:00 visar instrumentpanelen gårdagens totaler.