Как создать напоминание в телеграм боте? Напоминалка каждый месяц?

Question

[Давид Андросенко]

Помогите сделать бота, который каждый месяц будет присылать
сообщение напоминание каждому пользователю бота
То есть:
- напоминание каждый месяц
- всем пользователям бота

Answer 1

[Vindicar]

0. Ставишь aiogram и читаешь Quick start, чтобы понять, как в целом будет устроен бот.
1. Создаёшь и ведёшь базу пользователей бота, например, в sqlite3. Как её наполнять, это уже второй вопрос. Также может потребоваться отдельная таблица напомнинаний, но тебе виднее что за напоминания будут.
2. В боте создаёшь через asyncio.create_task() бесконечную задачу, которая
- проверяет время
- если сейчас подходящее время (скажем, полдень, 1е число месяца, плюс-минус 30 секунд), вызывает корутину уведомления пользователей,
- засыпает на минуту с помощью await asyncio.sleep() (ни в коем случае не time.sleep()).
3. Корутина уведомления пользователей должна извлекать из твоей базы уведомления, которые нужно отправить и id пользователей, которым эти уведомления нужно отправить (см. доки по sqlite3 как извлекать данные из БД запросом SELECT). Затем для каждого пользователя она должна отправить текст (см. доки по aiogram) и обработать возможное исключение (например, если пользователь заблокировал бота).
4. Может потребоваться пара обработчиков команд, чтобы добавлять/менять текст напоминаний.

Comments

[PinkPonySama]

У меня не получается через asyncio сделать бесконечную задачу. Он все равно выполняет либо main, либо задачу..
У меня бот сделан через WebHook на Flask если что.. Может быть проблема в этом?

[Vindicar]

PinkPonySama, я не очень хорошо знаком с вебхуками, так что помочь тут не могу.
Но бесконечную задачу сделать просто.

async def inifinite_task():
    while True:
        await do_something_useful() #выполняем один цикл работы
        await asyncio.sleep(60) #спим

Запускать её надо строго через asyncio.create_task(infinite_task()), а не через await.
Соответственно, у тебя будет функция вида

async def do_something_useful():
    pass # тут собственно один цикл работы

[PinkPonySama]

Vindicar, спасибо, я попробую

[PinkPonySama]

Vindicar, я честно не понимаю, что тут асинхронного. Код точно так же работает как и без asyncio

import asyncio
import time

a = 0
def do_something_useful():
    global a
    a += 1
    print(a)

s = 10000000
def do_something():
    global s
    s -= 1
    print(s)

def do_something1():
    name = input('\nНапиши пожалуйста: ')
    return name

def inifinite_task():
    while True:
        if do_something1() == 'да':
            print('Да')
            time.sleep(5)
            print('Спал 5 сек')
        else:
            print('Елсе')
            do_something_useful()
            do_something()
            time.sleep(10)
            print('Спал 10 сек')

print('Привет')
inifinite_task()
print('Пока')

Вот добавить сюда везде async и он будет точно так же работать…

[Vindicar]

PinkPonySama, ну если это единственный код в программе, то да, будет.
Но ведь тебе нужно было его подружить с телеграм-ботом, и я советовал через aiogram.

Асинхронный код весь исполняется в одном потоке. По сути, когда ты делаешь await, ты говоришь "выполни вот эту операцию, а пока она выполняется, посмотри, что ещё можно поделать. Как выполнится, вернёшься сюда". При этом тебе не приходится задумываться, что там у нас в очереди на выполнение, и куда нужно будет потом вернуться.
Это удобно для приложений, ориентированных на ввод-вывод, например, на сеть. Отправил данные на вывод, или ждёшь их на вводе - а пока это всё происходит, программа может заняться чем-то ещё.
Но в то же время, пока корутина (async функция) работает над чем-то кроме await операции, она не даст никакой другой корутине исполниться. Т.е. если пришли данные из сети, бот не сможет на них отреагировать, пока текущая корутина не уступит очередь.
Как следствие, длинные синхронные операции (вроде time.sleep()) подвешивают асинхронную программу только в путь.