Ошибка: незакрытый сеанс клиента даже после использования метода session.close () для закрытия сеанса - PullRequest
Новая
       4

Ошибка: незакрытый сеанс клиента даже после использования метода session.close () для закрытия сеанса

0 голосов
/ 06 февраля 2020

Когда я запускаю код ниже, я получаю эту ошибку: 

TypeError: Use async with instead
Unclosed client session
client_session: <aiohttp.client.ClientSession object at 0x0000023D639B0DA0>

Код был скопирован непосредственно из: https://www.artificialworlds.net/blog/2017/06/12/making-100-million-requests-with-python-aiohttp/. Примечание. Я пытался добавить session.close (), чтобы закрыть сеанс, но все еще получаю эту ошибку. 

from aiohttp import ClientSession
import asyncio
import sys

limit = 1000

async def fetch(url, session):
    async with session.get(url) as response:
        return await response.read()

async def bound_fetch(sem, url, session):
    # Getter function with semaphore.
    async with sem:
        await fetch(url, session)

async def run(session, r):
    url = "http://localhost:8080/{}"
    tasks = []
    # create instance of Semaphore
    sem = asyncio.Semaphore(limit)
    for i in range(r):
        # pass Semaphore and session to every GET request
        task = asyncio.ensure_future(bound_fetch(sem, url.format(i), session))
        tasks.append(task)
    responses = asyncio.gather(*tasks)
    await responses

loop = asyncio.get_event_loop()
with ClientSession() as session:
    loop.run_until_complete(asyncio.ensure_future(run(session, int(sys.argv[1]))))
...