Microservices Communication Patterns (Saga, Circuit Breaker) · درس

اختبار sagas المنسّقة

تعلّم كيفية اختبار sagas القائمة على التنسيق، بما يشمل اختبارات الوحدة لمسارات التعويض، واختبارات التكامل مع حالات فشل محاكاة للخدمات، والتحقق الشامل من اكتمال saga.

اختبار sagas المنسّقة درس مجاني في 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.

الأسئلة الشائعة

هل درس «اختبار sagas المنسّقة» مجاني؟

نعم — نص درس «اختبار sagas المنسّقة» كامل متاح مجاناً هنا على الويب. لتمرينه بشكل تفاعلي (محرر أكواد مدمج ومدرس ذكاء اصطناعي متاح 24/7) وفتح باقي دورة Microservices Communication Patterns (Saga, Circuit Breaker)، انتقل إلى CoddyKit PRO. تتضمن دورة Microservices Communication Patterns (Saga, Circuit Breaker) 4 دروس في المجموع.

ماذا ستتعلم في «اختبار sagas المنسّقة»؟

تعلّم كيفية اختبار sagas القائمة على التنسيق، بما يشمل اختبارات الوحدة لمسارات التعويض، واختبارات التكامل مع حالات فشل محاكاة للخدمات، والتحقق الشامل من اكتمال saga. تتمرن على Microservices Communication Patterns (Saga, Circuit Breaker) مع أكواد عملية تشغلها مباشرة في المتصفح، ومدرس ذكاء اصطناعي متاح 24/7 يجيب على أسئلتك أثناء عملك.

هل أحتاج إلى خبرة سابقة لأبدأ Microservices Communication Patterns (Saga, Circuit Breaker)؟

لا تُشترط خبرة سابقة. Microservices Communication Patterns (Saga, Circuit Breaker) على CoddyKit منظم للمبتدئين حتى المتقدمين، لذا يمكنك البدء من هنا أو من البداية والتقدم بسرعتك الخاصة. هذا هو الدرس 4 من أصل 4.

كم من الوقت يستغرق درس «اختبار sagas المنسّقة»؟

معظم دروس CoddyKit تستغرق حوالي 5–10 دقائق. كل منها موجز وتفاعلي، لذا تحرز تقدماً مستمراً وتستأنف من حيث توقفت عبر الويب والتطبيق.

هل يمكنني كتابة وتشغيل أكواد في درس Microservices Communication Patterns (Saga, Circuit Breaker) هذا؟

نعم. كل درس في Microservices Communication Patterns (Saga, Circuit Breaker) يتضمن محرر أكواد مدمج، لذا تكتب وتشغل أكواداً حقيقية مباشرة في متصفحك وتحصل على تعليقات فورية من الذكاء الاصطناعي — بدون إعداد محلي.

جميع الدروس في هذه الدورة

← العودة إلى Microservices Communication Patterns (Saga, Circuit Breaker)