0

Всем привет!

import asyncio
import aiohttp
aut_token = ("token")
tasks = []
iter_flag = True
interval = 0
seq = 0
class WAPI:

    async def receiver(WAPI_S):
        async for msg in WAPI_S:
            global interval
            global seq
            data = msg.json()
            seq = data.get("s")
            if data.get("op") == 10:
                interval = data.get("d").get("heartbeat_interval") / 1000 
            if data.get("op") == 11:
                pass
            raise aiohttp.ClientError

    async def heartbeating(WAPI_S):
        while iter_flag:
            await WAPI_S.send_json({
                            "op": 1,
                            "d": seq
                        })
            
            await asyncio.sleep(interval)

    async def event_manager():
        loop = asyncio.get_running_loop()
        try:
            async with aiohttp.ClientSession() as session:
                async with session.ws_connect("url") as WAPI_S: 
                    task_receive = loop.create_task(WAPI.receiver(WAPI_S)); task_heartbeating = loop.create_task(WAPI.heartbeating(WAPI_S))
                    tasks.append(task_receive); tasks.append(task_heartbeating)
                    await asyncio.gather(*tasks)
        except aiohttp.ClientError:
            global iter_flag
            iter_flag = False
            await asyncio.sleep(interval)
            for task in tasks:
                task.cancel()
            try:
                loop.close()
            except:
                loop.stop()
                
asyncio.run(WAPI.event_manager())

Пытаюсь реализовать перехват ClientError с закрытием loop, но чёт не выходит. Выводит RuntimeError с "Event loop stopped before Future completed."

Как правильно надо реализовывать подобное?

1
  • Уберите loop.close(). Да и loop.stop() тоже.
    – vitidev
    27 июл 2021 в 14:58

1 ответ 1

0

Не надо его закрывать. Он закроктся при выходе из asyncio.run. вот тут https://github.com/python/cpython/blob/890e22957d427ee994b85d62dfe4d5a7cbd34ec5/Lib/asyncio/runners.py#L52

6
  • А если, допустим, реализовывать перезагрузку клиента, то нужно вместо asyncio.run юзать более низкоуровневый loop.run_until_complete(), чтоб можно было применять loop.close()?
    – Debianov
    28 июл 2021 в 9:45
  • Для перезагрузки клиента можно использовать вызовы asyncio.run на каждую перезагрузку - ведь там уже реализованно закрытие, открытие и обработка тасков при завершении.
    – eri
    28 июл 2021 в 9:48
  • а в случае loop.run_until_complete этот же loop использовать повторно. если очень хочется - то можно его закрывать и открывать новый, но пока не вижу в этом смысла
    – eri
    28 июл 2021 в 9:49
  • Ага... И тогда (при asyncio.run) просто закрывать ClientSession через close, там по цепочке сам закроется event loop, и я смогу снова через asyncio.run стартануть с начала. Так? Код, который есть в этом вопросе, не полон (миниатюрная модель основного кода), но в полном коде, наверное, использование loop напрямую тоже не особо нужно. Так что ты прав.
    – Debianov
    28 июл 2021 в 10:48
  • async with закроет сессию при выходе из контекста
    – eri
    28 июл 2021 в 11:17

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими пользовательским соглашением, политикой конфиденциальности и политикой о куки

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.