Можно ли расширить и параметризовать AsyncClient для регистрации тела ввода и вывода каждого внешнего вызова для повторного использования в нескольких методах, использующих один и тот же AsyncClient?
import json
import logging
from fastapi import FastAPI, HTTPException
from httpx import AsyncClient
# Set up basic configuration for logging
logging.basicConfig(level=logging.DEBUG)
app = FastAPI()
client = AsyncClient()
@app.get("/example_post")
async def example_post():
url = "https://jsonplaceholder.typicode.com/posts" # Free fake and reliable API for testing and prototyping.
payload = {
"title": 'fooxxx',
"body": 'bar',
"userId": 1,
}
# Perform the HTTP POST request; would like to log input payload and output data response
response = await client.post(url, content=json.dumps(payload))
# Parse response as JSON
data = response.json()
# Searching for universal solution that can log request and response of every api call instead of logging manually
logging.info(f"Received response: {data}")
return data
if __name__ == "__main__":
import uvicorn
uvicorn.run(app, host = "0.0.0.0", port=8000)
Когда дело доходит до регистрации тела запроса, вам следует учитывать перехватчики событий.
Вот документ: https://www.python-httpx.org/advanced/event-hooks/.
И вот как это можно реализовать:
from httpx import AsyncClient
from httpx import Response, Request
async def log_request(request: Request):
print(f"Request event hook: {request.method} {request.url} {request.content} - Waiting for response")
client = AsyncClient(event_hooks = {'request': [log_request]})
Что касается тела ответа, здесь все немного сложнее, поскольку тело представляет собой поток, который можно потребить только один раз.
Чтобы обойти эту проблему, вы можете написать собственный транспортный уровень. Вы можете обратиться к этому ответу: https://github.com/encode/httpx/discussions/3073#discussioncomment-8263619
@Chris отметил этот вопрос как повторяющийся, и это не та же проблема. Мне нужно регистрировать ввод и вывод AsyncClient не по запросу на моей конечной точке (в данном случае example_post), а по URL-адресу.