Срабатывание по изменению, а не по часам

Событийно-ориентированный дизайн срабатывает при изменении состояния. Изменение состояния и есть событие. Событие — это триггер.

Форма 1: атомарный переход заменяет задачу восстановления.

Если переход состояния может оставить систему в сломанном промежуточном состоянии, дефект находится в самом переходе, а не в отсутствии задачи восстановления. Исправьте переход, чтобы он завершался атомарно (или транзакционно). Когда переход завершается атомарно, сломанное состояние никогда не возникает. Задаче восстановления нечего восстанавливать.

# ДЕФЕКТ: неатомарный переход оставляет сломанное состояние
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-задача восстанавливает согласованность, если шаг 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 (cache stampede при старте джоба и обращении к тёплому upstream). MOAD-0009 вредит не только сам по себе — он регулярно доставляет и другие MOAD.

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

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