Snippet

Streaming von Echtzeitdaten mit asynchronen Generatoren in Django Views

Django unterstützt das Streamen asynchroner Antworten mithilfe asynchroner Generatorfunktionen, die an StreamingHttpResponse übergeben werden. Dieses Muster hält Verbindungen offen, ohne Server-Worker-Threads bei Echtzeit-Datenübertragungen wie Server-Sent Events (SSE) zu blockieren.

snippet.py

python

import asyncio
from django.http import StreamingHttpResponse
 
async def event_stream_generator():
    for i in range(1, 6):
        await asyncio.sleep(1)
        yield f"data: Event payload {i}\n\n"
 
async def async_sse_view(request):
    return StreamingHttpResponse(
        event_stream_generator(),
        content_type="text/event-stream"
    )

django

Erklärung

async def event_stream_generator():

Definiert eine asynchrone Generatorfunktion, die periodisch Datenpakete ausgibt.

await asyncio.sleep(1)

Pausiert die Ausführung asynchron, ohne die Ereignisschleife zu blockieren.

yield f"data: Event payload {i}\n\n"

Gibt formatierte Server-Sent-Event-Datenstrings an den Stream-Puffer aus.

return StreamingHttpResponse(

Erstellt eine Streaming-Antwort unter Übergabe des asynchronen Iterators und des SSE-Header-Inhaltstyps.

Vorheriges Snippet Nächstes Snippet

Mehr Python-Übungen für Fortgeschrittene →

Streaming von Echtzeitdaten mit asynchronen Generatoren in Django Views

Verwandt