Как сделать так, чтобы отправлялось сообщение от телеграм-бота в определенное время?

Question

[serhiops]

Использую aiogram. Нужно сделать так, чтобы сообщение отправлялось в определенное время каждый день. Как это можно реализовать?

Comments

[Musickk]

Dr. Bacon, д я уже похожий вопрос отметил)

Answer 1

[Vindicar]

aioschedule

Answer 2

[Kai41k]

Это делается так

import time
from datetime import datetime

time = datetime(datetime.now().year, datetime.now().month, datetime.now().day, datetime.now().hour, datetime.now().minute)

if time.hour == <час> and time.minute == <минут>:
	await bot.send_message(message.from_user.id, f'Время: {time.hour}:{time.minute}')
else:
	await bot.send_message(message.from_user.id, time)

Где в <час> и <минут> нужно указать час и минуту, при котором, бот будет отправлять сообщение

Comments

[serhiops]

@dp.message_handler()
async def timese (message:types.Message):
times = datetime(datetime.now().year, datetime.now().month, datetime.now().day, datetime.now().hour, datetime.now().minute)
if times.hour == 12 and times.minute == 44:
await bot.send_message(message.from_user.id, f'Время: {times.hour}:{times.minute}')
else:
await bot.send_message(message.from_user.id, times)
так?

[shurshur]

serhiops, нет. При таком решении сообщение отправится только если в пользователь напишет ровно в 12:44 боту.

[serhiops]

shurshur, а каким образом можно реализовать нужный мне вариант?

[shurshur]

serhiops, в обработчике команды ничего не надо отправлять. В нём нужно только добавить задание в очередь с указанием времени. Например (но необязательно!), очередь можно хранить в таблице в базе, для чего сделаем таблицу message_queue с такими полями:

id - главный ключ;
send_time - время отправки;
recipient_id - id получателся;
message - текст сообщения;
status - статус сообщений, пусть имеет значения awaiting или sent.

Вместо отправки добавим сообщение в таблицу в статусе awating (ожидает).

Регулярно пусть выполняется выгрузка из базы сообщений, которые ещё awaitng, но время уже наступило:

SELECT id,send_time,recipient_id,message FROM message_queue WHERE status='awaiting' AND send_time<NOW();

Извлечённые сообщения отправляем. Каждое переводим в статус sent, чтобы не отправить второй раз:

UPDATE message_queue SET status='sent' WHERE id=<id сообщения в очереди>;

Остаётся вопрос: как организовать регулярную выборку сообщений из очереди? Можно сделать по-разному:

1. Сделать отдельный тред в скрипте, который будет отслеживать очередь, перемежая это вызовами sleep. Или вместо треда таску в asyncio (если уже используется aiogram, то это более чем разумно).

2. Обрабатывать очеред в отдельном постоянно запущенном скрипте, либо запускать скрипт из cron каждую минуту.

Первый способ хорош тем, что всё в одном скрипте и потенциально очередь можно хранить не в базе, не в файле, не в брокере очереди типа rabbitmq, а прямо в переменной в скрипте. Правда, при этом в случае падения скрипта все запланированные задания на отправку будут потеряны. Второй хорош тем, что проблемы/тормоза скрипта отправке не будут вредить основному коду бота.

И, наконец, есть ещё один способ, при котором можно избежать организации очереди своими силами - использовать модули schedule/aioschedule (синхронный и асинхронный соответственно). Фактически, они берут на себя сохранение задания в очереди и вызов запрошенной функции в нужное время. Именно это тут посоветовали в первом ответе.

Answer 3

[tarasik016]

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

bot = Bot(token=os.getenv('TOKEN'))
dp = Dispatcher(bot)

@dp.message_handler(commands=['start'])
async def command_start(message : types.Message):
	while True:
		await asyncio.sleep(1)
		now = datetime.now()
		current_time = now.strftime("%H:%M:%S")
		if current_time == '23:44:01': 
			await bot.send_message(message.chat.id, f'"Это сообщение отправлено в {current_time}"')

@dp.message_handler(commands=['mess'])
async def command(message : types.Message):
	await bot.send_message(message.chat.id, 'Для полной картины, асинхронность работает')

executor.start_polling(dp, skip_updates=True)

Comments

[serhiops]

это ужасный код. Я отметил ответом правильное решение.

на момент компиляции

убило

[tarasik016]

Как это должно выглядеть правильно, покажите пожалуйста.

[serhiops]

tarasik016, у меня не осталось исхожников, но вот, вроде, что-то неплохое. Странно, что ты это раньше не нашел link

[tarasik016]

Действительно странно что не нашел, плохо гуглил. Спасибо