UPD:
Я пересмотрел своё мнение и код ниже довольно плох, не используйте его. Рекомендую обратить внимание на модуль shedule
.
Я решил использовать
threading.Timer
Этот класс создаёт отдельный поток (что не мешает работе программы) и через определённый промежуток времени запускает некоторую функцию.
Но в нашем случае этого недостаточно. Наша программа должна:
- Вычислить промежуток времени до первого срабатывания (в примере это 12:00)
- Запустить функцию через найденный промежуток времени
- После завершения работы функции запустить новый таймер с новым интервалом.
Для этих целей я создал класс-обёртку CustomTimer
. Он дополняет стандартный Timer
нашим функционалом:
UPD:
from vk_api import VkApi
from threading import Timer
from datetime import datetime
from datetime import timedelta
from random import randint
def send_msg(vk, chat_id, message):
random_id = randint(1, 2147483647)
vk.messages.send(
random_id=random_id,
chat_id=chat_id,
message=message
)
def get_delta(hour=0, minute=0, second=0, microsecond=0):
now = datetime.now()
run_at = now.replace(hour=hour, minute=minute, second=second, microsecond=microsecond)
if run_at < now:
run_at += timedelta(days=1)
return (run_at - now).total_seconds()
class CustomTimer:
def __init__(self, *args, delta=0.0, function=send_msg, interval=86400.0, **kwargs):
self.delta = delta
self.interval = interval
self.function = function
self.args = args
self.kwargs = kwargs
self.timer = None
def callback(self):
self.function(*self.args, **self.kwargs)
self.normal_start()
def normal_start(self):
self.timer = Timer(self.interval, self.callback)
self.timer.start()
def start(self):
self.timer = Timer(self.delta, self.callback)
self.timer.start()
if __name__ == '__main__':
vkSession = VkApi(token=[Ваш токен])
vk = vkSession.get_api()
delta = get_delta(21, 51)
t = CustomTimer(vk, [id Вашей беседы], 'Раз в 5 секунд', delta=delta, interval=5)
t.start()
delta = get_delta(21, 51)
t = CustomTimer(vk, [id Вашей беседы], 'Раз в 3 секунды', delta=delta, interval=3)
t.start()
delta = get_delta(21, 51)
t = CustomTimer(vk, [id Вашей беседы], 'Раз в 10 секунд', delta=delta, interval=10)
t.start()
Чтобы воспользоваться классом нужно:
- Передать все аргументы, которые ждёт потенциальная функция (в примере это
send_msg
). Я передаю объект для доступа к api, id беседы и нужное сообщение.
- Указать время в секундах до первого запуска. Для удобства я создал функцию
get_delta
. Параметры этой функции определены по-умолчанию нулем, так что указывать время довольно удобно (в примере я запускаю все потоки в 21:51).
- Указать интервал. Это тот промежуток времени, через который будет вызываться функция. Например, если вы хотите запускать её раз в день, то укажите 86400 и т. д.
- Указать функцию для запуска.
Многие параметрам я дал значение по умолчанию (например, функции), так как в большинстве случаев Вы будете использовать одни и те же значения.
listen()
цикле, я прав? В таком случае она выполняется только когда приходит очередное событие. Вам правильно рекомендовали потоки, необходимо вынести функцию за цикл. Я как раз хотел это реализовать. Если у меня получится, отвечу Вам подробнее.