Как запустить асинхронную функцию параллельно теллеграм боту?

Question

[Herben]

Есть асинхронный телеграм бот на pyTelegramBotAPI библиотеке, бот отвечает только когда пользователь пишет - например, пользователь пишет "погода" и он сразу же получает прогноз погоды. Я решил добавить авто-проверку погоды, чтобы бот, сам обнаружив низкую температуру, сообщил об этом пользователю. Вроде легко, думал я...

Я пробовал много способов, как это реализовать... Тупо 2 скрипт запустить, но телеграм выдаёт ошибку, что сессия уже используется 1 скриптом; потом сделать функцию (позаимствовал решение тут), которую пользователь запускал вручную в боте - await weather_check(), но она дублировалась, и переписка превращалась в спам-месиво.

И наконец, я просто запустил эту функцию через asyncio.run всё получилось, думал я - бот автоматически обо всём пишет. Но из-за этого, любые команды или сообщения он игнорит. Что я делаю не так или как реализовать это?

async def weather_check():
    while True:
        # Тело функции
        await asyncio.sleep(5) # Ожидание перед повторной проверкой

asyncio.run(weather_check())

Эта часть зацикливала функцию для варианта, где пользователь сам её вызывает. Почему она изначально по запуску скрипта этого не делала, я не знаю.

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.create_task(weather_check())

Простите, если тупой вопрос
За ранее спасибо

Comments

[Anonymous Penguin]

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

Answer 1

[Vindicar]

asyncio.create_task()

Comments

[Herben]

:(

Traceback (most recent call last):
  File "D:\Бот\main.py", line 490, in <module>
    asyncio.create_task(weather_check)
  File "D:\Users\User\AppData\Local\Programs\Python\Python39\lib\asyncio\tasks.py", line 360, in create_task
    loop = events.get_running_loop()
RuntimeError: no running event loop

[Vindicar]

Herben, у бота есть реакция на событие "бот запущен"? Вот там и запускай.

[Herben]

Vindicar, не понял, что ты подразумеваешь под этим? Библиотека telebot проверяет подходят ли отправленные ей сообщения под критерии, если нет, то ничего не происходит

@bot.message_handler(commands=['start'])
async def send_welcome(message):
    asyncio.create_task(weather_check) #Как я понял, ты имел тут?
    await bot.send_message(message.chat.id, 'Меню: ', reply_markup=menu)

и я попробовал вписать твоё решение, но уже в этом случае ничего не произошло

[Vindicar]

Herben, нет, я имею ввиду событие "бот подключен к сети". До того, как было получено первое сообщение от пользователя, но после того, как был запущен рабочий цикл asyncio.

Если такого события нет, то можно попробовать иначе.

import asyncio

async def main():
    # к этом момент рабочий цикл уже запущен, так как он и выполняет main()
    asyncio.create_task(.....)
    await bot.polling()

if __name__ == '__main__':
    asyncio.run(main())

[Herben]

Vindicar, спасибо, но почему-то авто-проверка всё ещё не работает, попросту не запускается, вызвал для проверки print в той функции, но консоль пуста

async def weather_check():
    print('123')
    #Остальные команды

async def main():
    bot.add_custom_filter(asyncio_filters.StateFilter(bot))
    await bot.polling(skip_pending=True)
    asyncio.create_task(weather_check)

if __name__ == '__main__':
    asyncio.run(main())

Поменять местами поллинг и функцию тоже пробовал - вызывает ошибку сессии

[Vindicar]

Herben, ну так нужно головой подумать. Ну или хотя бы сначала попробовать как у меня в примере.
Как по твоему, как быстро выполнится bot.polling()?

Ответ

bot.polling() будет выполняться, пока работает бот. Так как вы вызываем bot.polling() через оператор await, выполнение main() не продолжится (а значит, create_task() не выполнится), пока бот не завершит работу.

Найди уже какой-нибудь материал по асинхронному программированию и освой его, а потом бросайся писать ботов.

[Herben]

Vindicar, я await написал потому что пытался исправить эту ошибку

#Это уже без await
D:\Бот\main.py:490: RuntimeWarning: coroutine 'AsyncTeleBot.polling' was never awaited
  bot.polling(skip_pending=True)
RuntimeWarning: Enable tracemalloc to get the object allocation traceback
123 #Функция weather_check запустилась, но скрипт сразу же завершился

В общем спустя кучи попыток исправить ошибку через run untill и run forever я просто поменял местами weather_check и кинул поллинг в await и это сработало, невероятно огромное спасибо тебе!

Итоговый вариант, который работает (хоть и почему-то вызывает unclosed client session ошибку, главное работает :D)

async def main():
    bot.add_custom_filter(asyncio_filters.StateFilter(bot))
    asyncio.create_task(ad_check())
    await bot.polling(skip_pending=True)

if __name__ == '__main__':
    asyncio.run(main())