带有 Rabbit MQ 虚拟主机的芹菜不接受 Django 中 app.tasks.py 的任务

Question

需要帮助！

PS：我已经使用这个 link

创建了虚拟 Hosts

Celery and Vhosts

settings.py

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

celery.py

进口os 从芹菜进口芹菜

从 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。注意：我在设置后都启动了，但似乎不起作用

Worker terminal Screenshot

shell instance firing the request

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

Answer 1

我可能要迟到了！所以解决这个问题的方法是我错过了要添加到基础 project init.py 中与芹菜有关的设置。添加详细信息解决了我的问题！

带有 Rabbit MQ 虚拟主机的芹菜不接受 Django 中 app.tasks.py 的任务

Celery with Rabbit MQ Virtual Host not accepting tasks from app.tasks.py in Django

python

django

rabbitmq

vhosts

celery

Celery and Vhosts

settings.py

celery.py

app1.tasks.py