Idempotenz

Idempotenz im Überblick

In verteilten Systemen passieren Netzwerkfehler. Eine Anfrage wird gesendet, aber die Antwort kommt nie an – war die Anfrage erfolgreich oder nicht? Die sichere Lösung: einfach nochmal senden. Aber nur, wenn die Operation idempotent ist.

Nicht idempotent: POST /orders – zweimal gesendet = zwei Bestellungen
Idempotent: PUT /orders/123/status mit {"status": "shipped"} – zehnmal gesendet = Status ist „shipped”

Das ist der Kern: Idempotente Operationen können sicher wiederholt werden, ohne unerwünschte Nebeneffekte.

At-least-once vs. Exactly-once

In verteilten Systemen gibt es drei Delivery-Garantien:

At-least-once + Idempotenz = sicheres System: Wenn Duplikate sicher ignoriert werden, ist At-least-once ausreichend und viel einfacher als Exactly-once.

Technisch betrachtet

HTTP-Methoden im Überblick

Idempotency Key implementieren

import json
import redis
from fastapi import FastAPI, Header, HTTPException

app = FastAPI()
cache = redis.Redis()

@app.post("/payments")
async def create_payment(
    payment: PaymentRequest,
    idempotency_key: str = Header(..., alias="Idempotency-Key")
):
    cache_key = f"idem:{idempotency_key}"

    # Bereits verarbeitet? → Gespeichertes Ergebnis zurückgeben
    cached = cache.get(cache_key)
    if cached:
        return json.loads(cached)

    # Noch nicht verarbeitet → Zahlung durchführen
    try:
        result = await process_payment(payment)
    except Exception as e:
        # Fehler NICHT cachen – Retry soll erneut versuchen
        raise HTTPException(status_code=500, detail=str(e))

    # Ergebnis 24h cachen (nur bei Erfolg)
    cache.setex(cache_key, 86400, json.dumps(result))
    return result

Idempotente Datenbankoperationen

-- ❌ Nicht idempotent: Jedes Mal wird ein neuer Datensatz erstellt
INSERT INTO orders (user_id, product_id, amount)
VALUES (123, 456, 99.99);

-- ✅ Idempotent: Nur einfügen wenn noch nicht vorhanden
INSERT INTO orders (id, user_id, product_id, amount)
VALUES ('ord_abc123', 123, 456, 99.99)
ON CONFLICT (id) DO NOTHING;

-- ✅ Idempotent: Upsert – einfügen oder aktualisieren
INSERT INTO order_status (order_id, status, updated_at)
VALUES ('ord_abc123', 'shipped', NOW())
ON CONFLICT (order_id) DO UPDATE SET
  status = EXCLUDED.status,
  updated_at = EXCLUDED.updated_at;

Idempotente Webhook-Verarbeitung

processed_events = set()  # In Production: Redis oder DB

@app.post("/webhooks/stripe")
async def handle_stripe_webhook(request: Request):
    payload = await request.body()
    sig = request.headers.get("Stripe-Signature")

    # Signatur verifizieren
    event = stripe.Webhook.construct_event(payload, sig, WEBHOOK_SECRET)

    # Bereits verarbeitet?
    if event.id in processed_events:
        return {"status": "already_processed"}

    # Verarbeiten
    if event.type == "payment_intent.succeeded":
        await fulfill_order(event.data.object)

    processed_events.add(event.id)
    return {"status": "ok"}

Stripe-Beispiel

curl https://api.stripe.com/v1/charges \
  -H "Idempotency-Key: a8f3b2c1-4d5e-6f7a-8b9c-0d1e2f3a4b5c" \
  -d amount=2000 \
  -d currency=eur
# Zweiter Aufruf mit gleichem Key → gleiche Antwort, keine zweite Zahlung

Wann ist Idempotenz besonders wichtig?

• Zahlungen: Doppelte Abbuchungen sind kritisch
• E-Mail-Versand: Doppelte Willkommens-Mails sind ärgerlich
• Lagerbestand: Doppeltes Reduzieren führt zu negativem Bestand
• Webhook-Handler: Webhooks werden oft mehrfach gesendet (Retry-Logik des Senders)
• Message Queues: Kafka, RabbitMQ liefern At-least-once – Consumer müssen idempotent sein