Требуется помощь!
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 Пожалуйста, помогите!