Сервер asyncio не отменяет запрос, даже если aiohttp.ClientSession превышает таймаут ⇐ Python

[Anonymous]

Конечная цель — отменить запрос на стороне сервера, если клиент превышает таймаут.
Код, связанный с запуском сервера:

Код: Выделить всё

def run_server_loop(
routes: web.RouteTableDef,
shutdown_state: ShutdownState,
logger: Logger,
*,
port: int,
periodic_callback: Callable[[], None] | None = None,
shutdown_callback: Callable[[], None] | None = None,
) -> None:
loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
try:
loop.run_until_complete(
_run_server(
routes,
shutdown_state,
logger,
port=port,
periodic_callback=periodic_callback,
)
)
finally:
if shutdown_callback is not None:
shutdown_callback()
logger.info('Server stopped')
flush_logs()

async def _run_server(
routes: web.RouteTableDef,
shutdown_state: ShutdownState,
logger: Logger,
*,
port: int,
periodic_callback: Callable[[], None] | None = None,
) -> None:
try:
app = web.Application()
app.add_routes(routes)
runner = web.AppRunner(
app,
access_log_format=(
'%a %t [%D μs] "%r" %{Content-Length}i %s '
'%b "%{Referer}i" "%{User-Agent}i"'
),
)
await runner.setup()
site = web.TCPSite(runner, port=port)
await site.start()
logger.info(f'Listening {site.name}')

while not shutdown_state.is_shutdown_requested:
await asyncio.sleep(0.1)
if periodic_callback is not None:
periodic_callback()

await runner.cleanup()
except:  # noqa
logger.critical('Unhandled exception', exc_info=True)
raise

Вот мой код конечной точки:

Код: Выделить всё

@routes.get('/ping')
async def handle_ping(_) -> web.Response:
try:
import time
import asyncio
for i in range(10):
await asyncio.sleep(1)

return web.json_response(
data=PingResult(
service_name=service_name,
version=SERVICE_VERSION,
storage_path=str(storage_dir.path),
daemon_pid=daemon.pid,
daemon_status=str(daemon.status.value),
).dict()
)
except asyncio.CancelledError as ce:
print('Request was cancelled')
return HTTPBadRequest(ErrorResult(error='Request was cancelled'))

Код клиента

Код: Выделить всё

async def ping(timeout=10) -> PingResult:
async with aiohttp.ClientSession(timeout=ClientTimeout(total=timeout)) as session:
async with session.get('http://localhost:5002/ping') as resp:
body = await resp.json()
return PingResult.parse_obj(body)

Модели

Код: Выделить всё

from aiohttp import web
from pydantic import BaseModel

class ErrorResult(TypedDict):
error: str

class HTTPBadRequest(web.HTTPBadRequest):
def __init__(self, error: Mapping) -> None:
super().__init__(text=dumps(error), content_type='application/json')

class PingResult(BaseModel):
service_name: str
version: str
storage_path: str
daemon_pid: int
daemon_status: str

Даже если я вызову ping(timeout=2), я увижу, что запрос на сервере не был отменен. Или, если я вызову curl http://localhost:5002/ping и завершу команду менее чем за 2–3 секунды, я получу такое же поведение (код на стороне сервера работает без какого-либо завершения).
Похоже, я неправильно понимаю саму идею отмены запроса, но я могу понять, как мне достичь своей главной цели.


Подробнее здесь: https://stackoverflow.com/questions/791 ... exceeds-it