Warum wird Ws.Send_Text (& quot; 1 & quot;) vor Load_dataset ('Beans & quot;) in Fastapi ausgeführt?

Fastapi Asynchronous Programing mit await : ws.send_text() und load_dataset() Ausführungsreihenfolge

In diesem Artikel werden die Ausführungsreihenfolge von ws.send_text() und load_dataset() erörtert, wenn sie async / await für die asynchrone Programmierung im Fastapi -Framework verwenden. Im vorherigen Code -Beispiel gab es ein Missverständnis: ws.send_text("1") scheint zu warten, bis load_dataset("beans") vor der Ausführung abgeschlossen ist. Tatsächlich ist dies nicht der Fall.

Der Schlüssel besteht darin, die Rolle des await -Schlüsselworts und die Eigenschaften load_dataset() zu verstehen. await wird nur verwendet, um auf die asynchrone Operation abzuschließen. ws.send_text() ist eine asynchrone Operation. await ws.send_text("1") darauf wartet, dass die Nachricht abgeschlossen wird. load_dataset("beans") ist jedoch ein synchroner Blockiervorgang , der die aktuelle Coroutine blockiert, bis der Datensatz geladen wird.

Analyse des Codeausführungsprozesses:

1. await ws.accept() : Warten Sie, bis die Websocket -Verbindung hergestellt wird.
2. await ws.send_text("1") : Senden Sie die Meldung "1" asynchron und führen Sie nach Abschluss dieser Operation weiter aus.
3. dataset = load_dataset("beans") : Der Synchron -Blockiervorgang beginnt, das Programm pausiert hier, bis load_dataset("beans") den Datensatz von der Ferne heruntergeladen und lädt.
4. await ws.send_text("2") : Senden Sie die Nachricht "2" asynchron, und Sie müssen auch warten, bis das Senden abgeschlossen ist.

Experimentelle Überprüfung und Interpretation von Ergebnissen:

Die experimentellen Ergebnisse zeigen deutlich, dass die Browser -Seite "1" und dann "2" erhält, was mit dem Blockierungsmerkmal von load_dataset("beans") übereinstimmt. Obwohl ws.send_text("1") zuerst ausgeführt wird, wird die Sende von " load_dataset("beans") " verzögert, bis der Datensatz geladen ist.

Verbesserter Code zur Implementierung der Parallelität:

Wenn load_dataset("beans") und ws.send_text("1") gleichzeitig ausgeführt werden müssen, muss load_dataset("beans") in asynchrone Operationen umgewandelt werden. Dies erfordert normalerweise die Verwendung von asynchronen IO -Bibliotheken wie aiohttp , um Daten herunterzuladen. Hier ist ein verbessertes Beispiel (unter der Annahme, dass aiohttp verwendet wird und eine asynchrone Funktion load_dataset_async implementiert ist):

 Asyncio importieren
Aus der DateTime -Importdatetime importieren

Aus Datensätzen importieren Sie load_dataset
von fastapi import fastapi, webocket
von fastapi.responses importieren htmlresponse

app = fastapi ()

# ... (HTML -Code bleibt gleich) ...

@App.Websocket ("/ws")
Async def H (WS: WebSocket):
    Warten Sie Ws.accept ()
    task = asyncio.create_task (load_dataset_async ("beans")) # Asynchron laden Dataset laden
    Warten Sie ws.send_text (f "1: {datetime.now ()}")
    DataSet = Warte Task # warten auf die Dataset -Ladeaufgabe
    print (f "Zeit: {datetime.now ()} => dataset: {dataset}")
    Warten Sie ws.send_text (f "2: {datetime.now ()}")
    # ... (Rest des Codes bleibt gleich) ...

Erstellen Sie asynchrone Aufgaben durch asyncio.create_task() , load_dataset_async("beans") kann gleichzeitig im Hintergrund ausgeführt werden, ohne die Hauptdarstellung zu blockieren.

Zusammenfassung: ws.send_text("1") wurde zuerst im ursprünglichen Code ausgeführt, aber die synchrone Blockierungsfunktion von load_dataset("beans") bestimmt die Ausführungsreihenfolge der nachfolgenden Operationen. Um die Parallelität zu erreichen, muss der Datenbelastungsvorgang asynchron sein.

Das obige ist der detaillierte Inhalt vonWarum wird Ws.Send_Text (& quot; 1 & quot;) vor Load_dataset ('Beans & quot;) in Fastapi ausgeführt?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!