Как реализовать систему изменения данных в базе данных?

Question

[Михаил Мунтян]

Пишу игрового бота на python + aiogram + sqlite. Хочу узнать как лучше реализовать одну систему, объяснить не могу, приведу пример:
Идет обработка сообщений от пользователя в одном скрипте, есть майнинг фермы у пользователя, которые раз в час должны добавлять пользователю криптовалюту и обновлять это все в базе данных.
Написать где то эту систему в одном скрипте прям так - не вариант, бот будет приостанавливаться, можно прибегнуть к мультипоточности, или к изучению асинхронности, а может есть вариант лучше, подскажите пожалуйста.

Comments

[Алан Гибизов]

Очень мало данных. Сколько клиентов, с которых собираются сведения? Каким путём собираются сведения? Сколько времени занимает получение сведений от одного клиента?

[Михаил Мунтян]

Алан Гибизов, Насчет сбора сведений это просто как пример и представления что делает бот и как все устроено, не нужно на этом заостряться

[Алан Гибизов]

Михаил Мунтян, ну если ты сам лучше знаешь - успехов…

[Михаил Мунтян]

Алан Гибизов, вопрос просто не вокруг этого крутиться, а вокруг реализации системы

[Vindicar]

Михаил Мунтян, какой совет по реализации ты ожидаешь услышать, не описывая никаких деталей?

[Михаил Мунтян]

Vindicar, возможно я не правильно поставил вопрос, а какие детали вы ожидаете услышать?

[AVKor]

Михаил Мунтян,

какие детали вы ожидаете услышать?

Это не имеет значения, поскольку всё равно не желаете их сообщать, когда просят.

[Vindicar]

Михаил Мунтян, ну например, так:
"У каждого пользователя есть ассоциированный счёт, раз в N минут этот счёт должен увеличиваться. Насколько - зависит от ряда факторов, т.е. прирост не постоянен. Как реализовать эту цикличность, не нарушая работу остального бота?"
Это если я верно понял.

[Михаил Мунтян]

Vindicar, Прирост счета с криптовалютой зависит от количества майнинг ферм пользователя, если добавить цикл то бот будет останавливаться и не отвечать на сообщения, это я уточнил

[Михаил Мунтян]

AVKor, Потому-что я не понимаю всю точность деталей, поэтому не могу сообщить точно

Answer 1

[Vindicar]

Ну во-первых, если ты используешь aiogram, то про многопоточность лучше забыть. Асинхронность с многопоточностью сочетается довольно плохо. Это возможно, но нетривиально, и новичкам лучше не связываться.
Во-вторых, дай угадаю - задержку в цикле фарминга реализуешь через time.sleep()? Если да, то конечно, цикл асинхронной программы останавливается на это время. Вот почему предусмотрена функция asyncio.sleep(), которая может приостановить выполнение отдельной корутины, не трогая остальных.
В-третьих, если тебе нужно выполнить корутину и дождаться результата её выполнения - используй оператор await. Если же тебе нужно запланировать выполнение корутины и идти дальше, не дожидаясь её результата (выполнение "как только, так сразу") - лучше использовать asyncio.get_event_loop().create_task().

Думаю, остальное сможешь додумать сам.

Comments

[Михаил Мунтян]

цикл этот я еще не реализовал, спрашиваю как лучше, корутина я так понимаю это что-то вроде доп программы которая сможет работать отдельно?

[Михаил Мунтян]

Вообщем реализовал что-то типо такого:

async def refreshator():
    while True:
        await asyncio.sleep(60)
        # Задача на обновление кол-во криптовалюты у пользователя

if __name__ == '__main__':
    asyncio.get_event_loop().create_task(refreshator())
    executor.start_polling(dp, skip_updates=True)

Я все верно сделал?

[Vindicar]

Михаил Мунтян, нет. Корутина - это всего-навсего async def функция. Вообще, посоветую сначала разобраться с работой асинхронной программы как таковой.

Если очень коротко:

1. Асинхронная программа состоит из отдельных длительных операций (чаще всего ввода вывода) и реакций на них. Результат операции обычно называется Future.
   
2. Цикл-реактор (loop) поочередно, в одном потоке, проверяет текущий список доступных Future. Если какая-то операция закончилась (её Future реализовалось), реактор выполняет код реакции на это Future.
   
3. Корутины (async) - это функции, которые умеют приостановить своё выполнение, пока не реализуется указанное Future. Реакция на это заключается в продолжении работы корутины.
   
4. Всякая корутина возвращает Future. Если вызвать корутину без await, получишь просто объект Future, который не зарегистрирован в реакторе, и сам код корутины не выполнится.
   
5. await - простой способ сказать "запланируй вот это Future к выполнению вместо меня, а я подожду".
   
6. Так как реактор работает в одном потоке, в один момент времени работает только одна корутина. Управление между корутинами передаётся строго при вызове await и при выходе из корутины.
   
7. При многопоточности другой поток может вклиниться вообще в любой момент, а тут другая корутина может вклиниться только пока ты делаешь await.
   
8. Так как реактор работает в одном потоке, длительная синхронная (без await) операция не даст другим корутинам выполняться!
   

[Михаил Мунтян]

Vindicar, спасибо за столь короткое и понятное введение. При запуске программы я получаю предупреждение: DeprecationWarning: There is no current event loop
asyncio.get_event_loop().create_task(refreshator())

В интернете пишут что нужно по другому получать цикл событий

[Vindicar]

Михаил Мунтян, ну можно и по-другому - например, явно в начале программы его создать через asyncio.new_event_loop(). Или, если ты уже внутри корутины, то можно вызвать asyncio.get_running_loop().
Так или иначе, тебе нужен экземпляр этого класса, чтобы вызвать create_task(). И в одном потоке может быть только один реактор.
К слову, create_task() вернёт объект Task, с которым тоже много интересного можно сделать. Имеет смысл это возвращаемое значение сохранить.