Не работает функция отправки сообщения aiogram по расписанию?

Question

[username]

почему не заходит в функцию планировщика? Сервер запускается, вебхук слушает, на команды реагирует. Но не могу послать именно сообщения библиотекой aiogram, хотя вывел в отдельный поток. Помогите, пожалуйта, разобраться. Заранее спасибо!

from aiogram import Bot, Dispatcher, types
from aiohttp import web
import asyncio
from threading import Thread
from apscheduler.schedulers.asyncio import AsyncIOScheduler

TOKEN = 'токен из телерам'
app = web.Application()
bot = Bot(TOKEN)
dp = Dispatcher(bot)

def test():
    print('here?')
    asyncio.run(bot.send_message(chat_id, 'test'))

def start_scheduler():
    scheduler = AsyncIOScheduler()
    asyncio.set_event_loop(asyncio.new_event_loop())
    scheduler.add_job(test, 'interval', seconds=2)
    scheduler.start()

async def on_startup(app):
    await bot.set_webhook('https://' + WEBHOOK_URL + WEBHOOK_URL_PATH, drop_pending_updates=True)


async def on_shutdown(app):
    await bot.delete_webhook()

if __name__ == '__main__':
    Bot.set_current(bot)
    app.on_shutdown.append(on_shutdown)
    app.on_startup.append(on_startup)
    scheduler_thread = Thread(target=start_scheduler)
    scheduler_thread.start()
    web.run_app(app, host=WEBHOOK_IP, port=int(WEBHOOK_PORT))

Comments

[Vindicar]

Мешать потоки с asyncio - плохая идея.
Да и зачем тебе поток? start() у AsyncIOScheduler - это неблокирующий метод.

[Модератор]

Не надо ставить как можно больше тэгов. Лучше оставить один, но конкретный, с которым проблема.
См.п.3.1 Регламента. Также обратите внимание на п.3.4

[username]

Vindicar, Да, вы правы, start() у AsyncIOSchedule не блокирует выполнение, но и не запускет планировщик. Убрал потоки, но все-равно scheduler не выполняется. Как понять что именно мещает выполнению кода?

[akudja238]

username, покажи обновленный вариант.
В моем случае вот в таком виде scheduler работает

import os
import asyncio

from aiogram import Bot, Dispatcher
from aiogram.fsm.storage.memory import MemoryStorage
from apscheduler.schedulers.asyncio import AsyncIOScheduler

from dotenv import load_dotenv
from logger import logger
from db import DataBase

from dialogs import first_dialog, add_rom_dialog, delete_rom_dialog
from handlers import common, get_data, delete_data
from tasks import send_notifications

load_dotenv()

TOKEN = os.getenv('TOKEN')

db = DataBase()


async def main():
    bot = Bot(token=TOKEN)
    dp = Dispatcher(storage=MemoryStorage())
    dp.include_routers(
        common.router,
        get_data.router,
        delete_data.router,
        first_dialog.router,
        add_rom_dialog.router,
        delete_rom_dialog.router,
    )
    scheduler = AsyncIOScheduler()
    scheduler.add_job(send_notifications, trigger='interval', days=1, kwargs={'bot': bot})
    scheduler.start()

    logger.info('Bot is running')
    await dp.start_polling(bot, allowed_updates=dp.resolve_used_update_types())

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

[username]

akudja238, была моя оплошность, я вызывал не async функции :) А так все работает, спасибо