Тестирование оркестрованных саг
Узнайте, как тестировать саги на основе оркестрации: выполнять модульные тесты путей компенсации, интеграционные тесты с имитацией сбоев служб и сквозную проверку завершения саги.
«Тестирование оркестрованных саг» — бесплатный урок Microservices Communication Patterns (Saga, Circuit Breaker) на CoddyKit. Это урок 4 из 4. Ты можешь прочитать весь урок бесплатно ниже — а потом практиковать его прямо в браузере с встроенным редактором кода и ИИ-репетитором 24/7. Это часть пути обучения Microservices Communication Patterns (Saga, Circuit Breaker), и твой прогресс синхронизируется между веб-версией и приложением CoddyKit. Курс Microservices Communication Patterns (Saga, Circuit Breaker) содержит 4 уроков всего.
Части этого урока еще не переведены и отображаются на английском.
Why Test Sagas?
An orchestration saga coordinates multiple services through a central orchestrator. A bug in the orchestrator can leave the system in an inconsistent state across services.
Testing sagas is harder than testing a single function because you must verify both the happy path and every compensation path.
- Did each step execute in order?
- Did failures trigger the right compensations?
- Is the final state consistent?
The Testing Pyramid for Sagas
Apply the classic testing pyramid:
- Unit tests — the orchestrator's decision logic in isolation.
- Integration tests — the orchestrator talking to real or stubbed services.
- End-to-end tests — the full saga across all services.
Most tests should be unit tests because they are fast and deterministic.
Unit Testing the Orchestrator
The orchestrator is often a state machine. You can unit test its transitions by feeding events and asserting the next command.
def next_command(state, event):
if state == 'STARTED' and event == 'PAYMENT_OK':
return 'RESERVE_STOCK'
if state == 'STARTED' and event == 'PAYMENT_FAILED':
return 'ABORT'
return 'NOOP'
print(next_command('STARTED', 'PAYMENT_OK'))
print(next_command('STARTED', 'PAYMENT_FAILED'))Mocking Service Calls
In unit tests, replace real service calls with mocks or stubs. This lets you control exactly what each step returns.
For example, force the payment service to return a failure so you can assert the orchestrator issues a compensation command.
class FakePayment:
def __init__(self, ok):
self.ok = ok
def charge(self, amount):
return 'PAYMENT_OK' if self.ok else 'PAYMENT_FAILED'
print(FakePayment(False).charge(100))Testing Compensation Paths
The riskiest part of any saga is compensation. For each forward step, write a test that:
- Executes steps up to a chosen point.
- Forces a failure.
- Asserts that every prior step was compensated in reverse order.
executed = ['reserve_stock', 'charge_card']
compensations = list(reversed(executed))
print('Compensate in order:', compensations)Integration Tests with Test Containers
Integration tests run the orchestrator against real dependencies in disposable containers (databases, message brokers).
Tools like Testcontainers spin up a real broker (e.g. Kafka or RabbitMQ) so message flow is exercised exactly as in production.
Simulating Service Failures
To test resilience, inject failures: make a downstream service return errors, time out, or crash mid-saga.
- HTTP 500 from a step
- Timeout (no response)
- Duplicate event delivery
Each scenario should leave the system consistent.
Testing Timeouts
Orchestrators often set a timeout for each step. If a step does not respond, the saga should trigger compensation.
import time
def wait_for_step(timeout, elapsed):
if elapsed > timeout:
return 'TIMEOUT -> COMPENSATE'
return 'OK'
print(wait_for_step(5, 7))
print(wait_for_step(5, 3))Asserting Final State Consistency
The most important assertion is that the system ends in a valid state. After a failed saga, no money should be charged and no stock reserved.
Query each service and verify the invariants hold across them.
Replaying Events in Tests
Because messages can be delivered more than once, replay the same event twice in your tests and assert the saga state is unchanged the second time. This verifies idempotency at the orchestrator level.
processed = set()
def handle(event_id):
if event_id in processed:
return 'IGNORED (duplicate)'
processed.add(event_id)
return 'PROCESSED'
print(handle('e1'))
print(handle('e1'))Observability in Tests
Add assertions on emitted logs, metrics, and trace spans. A well-tested saga should produce a clear audit trail so that, when a real failure happens in production, you can reconstruct exactly what occurred.
Quick Check
Which test type is the best place to verify the orchestrator's transition logic quickly and deterministically?
Recap
You learned how to test orchestrated sagas:
- Use the testing pyramid: many unit tests, fewer integration and E2E tests.
- Mock services to force happy and failure paths.
- Always test compensation order and final state consistency.
- Replay events to confirm idempotency, and inject timeouts and failures.
Thorough saga testing is what keeps distributed transactions trustworthy.
Часто задаваемые вопросы
Урок «Тестирование оркестрованных саг» бесплатный?
Да — полный текст урока «Тестирование оркестрованных саг» бесплатно доступен здесь в веб-версии. Чтобы практиковать его интерактивно (встроенный редактор кода и ИИ-репетитор 24/7) и разблокировать остальной курс Microservices Communication Patterns (Saga, Circuit Breaker), подпишись на CoddyKit PRO. Курс Microservices Communication Patterns (Saga, Circuit Breaker) содержит 4 уроков всего.
Чему я научусь в уроке «Тестирование оркестрованных саг»?
Узнайте, как тестировать саги на основе оркестрации: выполнять модульные тесты путей компенсации, интеграционные тесты с имитацией сбоев служб и сквозную проверку завершения саги. Ты практикуешь Microservices Communication Patterns (Saga, Circuit Breaker) с помощью реального кода, который запускаешь прямо в браузере, и ИИ-репетитор 24/7 отвечает на твои вопросы во время урока.
Нужен ли мне опыт, чтобы начать Microservices Communication Patterns (Saga, Circuit Breaker)?
Предыдущий опыт не требуется. Microservices Communication Patterns (Saga, Circuit Breaker) на CoddyKit структурирован для всех уровней — от новичков до продвинутых, поэтому ты можешь начать отсюда или с самого начала и учиться в своем темпе. Это урок 4 из 4.
Сколько времени занимает урок «Тестирование оркестрованных саг»?
Большинство уроков CoddyKit занимают около 5–10 минут. Каждый из них компактный и интерактивный, поэтому ты постоянно делаешь прогресс и продолжаешь с того же места в веб-версии и приложении.
Можно ли писать и запускать код в этом уроке Microservices Communication Patterns (Saga, Circuit Breaker)?
Да. Каждый урок Microservices Communication Patterns (Saga, Circuit Breaker) включает встроенный редактор кода, поэтому ты пишешь и запускаешь реальный код прямо в браузере и получаешь моментальную обратную связь от AI — локальная установка не требуется.
Все уроки этого курса
- Проектирование оркестраторов Саги
- Конечные автоматы для оркестрации
- Реализация с помощью движка рабочих процессов
- Тестирование оркестрованных саг