Fire on Change, Not on Clock

Event-driven डिज़ाइन तब सक्रिय होता है जब कोई बदलाव होता है। स्टेट चेंज ही इवेंट है। इवेंट ही ट्रिगर है।

Form 1: the atomic transition replaces the repair job.

यदि कोई स्टेट ट्रांजिशन सिस्टम को एक टूटी हुई इंटरमीडिएट स्टेट में छोड़ सकता है, तो दोष ट्रांजिशन में है, न कि रिपेयर जॉब की अनुपस्थिति में। ट्रांजिशन को एटॉमिक (या ट्रांजेक्शनल) रूप से पूरा करने के लिए ठीक करें। जब ट्रांजिशन एटॉमिक रूप से पूरा होता है, तो टूटी हुई स्टेट कभी अस्तित्व में नहीं आती। रिपेयर जॉब के पास ठीक करने के लिए कुछ भी नहीं बचता।

# 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'   # 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: atomic transition; no intermediate state visible
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()   # दोनों फ़ील्ड्स एटॉमिकली कमिट होती हैं; कभी भी आधा लिखा नहीं जाता

Form 2: incremental update पूरे recompute को बदल देता है।

एक रिपोर्ट जो स्क्रैच से recompute करती है, इसलिए फायर होती है क्योंकि पुराना डेटा + नया डेटा = नया रिजल्ट। लेकिन पुराना रिजल्ट + डेल्टा = वही नया रिजल्ट, जो incrementally कैलकुलेट किया गया। इवेंट: नया डेटा आया। ट्रिगर: सिर्फ नए डेटा के लिए aggregate अपडेट करें।

# DEFECT: schedule पर full recompute
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 अन्य MOADs को बढ़ाता है। एक स्टेट-रिपेयर जॉब जो टूटी हुई स्टेट ढूंढने के लिए सभी रिकॉर्ड्स को स्कैन करता है: MOAD-0001 (प्रति जॉब रन O(N) या O(N²) स्कैन)। एक रिपोर्ट जॉब जो सब कुछ कोल्ड से रीकंप्यूट करती है: MOAD-0005 (जब जॉब शुरू होती है और एक वार्म अपस्ट्रीम को हिट करती है तो कैश स्टैम्पीड)। MOAD-0009 केवल खुद से नुकसान नहीं पहुँचाता; यह अन्य MOADs को एक शेड्यूल पर डिलीवर करता है।

निदान करें और पुनः डिज़ाइन करें

एक टीम रात 2 बजे एक नाइटली क्रॉन जॉब चलाती है। जॉब सभी यूज़र्स के सभी ऑर्डर्स को स्कैन करती है और प्रत्येक यूज़र की कुल खरीद राशि को शुरू से रीकंप्यूट करती है। जॉब को 4 घंटे लगते हैं। सुबह 6 बजे तक, डैशबोर्ड ताज़ा टोटल दिखाता है। सुबह 2 बजे से 6 बजे के बीच, डैशबोर्ड कल के टोटल दिखाता है।