Каждый день бот в 20:00 должен проводить итерацию базы данных пользователей с платной подпиской и удалять тех у кого подписка истекла. Всё вроде бы сделал, но наткнулся на такую проблему: чтобы модуль shedule
( модуль отвечающий за выполнение функции в определённое время ) работал, должен быть активен цикл:
while True:
schedule.run_pending()
sleep(1)
так вот данный цикл блокирует все остальные команды. Позже я попытался переписать цикл асинхронным способом:
async def schedule_run():
while True:
schedule.run_pending()
sleep(1)
if __name__ == '__main__':
asyncio.get_event_loop().run_until_complete(schedule_run())
но так как, весь бот написан синхронно, это не помогло и цикл всё равно блокирует остальной функционал бота. Переписать бота под асинхронную модель мягко говоря будет трудно, так как он состоит из 2100 строк кода. Вообщем мне нужно узнать, как сделать так, чтобы цикл выполнялся параллельно от всех остальных функций в боте.
Вот данный отрезок кода:
def db_check_pro_user(user_id):
row, user_id, sub_type, date_buy, date_stop = db_get_pro_user(user_id)
today = datetime.date.today()
if today == date_stop:
if sub_type == 1:
bot.send_message(user_id, text="Тут текст", parse_mode="Markdown")
elif sub_type == 2:
bot.send_message(user_id, text="Тут текст", parse_mode="Markdown")
db_del_pro_user(user_id)
def check_start():
today = datetime.date.today()
users = db_get_pro_users()
for user in users:
user_id = user[0]
db_check_pro_user(user_id)
schedule.every().day.at("20:00").do(check_start)
while True:
schedule.run_pending()
sleep(1)
Бот написан на библиотеке telebot.