Паттерн Saga используется для управления распределёнными транзакциями, когда несколько сервисов должны выполнить операции, и при ошибке нужно откатить уже выполненные шаги.

Saga разбивается на последовательность локальных транзакций с компенсирующими действиями (откатами). Если один из шагов неудачен, запускаются компенсирующие транзакции для предыдущих шагов.

Реализация:

Оркестрация — центральный координатор управляет последовательностью шагов и откатом.
Хореография — каждый сервис публикует события о выполнении и слушает события других для запуска своих шагов.

Уведомление об откате:

Через события в шине сообщений (например, Kafka, RabbitMQ) сервисы получают команды на выполнение компенсирующих действий.
В оркестрации координатор отправляет запросы на откат конкретным сервисам.

Пример (упрощённо):

Сервис A выполняет действие, публикует событие "A выполнено".
Сервис B слушает событие, выполняет действие, публикует "B выполнено".
Если сервис B не может выполнить действие, координатор запускает компенсирующую транзакцию для сервиса A.

В Python можно реализовать Saga с помощью очередей сообщений и состояния шагов, например, используя Celery и брокер сообщений.

Расскажи про паттерн Saga. Как реализовывали у себя? Как уведомляли сервисы об откате?