首页 文章

Django芹菜 Worker 没有收到任务

提问于
浏览 次
0

每当我运行芹菜 Worker 时，我都会收到警告

./manage.py celery worker -l info --concurrency=8

enter image description here

如果我被忽略这个警告，那么我的芹菜 Worker 没有收到芹菜打败任务

在googled之后我也改变了 Worker 的名字，但是这次我没有收到警告但是芹菜 Worker 仍然没有收到芹菜打败预定的任务

我检查了芹菜捶打日志，芹菜按时按时安排任务 .

我还检查了芹菜花及其展示的两名 Worker ，第一名 Worker 正在接收任务而不是执行它，如何将所有任务发送给第二名 Worker ？或者我如何禁用第一个海带 Worker ，什么是我失踪的djagno-celery设置？

我的django settings.py

RABBITMQ_USERNAME = "guest"
RABBITMQ_PASSWORD = "guest"
BROKER_URL = 'amqp://%s:%s@localhost:5672//' % (RABBITMQ_USERNAME, 
RABBITMQ_PASSWORD)
CELERY_DEFAULT_QUEUE = 'default'
CELERY_DEFAULT_EXCHANGE = 'default'
CELERY_DEFAULT_ROUTING_KEY = 'default'
CELERY_IGNORE_RESULT = True
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
celery_enable_utc=True
import djcelery
djcelery.setup_loader()
python django rabbitmq celery django-celery

1 回答

  • 1

    您只启用了工作人员 . 对于要执行的任务，您必须在 your_task.delay () 函数的帮助下调用该任务 . 例如，打开另一个终端，输入您的项目，然后运行 python manage.py shell 命令 . 当你进入你的项目Django的shell时，导入你的任务并运行命令 your_task.delay () 在下面的链接中，有一个与rabbitmq经纪人的芹菜代码示例，我建议你研究它：https://github.com/celery/celery/tree/master/examples/django

    回复于

相关问题