Snippet

Asynchrone Request-Kontext-Middleware zur Korrelations-ID-Injektion

Diese Middleware demonstriert die asynchrone HTTP-Request-Verarbeitung in Django, erfasst Header-Kontexte und gewährleistet die Fehlerfortpflanzung über asynchrone Grenzen hinweg.

snippet.py

python

from typing import Callable, Awaitable
from django.http import HttpRequest, HttpResponse
 
class AsyncCorrelationMiddleware:
    def __init__(self, get_response: Callable[[HttpRequest], Awaitable[HttpResponse]]):
        self.get_response = get_response
 
    async def __call__(self, request: HttpRequest) -> HttpResponse:
        request.correlation_id = request.headers.get("X-Correlation-ID", "anon")
        try:
            response = await self.get_response(request)
            response["X-Correlation-ID"] = request.correlation_id
            return response
        except Exception as exc:
            request.meta_error = str(exc)
            raise

django

Erklärung

class AsyncCorrelationMiddleware:

Defiert eine asynchrone Middleware-Klasse, die mit Djangos ASGI-Pipeline kompatibel ist.

def __init__(self, get_response: Callable[[HttpRequest], Awaitable[HttpResponse]]):

Speichert das nachgelagerte asynchrone Response-Handler-Ausführungsobjekt.

async def __call__(self, request: HttpRequest) -> HttpResponse:

Definiert die asynchrone Aufrufschnittstelle zur Verarbeitung eingehender HTTP-Requests.

request.correlation_id = request.headers.get("X-Correlation-ID", "anon")

Extrahiert den Korrelations-Header oder weist dem Request einen Standardwert zu.

response = await self.get_response(request)

Wartet asynchron auf die nachgelagerte Request-Verarbeitung zur Erzeugung der Response.

Vorheriges Snippet Nächstes Snippet

Mehr Python-Übungen für Experten →

Asynchrone Request-Kontext-Middleware zur Korrelations-ID-Injektion

Verwandt