تسليم Pub/Sub وعدم تكرار الأثر

deliveries = [("event-a", 10), ("event-a", 10), ("event-b", 20)]
seen = set()
total = 0
for event_id, amount in deliveries:
    if event_id in seen: continue
    seen.add(event_id)
    total += amount
print(f"deliveries={len(deliveries)} unique={len(seen)} total={total}")

deliveries=3 unique=2 total=30

تمثل ثلاثة تسليمات حدثين بمجموع 30، والمجموعة ليست حلا إنتاجيا.

arrivals_per_minute = 120
processed_per_minute = 100
minutes = 5
growth = max(0, arrivals_per_minute - processed_per_minute)
print(f"growth_per_minute={growth} added_backlog={growth * minutes}")

growth_per_minute=20 added_backlog=100

تضيف خمس دقائق مئة رسالة تحت المعدلين المخترعين الثابتين.