Error asyncio unclosed client session

У меня есть test.py файл и AsyncioCurl.py файл.
Я уже использую session вместо просто aiohttp.request
Но это также дает мне эту ошибку:

Unclosed client session
client_session: <aiohttp.client.ClientSession object at 0x000001FAEFEA7DA0>
Unclosed connector
connections: ['[(<aiohttp.client_proto.ResponseHandler object at 0x000001FAF10AC648>, 119890.906)]']
connector: <aiohttp.connector.TCPConnector object at 0x000001FAF0F702B0>

test.py

import asyncio
from AsyncioCurl import AsyncioCurl
async def a():
    payload = {}
    url = "https://awebsiteisthere.com"
    data = await AsyncioCurl().get(url,payload)
    print(data)

task = [
    a()
]

loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(task))

< Сильный > AsyncioCurl.py

import asyncio
import aiohttp
from Log import Log
from Base import sign
from config import config


class AsyncioCurl:
    def __init__(self):
        self.session = aiohttp.ClientSession(timeout=aiohttp.ClientTimeout(total=4))

    async def get(self,url,param):
        Log.debug("GET: "+url)
        payload = {
            "cookie":config["Token"]["COOKIE"]
        }
        payload = dict(param,**payload)
        payload = sign(payload)
        async with self.session.get(url,params=payload) as r:
            Log.debug(r.status)
            return await r.json()

    async def post(self,url,param):
        async with sem:
            Log.debug("POST: "+url)
            payload = {
                "cookie":config["Token"]["COOKIE"]
            }
            payload = dict(param,**payload)
            payload = sign(payload)
            async with self.session.post(url,data=payload) as r:
                return await r.json()

    async def nspost(self,url,param):
        Log.debug("POST: "+url)
        headers = {
            "Accept":"application/json, text/plain, */*",
            "User-Agent":"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_3) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/62.0.3202.94 Safari/537.36",
            "Accept-Language":"zh-CN,zh;q=0.9",
            "accept-encoding":"gzip, deflate",
            "cookie":config["Token"]["COOKIE"]
        }
        async with self.session.post(url,data=param,headers=headers) as r:
            return await r.json()

    async def nsdpost(self,url):
        Log.debug("POST: "+url)
        headers = {
            "Accept":"application/json, text/plain, */*",
            "User-Agent":"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_3) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/62.0.3202.94 Safari/537.36",
            "Accept-Language":"zh-CN,zh;q=0.9",
            "accept-encoding":"gzip, deflate",
            "cookie":config["Token"]["COOKIE"]
        }
        async with self.session.post(url,headers=headers) as r:
            return await r.json()

Это не ошибка, просто предупреждение. И вы можете справиться с этим, закрыв сессию. Попробуй это:

async def a():
    payload = {}
    url = "https://awebsiteisthere.com"
    curl = AsyncioCurl()
    data = await curl.get(url,payload)
    print(data)
    await curl.session.close()  # this

Я только что добавил close() в конец вашего test.py скрипта

import asyncio
from AsyncioCurl import AsyncioCurl
async def a():
    payload = {}
    url = "https://awebsiteisthere.com"
    data = await AsyncioCurl().get(url,payload)
    print(data)
    await AsyncioCurl.close() #added this line

task = [
    a()
]

loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(task))

662 исправляет это для run_async=False (по умолчанию используется False, поэтому вы используете режим False, если вы явно не указываете этот параметр), поскольку режим синхронизации больше не зависит от библиотеки aiohttp.

@seratch Я использовал его в асинхронном режиме (забыл указать). Это что-то меняет?

@jourdanrodrigues Спасибо за ответ. В этом случае это может все еще существовать в зависимости от вопросов, связанных с aiohttp. Позвольте мне снова открыть это и удалить веху v2.6.0.

Имея ту же проблему, try-except поймал asyncio.TimeoutError и в конце он показал «Незакрытый сеанс клиента»,

try:
    await slack_client.chat_postMessage(...)
except Exception:
    logger.exception(f'failed to post message')

После некоторого расследования кажется, что исключение может быть вызвано внутри инструкции async with, https://github.com/slackapi/python-slackclient/blob/v2.3.1/slack/web/base_client.py#L259

Итак, можем ли мы использовать оператор try-finally, чтобы убедиться, что сеанс клиента aiohttp правильно закрыт? Я провел несколько тестов локально, похоже, в моем случае это работает,

try:
    async with session.request(http_verb, api_url, **req_args) as res:
        data = {}
        try:
            data = await res.json()
        except aiohttp.ContentTypeError:
            self._logger.debug(
                f"No response data returned from the following API call: {api_url}."
            )
        response = {"data": data, "headers": res.headers, "status_code": res.status}
finally:
    if not use_running_session:
        await session.close()

@NoAnyLove Спасибо, что поделились этим! Мне тоже нравится ваше предложение. Чтобы продвинуться вперед, я хочу иметь модульный тест, который всегда сначала воспроизводит ситуацию, а затем хотел бы применить его исправление в качестве допустимого решения. Если вам интересно работать над обоими, я буду рад рассмотреть и объединить их. Если вы заняты, я, вероятно, поработаю над этим на следующей неделе.

Спасибо за быстрый ответ. Постараюсь поработать на выходных.