【发布时间】:2022-01-06 15:27:58
【问题描述】:
我想在 django 应用中添加以下 celery 设置修改
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
Celery 使用如下执行
command: celery -A server worker -Ofair — without-gossip — without-mingle — without-heartbeat
我已将它们直接添加到 Django settings.py 但我不确定 Celery 是否真的选择了这些设置。所以我想知道是否有其他方法可以添加它们或有人有类似的经历?
我正在使用
celery==5.2.1
Django==3.2.5
【问题讨论】:
-
我的问题不是关于设置,我的问题是关于你把Django项目文件夹放在哪里
-
将它们放入您的项目
settings.py。例如worker_send_task_events将是CELERY_SEND_EVENTS=False -
这对我有用,谢谢!