Vorbește-mi despre pattern-ul Saga. Cum l-ați implementat? Cum ați notificat serviciile despre rollback?

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

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

Реализация:

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

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

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

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

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

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