변경 시 실행, 시계에 의한 실행 아님

이벤트 기반 설계는 무언가가 변경될 때 실행됩니다. 상태 변경이 이벤트입니다. 이벤트가 트리거입니다.

형태 1: 원자적 전환이 복구 작업을 대체합니다.

상태 전환이 시스템을 깨진 중간 상태로 남길 수 있다면, 결함은 전환 자체에 있으며 복구 작업이 없다는 데 있지 않습니다. 전환이 원자적으로(또는 트랜잭션으로) 완료되도록 수정하세요. 전환이 원자적으로 완료되면 깨진 상태는 존재하지 않습니다. 복구 작업이 복구할 대상이 없습니다.

# 결함: 비원자적 전환이 깨진 상태를 남김
def close_pr_on_repo_private(pr_id):
pr = PR.get(pr_id)
pr.status = 'branch-forced-closed'   # step 1: partial state
pr.save()                             # visible to users NOW
# ... other steps may fail ...
pr.merge_status = 'not_applicable'
pr.save()                             # step 2: now consistent
# Sidekiq job reconciles if step 2 fails

# FIX: 원자적 전환; 중간 상태가 보이지 않음
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()   # 두 필드가 원자적으로 커밋됨; 절대 반만 기록되지 않음

형식 2: 증분 업데이트가 전체 재계산을 대체합니다.

스크래치부터 다시 계산하는 보고서는 기존 데이터 + 새 데이터 = 새 결과로 실행됩니다. 그러나 기존 결과 + 델타 = 동일한 새 결과이며, 증분 방식으로 계산됩니다. 이벤트: 새 데이터가 도착했습니다. 트리거: 새 데이터에 대해서만 집계를 업데이트합니다.

# 결함: 스케줄에 따른 전체 재계산
def nightly_totals_job():
for user in all_users():
total = sum(o.amount for o in user.orders)  # 모든 시간 스캔
user.total_purchases = total
user.save()

# FIX: 이벤트 기반 증분 업데이트
def on_order_placed(order):
order.user.total_purchases += order.amount   # 델타만
order.user.save()

증분 업데이트는 새벽 2시가 아니라 주문이 도착할 때 실행됩니다. 영향을 받는 사용자만 업데이트하며, 전체 주문이 아닌 새 주문만 읽습니다. 야간 작업은 사라집니다.

Form 1이 깨진 전환을 드러내는 이유

Form 1 Metered Heart는 상태 전환이 완료되지 않았음을 보여줍니다. 복구 작업은 엔지니어가 깨진 상태를 발견하고 전환을 수정하는 대신 조정 메커니즘을 추가했기 때문에 존재합니다. 복구 작업은 깨진 아키텍처 결정에 대한 임시방편입니다.

MOAD-0009의 증폭 효과

MOAD-0009는 다른 MOAD를 증폭시킵니다. 깨진 상태를 찾기 위해 모든 레코드를 스캔하는 상태 복구 작업은 MOAD-0001(O(N) 또는 O(N²) 스캔)을 유발합니다. 모든 것을 처음부터 다시 계산하는 보고서 작업은 MOAD-0005(작업 시작 시 따뜻한 상류 시스템에 대한 캐시 스탬피드)를 유발합니다. MOAD-0009는 그 자체로도 해롭지만, 다른 MOAD를 정기적으로 전달합니다.

진단 및 재설계

한 팀이 매일 새벽 2시에 cron 작업을 실행합니다. 이 작업은 모든 사용자의 모든 주문을 스캔하여 각 사용자의 총 구매 금액을 처음부터 다시 계산합니다. 작업은 4시간이 걸리며, 오전 6시가 되면 대시보드에 최신 합계가 표시됩니다. 새벽 2시부터 6시 사이에는 대시보드에 전날의 합계가 표시됩니다.