Возникает ошибка при вызове своего асинхронного метода(Pyrogram)?

Question

[KPoseidon]

Код метода:

async def GetUserByUsername(username: str, bot_func: Client):
        if bot_func.is_connected == True:
            await bot_func.stop()
        await bot_func.start()
        user = await bot_func.invoke(ResolveUsername(username=username))
        await bot_func.stop()
        return user.users[0]

Ошибка:

2023-02-07 19:24:16,886 (async_telebot.py:543 MainThread) ERROR - TeleBot: "Task <Task pending name='Task-83' coro=<AsyncTeleBot._run_middlewares_and_handlers() running at /Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/telebot/async_telebot.py:516> cb=[gather.<locals>._done_callback() at /Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/asyncio/tasks.py:754]> got Future <Task pending name='Task-111' coro=<Dispatcher.handler_worker() running at /Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/pyrogram/dispatcher.py:202>> attached to a different loop"

Возникает ошибка при вызове данного метода, что я мог неправильно сделать? Библиотека с ТГ Апи: Pyrogram

Answer 1

[Vindicar]

attached to a different loop

Ты или мешаешь асинхронность с многопоточностью, или какую-то подобную глупость делаешь. Без полного кода бота сказать затруднительно.

Comments

[KPoseidon]

ну хз, пока многопоточность не делаю в тг боте. Исходник бота теперь в Гитхабе: https://github.com/LanceMinecraftFBA/AlbiChatManager

[Vindicar]

KPoseidon, что-то я не понял. У тебя там асинхронная версия pyTelegramBotAPI, причём тут пирограм? Ты его даже не импортируешь нигде.

[Vindicar]

KPoseidon, а, всё, понял.
Зачем ты запускаешь отдельного бота в GetUserByUsername()?

[KPoseidon]

Vindicar, тип надо было запустить с самого начала и всё?

[Vindicar]

KPoseidon, ну конечно! А функциям просто тем или иным способом давай доступ к этому экземпляру.

[KPoseidon]

Vindicar, аааа, я дурачок в питоне, ща чекну

[KPoseidon]

Vindicar,

Traceback (most recent call last):
  File "/Users/lance/Python projects/AlbiChatManager/bot.py", line 19, in <module>
    asyncio.run(bot_func.start())
  File "/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/asyncio/runners.py", line 190, in run
    return runner.run(main)
           ^^^^^^^^^^^^^^^^
  File "/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/asyncio/runners.py", line 89, in run
    raise ValueError("a coroutine was expected, got {!r}".format(coro))
ValueError: a coroutine was expected, got <pyrogram.client.Client object at 0x106736650>

[Vindicar]

KPoseidon, я хз где ты это написал, но ты явно не очень хорошо представляешь, как работают асинхронные программы...
Есть рабочий цикл (event loop), в котором программа крутится всё время. Весь асинхронный код выполняется как часть этого цикла, а asyncio определяет, какую часть кода (корутину) выполнить.

При старте ты запускаешь этот цикл и передаёшь ему главную корутину. Большинство методов типа bot.run() делают именно это - запускают цикл и отдают ему для выполнения тело бота.

Тело бота занимается сетевым вводом-выводом и мониторит происходящее. По наступлении события (сообщения, например), бот дёргает соответствующий обработчик-корутину, который ты зарегистрировал до старта. Пока обработчик работает, цикл ждёт - но при await-вызове другой корутины он "уступает ей место", пока она не завершится, позволяя циклу продолжить работу.

Т.е. для написания бота на базе библиотеки нужно сделать две вещи:
1. Разобраться, как запустить тело бота. Бот может иметь готовый синхронный метод, который надо дёргать без await. Этот метод запустить event loop и будет его крутить пока бот не завершит работу. Или же бот может иметь асинхронное тело, которое надо вызвать в рамках уже запущенной корутины в уже работающем event loop. Какой из двух вариантов выбрать - смотри сам, но нужно выбрать один.
2. Ну и разобраться, как подключить обработчики к боту.
Всё, что между этими двумя пунктами - задача библиотеки, для нас это чёрный ящик.

[KPoseidon]

Vindicar, после инициализации переменной bot_func

[KPoseidon]

Vindicar, в питоне он какой-то загадочный(в СиШарпе я на задобись юзаю асинхронность и всё норм)

[KPoseidon]

зато синхронный запуск пирограм клиента ломает вызов метода по поводу resolveUsername:

2023-02-08 17:13:41,286 (async_telebot.py:543 MainThread) ERROR - TeleBot: "Task <Task pending name='Task-53' coro=<AsyncTeleBot._run_middlewares_and_handlers() running at /Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/telebot/async_telebot.py:516> cb=[gather.<locals>._done_callback() at /Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/asyncio/tasks.py:754]> got Future <Future pending cb=[_chain_future.<locals>._call_check_cancel() at /Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/asyncio/futures.py:387]> attached to a different loop"

боже, в питоне я 100 раз сдохну

[Vindicar]

KPoseidon, ну вот тут сразу вопрос: а на кой хрен тебе вообще два разных бота в одном скрипте? Эту ситуацию лучше исключать сразу, и не допускать до тех пор, пока это возможно.

Их запустить так, чтобы они не подрались - задача нетривиальная, как раз потому, что по дефолту они пытаются каждый запустить свой event loop со своим телом бота. А event loop должен быть ОДИН. Тебе исключение об этом и говорит - объекты asyncio, привязанные к разным event loop, не могут толком взаимодействовать.

Если по другому никак (но я не представляю себе ситуацию, почему), то второго бота надо запускать по-другому, не обычным способом, а как корутину в рамках уже существующего event loop.
Т.е., грубо говоря, если бот при своём запуске делает что-то типа (код условный)

def run(self):
    asyncio.run(self.main())

то тебе нужно будет выполнить не bot.run(), а asyncio.create_task(bot.main()). Тогда тело бота не попытается создать новый event loop, а запустится в уже существующем, бок о бок с предыдущим ботом. И они смогут нормально взаимодействовать.

Но всё равно, ищи способ избавиться от двух ботов в одном скрипте. Это только источник проблем.

[KPoseidon]

Vindicar,
а вот по bot_func.main() не существует

дайте пистолет, я уже не выношу питон от особенности, даже в шарпе я адекватно это реализовал

[KPoseidon]

KPoseidon, Vindicar, ай, ща запихну ресолвер в этот метод

[KPoseidon]

Vindicar,
да бл, помогите, я грохнусь от питона

[Vindicar]

KPoseidon, ну а по мне так в шарпе вообще нет асинхронности. Есть тонкая обёртка над паттерном worker pool - которая, к тому же, справляется только с тривиальнейшими задачами. Холиварить будем?

В общем, не нравится - не ешь. Общий принцип я тебе рассказал, конкретику (как запустить бота в рамках существующего event loop) надо извлекать из документации на используемые библиотеки. Я ни с той, и с другой не работал, могу только проводить аналогии с тем же aoigram.

[KPoseidon]

Vindicar, крче, ты прав, не нравится - не ешь. я сдаюсь с этой "многопоточностью". Даже в единый loop не запихивается, ну и пусть не будет бот владеть сразу двумя АПИ от Телеги.