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

Question

[creat1vv]

В чем суть вопроса. У меня есть команда /settime @user time

К примеру я пишу /settime anton#2834 17 потом /settime egor#5234 13
17 и 13 записалось в базу данных для антона и егора, и мне нужно чтобы бот каждый день бот присылал во время антона сообщение для антона, а во время егора сообщение для егора.

Как я могу это реализовать?

Answer 1

[fenrir]

Наиболее простой способ без кронов использовать имеющийся в discord.ext модуль tasks.

from discord.ext import tasks

@bot.event
async def on_ready():
    test_task.start()

@tasks.loop(minutes=1.0)
async def test_task():
    #твой код

Создаешь словарь, куда при запуске бота, при обновлении в бд в команде и по таймеру обновляются напоминания скажем за сегодняшний день, а в минутном loopе проверяешь не наступило ли время и если наступило вызываешь нужный код.

Comments

[creat1vv]

Получаю ошибку, понять не могу с чем связана

code:

@tasks.loop(minutes=1) 
    async def main(self):
        users = self.db.get_data2
        if users['workdate'] != 0:
            time1 = int(users['workdate'] + timedelta(minutes=-10))
            now = datetime.now()
            if now == time1:
                time2 = int(time1.timestamp())
                channel2 = self.bot.get_channel(987413413900718170)
                await channel2.send(f"<@{users['member_id']}>, твоя смена будет <t:{time2}:R>")
                time3 = int(users['workdate'] + timedelta(days=1))
                await self.db.update_member({"member_id": users['member_id']}, {"$set": {"workdate": time3}})

Ошибка:

Unhandled exception in internal background task 'main'.
Traceback (most recent call last):
  File "C:\python\lib\site-packages\disnake\ext\tasks\__init__.py", line 157, in _loop
    await self.coro(*args, **kwargs)
  File "C:\Users\Creativchak\Desktop\HarukoBot\cogs\tasks.py", line 29, in main
    if users['workdate'] != 0:
TypeError: 'method' object is not subscriptable

[fenrir]

creat1vv, после users = self.db.get_data2 сделайте print или точку остановки.
Я конечно не ясновидящий чтобы отлаживать код, который не вижу, но судя по тексту ошибки self.db.get_data2 ничего не вернул. Да и вообще странный код, get_data вероятно функция, а значит должно быть self.db.get_data2()

[creat1vv]

fenrir, поставил () после get_data2

Теперь
TypeError: 'coroutine' object is not subscriptable

[fenrir]

creat1vv, повторю, я не знаю что за объект self.db.get_data2 и я не знаю что лежит в users.
Строку с ошибкой Вам указал, дальше разбирайтесь.

Answer 2

[Deerenaros]

Уф..

Comments

[creat1vv]

И через таски делать?

[Deerenaros]

creat1vv Ага.

Можно хоть тред делать с бесконечным while, маленькими sleep и постоянными проверками. В schedule эта логика примерно так и реализована.

Ещё можно базу грепать каждую секунду на предмет "вот сейчас будет что-нибудь?". Этот вариант чуть лучше в плане стабильности (можно рестартовать машину без опасений - само восстановится), но чуть менее точный и с повышенной нагрузкой на базу.

В реальных проектах используются гибридные варианты.

Или man crontab

[creat1vv]

Deerenaros, если делать через таски, как именно сделать разное время для разных пользователей? Таск не передаёт ведь member? А я должен получить время из бд

[Totem]

Также есть aiocron, если речь идет об асинхронном программировании

[Deerenaros]

creat1vv, можешь использовать глобальные переменные, или внутри таски грепать базу, или создавать таску как было получено сообщение, то есть сразу в контексте, да хоть dbless если не так критичны пропуски и ошибки. Не понимаю, в чём, собственно, проблема? Попробуй, не получится - тогда пиши. Или вопрос подробнее писать надо.

[creat1vv]

Deerenaros, привет. Никак не могу получить из базы данных в тасках пользователей и их даты.

Сам код:

@tasks.loop(minutes=1) 
    async def main(self):
        users = self.db.get_data2
        if users['workdate'] != 0:
            time1 = int(users['workdate'] + timedelta(minutes=-10))
            now = datetime.now()
            if now == time1:
                time2 = int(time1.timestamp())
                channel2 = self.bot.get_channel(987413413900718170)
                await channel2.send(f"<@{users['member_id']}>, твоя смена будет <t:{time2}:R>")
                time3 = int(users['workdate'] + timedelta(days=1))
                await self.db.update_member({"member_id": users['member_id']}, {"$set": {"workdate": time3}})

Вылазит ошибка:

Unhandled exception in internal background task 'main'.
Traceback (most recent call last):
  File "C:\python\lib\site-packages\disnake\ext\tasks\__init__.py", line 157, in _loop
    await self.coro(*args, **kwargs)
  File "C:\Users\Creativchak\Desktop\HarukoBot\cogs\tasks.py", line 29, in main
    if users['workdate'] != 0:
TypeError: 'method' object is not subscriptable