Tengo una aplicación FastAPI que, en varias ocasiones diferentes, necesita llamar a API externas. Uso httpx.AsyncClient para estas llamadas. El punto es que no entiendo completamente cómo debo usarlo.
De la documentación de httpx, debería usar administradores de contexto,
async def foo(): """" I need to call foo quite often from different parts of my application """ async with httpx.AsyncClient() as aclient: # make some http requests, eg, await aclient.get("http://example.it") Sin embargo, entiendo que de esta manera se genera un nuevo cliente cada vez que llamo a foo() , y es precisamente lo que queremos evitar al usar un cliente en primer lugar.
Supongo que una alternativa sería tener algún cliente global definido en alguna parte, e importarlo cuando lo necesite así.
aclient = httpx.AsyncClient() async def bar(): # make some http requests using the global aclient, eg, await aclient.get("http://example.it")Sin embargo, esta segunda opción parece algo sospechosa, ya que nadie se ocupa de cerrar la sesión y cosas por el estilo.
Entonces, la pregunta es: ¿cómo (re) uso httpx.AsyncClient() dentro de una aplicación FastAPI?
Bueno, tu alternativa me parece buena, generas un cliente y lo reutilizas cada vez que lo necesitas, pero tienes razón, nadie cierra la sesión.
desde httpx doc : (en su caso, importe BackgroundTask y StreamingResponse desde fastApi)
import httpx from starlette.background import BackgroundTask from starlette.responses import StreamingResponse client = httpx.AsyncClient() async def home(request): req = client.build_request("GET", "https://www.example.com/") r = await client.send(req, stream=True) return StreamingResponse(r.aiter_text(), background=BackgroundTask(r.aclose))