יישום תבנית סאגה לעסקאות מבוזרות

---
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaTopic
metadata:
  name: order-saga-events
spec:
  partitions: 12
  replicas: 3
  config:
    retention.ms: "604800000"
    min.insync.replicas: "2"
    cleanup.policy: compact

היצרן חייב לכלול apiVersion: kafka.strimzi.io/v1beta2 kind: KafkaTopic metadata: name: order-saga-events spec: partitions: 12 replicas: 3 config: retention.ms: "604800000" min.insync.replicas: "2" cleanup.policy: compact — Kafka מבטיחה כתיבה בדיוק פעם אחת בניסיון חוזר. זה קריטי עבור Saga, שבה אירועים כפולים מובילים לביצוע חוזר של שלבים.

כיצד ליישם אידמפוטנטיות של handler?

Kafka ב-at-least-once פירושו: אירוע עשוי להגיע פעמיים. כל handler ב-Saga חייב להיות אידמפוטנטי — ביצוע חוזר עם אותו מזהה אירוע לא משנה את המצב. תבנית: בדוק אם האירוע כבר עובד → בצע עסקה מקומית → פרסם את האירוע הבא.

async def handle_order_created(event: OrderCreatedEvent):
    if await redis.get(f"processed:payment:{event.saga_id}"):
        logger.info(f"Event {event.saga_id} already processed")
        return
    async with db.transaction():
        payment = await payment_service.charge(
            customer_id=event.customer_id,
            amount=event.total_amount,
            idempotency_key=event.saga_id
        )
        await db.execute(
            "INSERT INTO saga_steps (saga_id, step, status) VALUES ($1, $2, $3)",
            event.saga_id, "payment", "completed"
        )
        await redis.setex(f"processed:payment:{event.saga_id}", 86400, "1")
        await kafka_producer.produce("payment.completed", PaymentCompletedEvent(...))

אם שלב N נכשל, יש לבטל את השלבים 1..N-1. עסקאות מפצות חייבות להיות גם אידמפוטנטיות — השתמש ב-enable.idempotence=True עם קידומת refund-.

מדוע אורקסטרציה עדיפה?

Temporal היא מנוע זרימת עבודה עם מצב מתמשך, ניסיון חוזר אוטומטי, והיסטוריה מלאה של כל ביצוע. כאשר עובד קורס, התהליך מתחדש מנקודת העצירה. תשתית: Temporal Server (Docker או Kubernetes), PostgreSQL להתמדה.

@workflow.defn
class OrderSagaWorkflow:
    @workflow.run
    async def run(self, order: OrderRequest) -> OrderResult:
        try:
            payment = await workflow.execute_activity(
                process_payment,
                order.payment_details,
                start_to_close_timeout=timedelta(seconds=30))
        except ActivityError:
            raise
        try:
            reservation = await workflow.execute_activity(
                reserve_inventory,
                order.items,
                start_to_close_timeout=timedelta(seconds=30))
        except ActivityError:
            await workflow.execute_activity(refund_payment, payment.payment_id)
            raise
        try:
            shipment = await workflow.execute_activity(
                create_shipment,
                order,
                start_to_close_timeout=timedelta(seconds=60))
        except ActivityError:
            await workflow.execute_activity(cancel_reservation, reservation.id)
            await workflow.execute_activity(refund_payment, payment.payment_id)
            raise
        return OrderResult(order_id=order.id, payment_id=payment.payment_id, shipment_id=shipment.id)

ניטור Saga: מה לעקוב

DLQ (תור הודעות מתות) הוא קריטי. אירועים שלא עובדו לאחר 3 ניסיונות חוזרים עוברים ל-DLQ. יש לטפל בהם אוטומטית או ידנית.

כיצד ליישם את תבנית Saga: מדריך שלב אחר שלב

1. ביקורת ארכיטקטורה: זהה נקודות כשל במיקרוסרוויסים הנוכחיים.
2. עיצוב Saga: תאר שלבים, פיצויים, סכמת אירועים.
3. פריסת תשתית: הגדר אשכול Kafka/Temporal, topics, התמדה.
4. יישום handler: יישם אידמפוטנטיות, עסקאות מפצות, DLQ.
5. ניטור והתראות: הגדר לוחות מחוונים של Prometheus/Grafana, התראות על פיצויים ו-DLQ.

מה כלול בעבודה שלנו

• ביקורת ארכיטקטורה: ניתוח מיקרוסרוויסים נוכחיים ונקודות כשל.
• עיצוב Saga: הגדרת שלבים, פיצויים, סכמת אירועים.
• פריסת תשתית: אשכול Kafka/Temporal, תצורת topic, הגדרת התמדה.
• יישום handler: אידמפוטנטיות, עסקאות מפצות, DLQ.
• ניטור והתראות: לוחות מחוונים של Prometheus/Grafana, התראות על פיצויים ו-DLQ.
• תיעוד והדרכה: runbook, תבניות postmortem, הדרכת צוות.

תהליך היישום

העלות מחושבת באופן אישי לאחר ביקורת ארכיטקטורת מיקרוסרוויסים. צור קשר להערכה של הפרויקט שלך.

הזמן יישום Saga במפתח — קבל מערכת מבוזרת יציבה.