Sobes.tech
Middle
53

FastAPI permet d'implémenter des fonctions à la fois asynchrones et synchrones : comment cela influence-t-il le comportement ? Comment paralléliser les requêtes dans une fonction async ?

Entreprises à qui on a demandé
СБЕРСБЕР

Réponse de l'IA

sobes.tech IA

FastAPI поддерживает как синхронные, так и асинхронные обработчики запросов.

  • Синхронные функции выполняются в основном потоке, и если в них есть блокирующие операции (например, запросы к базе данных без async драйвера), они блокируют обработку других запросов.
  • Асинхронные функции позволяют использовать await для неблокирующих операций, что повышает производительность при большом числе одновременных запросов.

Однако, если внутри async функции вы вызываете блокирующий код без асинхронного интерфейса, это сведёт на нет преимущества асинхронности.

Для распараллеливания нескольких асинхронных задач внутри async функции можно использовать asyncio.gather(). Например:

from fastapi import FastAPI
import asyncio

app = FastAPI()

async def fetch_data(x):
    await asyncio.sleep(1)  # имитация асинхронной операции
    return x * 2

@app.get("/parallel")
async def parallel_requests():
    results = await asyncio.gather(
        fetch_data(1),
        fetch_data(2),
        fetch_data(3),
    )
    return {"results": results}

Таким образом, запросы внутри async def выполняются параллельно, что сокращает общее время ожидания.