İstemcinin aiohttp istek işleyicisinden bir bağlantıyı kapattığını algıla.

Question

Uzun süren bir çalışma isteğim var. Ancak, istek, istemcinin bağlantısı kesildiğinde temizlemek istediğim sunucu tarafı oluşturulmuş bazı kaynaklar gerektirir. Dokümanları inceledim, ancak ne zaman olduğunu tespit etmenin bir yolunu bulamıyorum. Herhangi bir fikir?

Answer 1

Bu, belgelere bakıldığında çok açık değildir, ancak asyncio sunucusunun, bağlantı kapatıldığında işleyici koroutine bir CancelledError atmasıdır. Eşzamansız bir işlemin tamamlanmasını beklerken nerede olursanız olun CancelledError'u yakalayabilirsiniz.

bu kullanarak, böyle bir şey ile bir bağlantı sonra temizlik:

async def passthrough_data_until_disconnect(): 
    await create_resources() 
    while True: 
     try: 
      await get_next_data_item() 
     except (concurrent.futures.CancelledError, 
       aiohttp.ClientDisconnectedError): 
      # The request has been cancelled, due to a disconnect 
      await do_cleanup() 
      # Re-raise the cancellation error so the handler 
      # task gets cancelled for real 
      raise 
     else: 
      await write_data_to_client_response()