Как добавить настройки celery в django?
Я хотел бы добавить следующую модификацию настроек celery в приложение django
worker_send_task_event = False
task_ignore_result = True
task_acks_late = True
worker_prefetch_multiplier = 10
В моем celery.py, я получил
import os
from celery import Celery
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'server.settings')
app = Celery('server')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()
И мой tasks.py
@shared_task
def some_task():
pass
Селери выполняется с помощью следующего
command: celery -A server worker -Ofair — without-gossip — without-mingle — without-heartbeat
Я добавил их непосредственно в Django settings.py
, но я не уверен, что Celery действительно подхватил эти настройки. Поэтому мне интересно, есть ли другой способ добавить их или у кого-то есть подобный опыт?
Я использую
celery==5.2.1
Django==3.2.5
Вам необходимо использовать именование в верхнем регистре, как описано здесь
Пример:
Используйте CELERYD_SEND_EVENTS = True
вместо worker_send_task_event = False