芹菜不运行任务

Question

请帮助我了解我做错了什么。芹菜不运行我的任务。

Settings.py
CELERY_BROKER_URL = 'redis://localhost:6379'
CELERY_RESULT_BACKEND = 'redis://localhost:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TIMEZONE = TIME_ZONE

芹菜/芹菜.py

from __future__ import absolute_import
import os
from celery import Celery
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'proj.settings') 
app = Celery('proj')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()

初始化.py

from __future__ import absolute_import, unicode_literals
from celery import app as celery_app   
__all__ = ['celery_app']

法典

@shared_task
def generate(instance, sender, **kwargs):
for i in CK_PROGRAM_NAME:
program_kf = i[0]
ck = instance.dk*program_kf
program_name = i[1]
program_obj = Program.objects.get(name=program_name)
foodprogram_generator(instance, ck, program_kf, program_obj, sender, **kwargs)
return
@receiver(post_save, sender=LeadUser)
def leaduser_foodprogram_post_save(instance, sender, **kwargs):
generate.delay(instance, sender, **kwargs)
return

Worker 由： celery -a proj worker --loglevel=INFO

逻辑是： 创建client_object后，post_save信号开始leaduser_foodprogram_post_save，添加到队列 generate((

我可以看到结果，所以我认为它没有运行。 没有芹菜，一切都可以正常工作。

谢谢你的回答！

Answer 1

几件事： * 带有命名空间的config_from_object可能会从变量中删除它，因此您可能无法获得所需的配置， * 当您看到共享任务时，您需要确保从配置的 Celery 应用程序调用任务，因为使用共享任务的重点是在不同应用程序之间实际共享任务。看看芹菜应用程序对象上的"set_default"函数，只需在芹菜设置上调用它，您应该会看到差异。 无论如何，最好的检查方法是将rdb放在那里并检查芹菜应用程序，检查配置，如果未设置代理，那么我之前评论中解释的第二点应该会让你继续