Quel est le problème avec ce code aiohttp asynchrone?

Question

Pour le code suivant à l'aide aiohttp:

async def send(self, msg, url): 
    async with aiohttp.ClientSession() as session: 
     async with session.post(url, data=msg) as response: 
      self._msg = response.read() 

async def recv(self): 
    return await self._msg 

Il fonctionne ... La plupart du temps, mais parfois (souvent, en fait) donne lieu à diverses exceptions - réponses généralement tronquées, ou une connexion étant déjà fermée exception.

En revanche, ce qui suit fonctionne parfaitement:

async def send(self, msg, url): 
    async with aiohttp.ClientSession() as session: 
     async with session.post(url, data=msg) as response: 
      self._msg = await response.read() 

async def recv(self): 
    return self._msg 

Je voudrais savoir pourquoi, la deuxième version est techniquement incorrecte pour mes besoins et je dois corriger. (Il est incorrect car la fonction recv peut être appelée avant que la réponse ait été lue)

Answer 1

with est un gestionnaire de contexte, il exécute du code avant et après toutes les instructions dans son bloc, la tenue de la comptabilité en général. C'est-à-dire que votre première fonction recv vous attend probablement sur un futur qui fait référence à une connexion déjà fermée, ou quelque chose du genre.

Disons que vous avez un code qui ressemble à ceci:

with open(...) as file: 
    file.read() 

C'est ce qu'il fait, à peu près:

file = open(...) 
file.read() 
file.close() 

Et cela est l'équivalent de ce que vous faites dans votre premier exemple:

file = open() 
file.close() 
... 
file.read()