Celery with Rabbit MQ虚拟主机不接受Django中app.tasks.py的任务

Question

需要帮助！

PS：我已经使用这个链接创建了虚拟主机

芹菜和Vhosts

设置.py

CELERY_BROKER_URL = 'amqp://flash:flash_education@localhost:5672/flash'

---

celery.py

导入操作系统从芹菜进口芹菜

从django.conf导入设置

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

---

app1.tasks.py

import datetime
import json
from celery import shared_task
@shared_task(name="ping")
def ping():
print("pong")

---

附加来自我的终端的图像，其中一个工作实例另一个是我发射任务的炮弹。注意：我启动后设置和所有，但它似乎不工作

工作终端屏幕截图

shell实例激发请求

RabbitMQ，Celery==4.4.2 Django==3.0.4请帮忙！

Answer 1

我可能迟到了！因此，解决方案是我错过了要添加到基础项目init.py中的与芹菜有关的设置。添加详细信息解决了我的问题！