Kenapa ws.send_text (& quot; 1 & quot;) melaksanakan sebelum load_dataset (& quot; kacang & quot;) dalam fastapi?

Pengaturcaraan Asynchronous Fastapi dengan await kata kunci: ws.send_text() dan load_dataset() Pesanan pelaksanaan

Artikel ini membincangkan perintah pelaksanaan ws.send_text() dan load_dataset() fungsi apabila menggunakan async / await untuk pengaturcaraan asynchronous dalam rangka FastAPI. Dalam contoh kod terdahulu, terdapat salah faham: ws.send_text("1") nampaknya perlu menunggu load_dataset("beans") untuk diselesaikan sebelum pelaksanaan. Malah, ini tidak berlaku.

Kuncinya adalah untuk memahami peranan kata kunci await dan ciri -ciri fungsi load_dataset() . await hanya digunakan untuk menunggu operasi tak segerak selesai. ws.send_text() adalah operasi asynchronous, jadi await ws.send_text("1") akan menunggu mesej dihantar untuk diselesaikan. Walau bagaimanapun, load_dataset("beans") adalah operasi menyekat segerak yang menghalang coroutine semasa sehingga beban dataset.

Analisis Proses Pelaksanaan Kod:

1. await ws.accept() : Tunggu sambungan WebSocket untuk ditubuhkan.
2. await ws.send_text("1") : Hantar mesej "1" secara asynchronously, dan terus melaksanakan selepas operasi ini selesai.
3. dataset = load_dataset("beans") : Operasi penyekatan segerak bermula, program berhenti di sini sehingga load_dataset("beans") memuat turun dan memuatkan dataset dari jauh dan selesai.
4. await ws.send_text("2") : Hantar mesej "2" secara asynchronously, dan anda juga perlu menunggu penghantaran selesai.

Pengesahan eksperimen dan tafsiran hasil:

Hasil eksperimen dengan jelas menunjukkan bahawa sisi penyemak imbas menerima "1" pertama, dan kemudian "2", yang konsisten dengan ciri -ciri penyekatan load_dataset("beans") . Walaupun ws.send_text("1") dilaksanakan terlebih dahulu, penyekatan load_dataset("beans") menyebabkan penghantaran "2" ditangguhkan sehingga dataset dimuatkan.

Kod yang lebih baik untuk melaksanakan kesesuaian:

Jika load_dataset("beans") dan ws.send_text("1") dikehendaki untuk melaksanakan secara serentak, load_dataset("beans") perlu diubah menjadi operasi tak segerak. Ini biasanya memerlukan penggunaan perpustakaan IO asynchronous, seperti aiohttp , untuk memuat turun data. Berikut adalah contoh yang lebih baik (dengan mengandaikan bahawa aiohttp digunakan dan fungsi load_dataset_async yang tidak disengajakan dilaksanakan):

 Import Asyncio
dari DateTime import datetime

dari dataset import load_dataset
Dari Fastapi Import Fastapi, WebSocket
dari fastapi.Sespons import htmlresponse

app = fastapi ()

# ... (kod HTML tetap sama) ...

@app.websocket ("/ws")
Async def h (WS: WebSocket):
    tunggu wscept ()
    tugas = asyncio.create_task (load_dataset_async ("kacang")) # asynchronously load dataset
    menunggu ws.send_text (f "1: {datetime.now ()}")
    dataset = menunggu tugas # menunggu tugas pemuatan dataset
    cetak (f "masa: {datetime.now ()} => dataset: {dataset}")
    menunggu ws.send_text (f "2: {datetime.now ()}")
    # ... (selebihnya kod tetap sama) ...

Buat tugas asynchronous melalui asyncio.create_task() , load_dataset_async("beans") boleh dilaksanakan secara serentak di latar belakang tanpa menyekat coroutine utama.

Ringkasan: ws.send_text("1") telah dilaksanakan terlebih dahulu dalam kod asal, tetapi ciri penyekatan segerak load_dataset("beans") menentukan perintah pelaksanaan operasi berikutnya. Untuk mencapai kesesuaian, operasi pemuatan data mestilah tidak segerak.

Atas ialah kandungan terperinci Kenapa ws.send_text (& quot; 1 & quot;) melaksanakan sebelum load_dataset (& quot; kacang & quot;) dalam fastapi?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!