Fire on Change, Not on Clock

Event-driven дизайн спрацьовує, коли щось змінюється. Зміна стану — це подія. Подія є тригером.

Форма 1: атомарний перехід замінює ремонтне завдання.

Якщо перехід стану може залишити систему в пошкодженому проміжному стані, дефект міститься в самому переході, а не в відсутності ремонтного завдання. Виправте перехід, щоб він завершувався атомарно (або транзакційно). Коли перехід завершується атомарно, пошкоджений стан ніколи не виникає. Ремонтному завданню нічого виправляти.

# 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'   # крок 1: частковий стан
pr.save()                             # видно користувачам ЗАРАЗ
# ... інші кроки можуть завершитися невдало ...
pr.merge_status = 'not_applicable'
pr.save()                             # крок 2: тепер узгоджено
# Sidekiq job узгоджує, якщо крок 2 не вдається

# ВИПРАВЛЕННЯ: атомарний перехід; немає проміжного стану
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()

# ВИПРАВЛЕННЯ: інкрементне оновлення на основі подій
def on_order_placed(order):
order.user.total_purchases += order.amount   # лише дельта
order.user.save()

Інкрементне оновлення спрацьовує, коли надходить замовлення, а не о 2 годині ночі. Воно оновлює лише відповідного користувача. Воно зчитує лише нове замовлення, а не всі замовлення за весь час. Нічний джоб зникає.

Чому Форма 1 виявляє зламаний перехід

Лічильник серця Form 1 показує, що перехід стану залишився незавершеним. Джоб відновлення існує, бо інженер помітив зламаний стан і додав механізм узгодження замість виправлення переходу. Джоб відновлення: лата над зламаним архітектурним рішенням.

MOAD-0009 як підсилювач

MOAD-0009 підсилює інші MOAD. Джоб відновлення стану, який сканує всі записи, щоб знайти зламаний стан: MOAD-0001 (сканування O(N) або O(N²) за кожне виконання джобу). Джоб звіту, який переобчислює все з нуля: MOAD-0005 (штампед кешу, коли джоб запускається і звертається до теплого upstream). MOAD-0009 не просто шкодить сам по собі; він доставляє інші MOAD за розкладом.

Діагностика та редизайн

Команда запускає нічний cron-джоб о 2 годині ночі. Джоб сканує всі замовлення всіх користувачів і переобчислює загальну суму покупок кожного користувача з нуля. Джоб триває 4 години. До 6 години ранку дашборд показує свіжі суми. Між 2 і 6 годинами ранку дашборд показує суми за вчора.