mirror of
https://github.com/Balshgit/mosgortrans.git
synced 2025-09-11 13:00:40 +03:00
add cron timer
This commit is contained in:
parent
fb603536ed
commit
025d2193d6
17
main.py
17
main.py
@ -15,14 +15,14 @@ dp.middleware.setup(LoggingMiddleware())
|
|||||||
|
|
||||||
|
|
||||||
@dp.message_handler(commands=['chatid'])
|
@dp.message_handler(commands=['chatid'])
|
||||||
async def chat_id(message: types.Message):
|
async def chat_id(message: types.Message) -> SendMessage:
|
||||||
|
|
||||||
# or reply INTO webhook
|
# or reply INTO webhook
|
||||||
return SendMessage(message.chat.id, message.chat.id)
|
return SendMessage(message.chat.id, message.chat.id)
|
||||||
|
|
||||||
|
|
||||||
@dp.message_handler()
|
@dp.message_handler()
|
||||||
async def echo(message: types.Message):
|
async def echo(message: types.Message) -> SendMessage:
|
||||||
# Regular request
|
# Regular request
|
||||||
# await bot.send_message(message.chat.id, message.text)
|
# await bot.send_message(message.chat.id, message.text)
|
||||||
|
|
||||||
@ -40,29 +40,22 @@ async def send_message(chat_ids: list[int]):
|
|||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
def asyncio_schedule():
|
def asyncio_schedule() -> None:
|
||||||
"""
|
|
||||||
python version >= 3.4.0
|
|
||||||
:return:
|
|
||||||
"""
|
|
||||||
from apscheduler.schedulers.asyncio import AsyncIOScheduler
|
from apscheduler.schedulers.asyncio import AsyncIOScheduler
|
||||||
|
|
||||||
scheduler = AsyncIOScheduler()
|
scheduler = AsyncIOScheduler()
|
||||||
scheduler.add_job(send_message, kwargs={'chat_ids': [417070387, ]}, trigger='interval', seconds=30)
|
scheduler.add_job(send_message, kwargs={'chat_ids': [417070387, ]}, trigger='cron', hour=19, minute=11, second=42)
|
||||||
scheduler.start()
|
scheduler.start()
|
||||||
|
|
||||||
|
|
||||||
async def on_startup(dp) -> None:
|
async def on_startup(dp) -> None:
|
||||||
await bot.set_webhook(WEBHOOK_URL)
|
await bot.set_webhook(WEBHOOK_URL)
|
||||||
asyncio_schedule()
|
# asyncio_schedule()
|
||||||
# insert code here to run it after start
|
|
||||||
|
|
||||||
|
|
||||||
async def on_shutdown(dp):
|
async def on_shutdown(dp):
|
||||||
logger.warning('Shutting down..')
|
logger.warning('Shutting down..')
|
||||||
|
|
||||||
# insert code here to run it before shutdown
|
|
||||||
|
|
||||||
# Remove webhook (not acceptable in some cases)
|
# Remove webhook (not acceptable in some cases)
|
||||||
await bot.delete_webhook()
|
await bot.delete_webhook()
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user