Проверка бд каждую минуту без блокировки бота aiogram?

Question

[Любитель поиграть в самолёты]

Привет, мне надо пробежатьсь по бд и если есть уведомления которые надо отправить - надо их отправить. При этом что бы сам бот тоже могу работать. Я нашёл вот такой код, но бот блокируется и не реагирует на команды.

# импорты
async def check_time():
    utc = datetime.now(timezone.utc)
    print(utc)
    # код отправки
    await asyncio.sleep(60)
    await check_time()

loop = asyncio.get_event_loop()
# https://qna.habr.com/answer?answer_id=1656961#answers_list_answer
asyncio.ensure_future(check_time())

loop.run_forever()

Aiogram 2.20

Как мне выполнить мою задачу?

Comments

[deadghoul]

Скачайте aioschedule

import aioschedule
import asyncio

async def check_time():
    utc = datetime.now(timezone.utc)
    print(utc)

async def scheduler():
    aioschedule.every(60).seconds.do(check_time)
    while True:
        await aioschedule.run_pending()
        await asyncio.sleep(60)

loop = asyncio.get_event_loop()

loop.create_task(scheduler)

loop.run_forever()

Если объёмы рассылки большие то бот без мультипроцессинга будет умирать пока отправляет все сообщения, но можно сделать сон небольшой после отправки каждого сообщения и он будет реагировать на команды

Answer 1

[Niksssan]

Подобный вопрос

import asyncio

from aiogram import Bot, types
from aiogram.dispatcher import Dispatcher
from aiogram.utils import executor

DELAY = 7200

bot = Bot(token='BOT TOKEN HERE')
dp = Dispatcher(bot)

@dp.message_handler(commands=['start', 'help'])
async def send_welcome(message: types.Message):
    await message.reply("Hi!\nI'm EchoBot!\nPowered by aiogram.")


async def update_price():
    ...


def repeat(coro, loop):
    asyncio.ensure_future(coro(), loop=loop)
    loop.call_later(DELAY, repeat, coro, loop)


if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.call_later(DELAY, repeat, update_price, loop)
    executor.start_polling(dp, loop=loop)

Answer 2

[Алексей Черемисин]

я немного не понял рекурсии: в функции check_time вызываем сами себя? Кажется (покопавшись в мозгах своих), так делать не очень хорошо.
И вместо asyncio.ensure_future(check_time()) пишем loop.ensure_future(check_time())
Сделайте еще одну функцию, которая будет запускать в бесконечном цикле последовательно check_time и asyncio.sleep

import asyncio
from datetime import datetime

async def check_time():
    utc = datetime.now()
    print(utc)

async def checker(timeout):
    while(True):
        await asyncio.sleep(timeout)
        await check_time()

loop = asyncio.get_event_loop()
task = loop.create_task(checker(60))
loop.run_forever()

ЗЫю пришлось открыть редактор... блин...

Comments

[Любитель поиграть в самолёты]

Алексей Черемисин, у меня бот вообще не запускается

[Любитель поиграть в самолёты]

Ошибок нет, просто зависает, не печатает ничего и на команды не реагирует

[Алексей Черемисин]

Python Новичок, я же привел полностью рабочий код!