Как в периодических задачах Celery использовать django orm?

Question

[NyxDeveloper]

У меня есть приложение на django, в котором нужно раз в неделю создавать отчет из информации в базе данных. Я настроил celery, в логах пишется, что задача выполняется, однако в базе данных ничего не меняется.
Я попробовал сделать тестовую задачку и проверить, будет ли меняться вообще хоть что-то.

# файл app/tasks.py
from vkmt_api.celery import app
from authentication.models import User

@app.task
def test_task():
    user = User.objects.get(username="test")
    user.first_name = user.first_name + "1"
    user.save()

# файл mainapp/celery.py

import os
from celery import Celery
from celery.schedules import crontab

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'my_project.settings')
app = Celery('my_project')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()

app.conf.beat_schedule = {
    "test-task": {
        "task": "reports.tasks.test_task",
        "schedule": crontab(minute="*/1")
    }
}

# настройки в файле settings.py

REDIS_HOST = '0.0.0.0'
REDIS_PORT = '6379'

CELERY_BROKER_URL = 'redis://' + REDIS_HOST + ':' + REDIS_PORT + '/0'
CELERY_BROKER_TRANSPORT_OPTION = {'visibility_timeout': 3600}
CELERY_RESULT_BACKEND = 'redis://' + REDIS_HOST + ':' + REDIS_PORT + '/0'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'

Исходя из вышеприведенного кода, следует максимально простая логика, раз в минуту должна выполняться функция test_task() и пользователю test к имени должна добавляться единица. То есть, через 5 минут после запуска приложения у пользователя test имя будет "name11111".
Скажите, что я делаю не так?

Comments

[Roman K]

Как запускаешь celery beat?

[NyxDeveloper]

запускаю весь сервер через скрипт:

import os

sudo_password = '...'

commands = [
    'killall -9 uwsgi',
    'killall -9 celery',
    '/etc/init.d/nginx restart',
    '/etc/init.d/redis restart',
    'nohup uwsgi --socket :8002 --wsgi-file my_project/wsgi.py --chmod-socket=666 &',
    'nohup celery -A my_project beat -l INFO &'
]


def main():
    for command in commands:
        os.system('echo %s|sudo %s' % (sudo_password, command))
        # os.popen("sudo %s" % command, 'w').write(sudo_password)
    print('server started')


if __name__ == '__main__':
    main()

[Roman K]

NyxDeveloper, кек, выброси этот способ запуска и возьми докер. Ещё и через sudo запускаешь.

И покажи логи celery и ошибки таска.

[NyxDeveloper]

в том и дело, ошибок нет!
вот лог
[2021-08-31 12:32:00,016: INFO/MainProcess] Scheduler: Sending due task test-task (reports.tasks.test_task)

[Roman K]

NyxDeveloper, ну тогда дебаговые принты

[NyxDeveloper]

так а как их делать?))
задачка же в отдельном треде создается)

[alternativshik]

Не вижу, где запущен селери? Таска выполняется вообще?

Answer 1

[NyxDeveloper]

В общем, при таком подходе нужно не через beat запускать, а через worker. Что, на самом деле, странно, учитывае, что для периодических задач по расписанию официальная документация говорит использовать именно beat.
https://docs.celeryproject.org/en/stable/django/fi...