Почему celery не отправляет письмо в указанное время?

Question

[marselabdullin]

Сделал отправку почты за час до наступления события(модель в django), в shell проверил работает проверка даты, но celery не отправляет ни почту, ни принт в консоль. Есть предчуствие , что что-то не дописал, так как не работал с запланированными действиями еще. но идей нет. Я нигде не подключал shedule.py возомжно в этом причина

tasks.py:

@shared_task
def event_send_mail():
    events = Event.objects.filter(event_date=datetime.now() + timedelta(minutes=60))
    for event in events:
        print("Событие")
        send_mail("Напоминание о событии", str(event.title) + "начинаеся через час",
                                     "[e-mail]", [event.user.email, ])

shedule.py:

CELERYBEAT_SCHEDULE = {
    'send_mail': {
        'task': 'send_mail',
        'schedule': timedelta(minutes=1),
    },
}

Answer 1

[Дмитрий]

celery достаточно громоздкий для таких простых задач. Я бы советовал вам использовать python rq. Для выполнения вашей задачи, нужно будет настроить окружение Django внутри задачи, чтобы загрузить нужные модели. Далее просто забрать cron. Это самое простое, и помогает избавиться от сложного celery

Comments

[marselabdullin]

сделал решение с помощью него и действительно оказалось просто, но обнаружил, что работает он только на линуксе. Пробую установить vargant(vm), как посоветовали, но все таки хотелось бы увидеть решение так же для celery

Answer 2

[szelga]

проверьте, запустили ли вы отдельный процесс для celery-beats: https://docs.celeryproject.org/en/stable/userguide...

Comments

[marselabdullin]

Такой ответ выдает

[marselabdullin]

Смотрел список активных тасков, и он пустой хотя функция должна вызываться. Он сам таск не запускает , так как я сделал там принт и он не выводится

[szelga]

версия celery какая?

[szelga]

и ещё в поле task должно быть указание на корректный "путь" к функции, что-то вроде app.tasks.event_send_mail.

[marselabdullin]

celery==4.4.6.
Исправил конфиги как сказано здесь, но ничего не меняется, единственное у меня стоит timedelta а там крон может в этом дело
https://medium.com/@yedjoe/celery-4-periodic-task-...

[szelga]

попробуйте это всё CELERYBEAT_SCHEDULE = { ... } запихать в settings.py для начала.

[marselabdullin]

я все это сделал как там написано, ничего не происходит. Там еще shared_task на task заменили и крон пробовал установил селери в инит

[GlamorousCar]

marselabdullin, удалось решить?

[marselabdullin]

GlamorousCar, удалось вроде декоратор другой нужно было использовать