Что такое transactional outbox и зачем он используется?

Question

Transactional outbox — это паттерн, при котором бизнес-данные и событие записываются в одну транзакцию базы данных. Событие сохраняется в специальную outbox-таблицу. Отдельный процесс позже читает эту таблицу и публикует события в брокер. Это устраняет проблему “данные сохранились, а событие не ушло” или наоборот. Паттерн часто используют в микросервисах с асинхронным взаимодействием.

YeaHub · Accepted Answer

ОпределениеTransactional outbox — архитектурный паттерн, гарантирующий, что изменения в базе данных и соответствующие события будут зафиксированы атомарно.Проблема, которую он решаетБез outbox возможна ситуация:Транзакция в БД закоммитилась.Отправка события в брокер упала.Другие сервисы никогда не узнают об изменении.Или наоборот — событие отправлено, а данные не сохранены.Как работает transactional outboxВ рамках одной транзакции:обновляются бизнес-таблицы;вставляется запись в outbox-таблицу.После коммита:отдельный worker читает outbox;публикует события в брокер;помечает записи как обработанные.Упрощённый пример (идея)with db.transaction():
    save_order(order)
    save_outbox_event(
        type="OrderCreated",
        payload={"order_id": order.id}
    )
Почему часто выбирают PostgresНадёжные транзакции.Простая реализация outbox-таблицы.Возможность блокировок, batch-чтения, индексов.Хорошо сочетается с CDC и logical replication.Ограничения и нюансыНужно чистить outbox-таблицу.Публикация событий происходит не мгновенно.Worker должен быть устойчив к повторам.ВыводTransactional outbox — базовый паттерн для надёжной интеграции БД и событий, когда нельзя позволить себе рассинхронизацию данных и сообщений.