Сельдерей с виртуальным хостом Rabbit MQ не принимает задачи из app.tasks.py в Django - PullRequest
Новая
       27

Сельдерей с виртуальным хостом Rabbit MQ не принимает задачи из app.tasks.py в Django

1 голос
/ 15 апреля 2020

Требуется помощь!

PS: я уже создал виртуальные хосты по этой ссылке

Сельдерей и призраки

settings.py 

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

celery.py

import os from celery import Celery

из 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")

Прикрепляя изображения из моего терминала, один из рабочих экземпляров другого - это оболочка, из которой я запускаю задачи. Примечание: я запустил и после настроек, и все, но, похоже, он не работает

Рабочий терминал Снимок экрана

Экземпляр оболочки, запускающий запрос

RabbitMQ, Celery == 4.4.2 Django == 3.0.4 Пожалуйста, помогите!

...