Невозможно просмотреть задачи в инструменте мониторинга Flower - Celery с помощью redis
В настоящее время я пытаюсь наметить задачу, используя сельдерей и редис, и я не могу понять, как просматривать мои задачи в цветах. Это мои файлы конфигурации.
local.yml`
version: '3'
volumes:
local_postgres_data: {}
local_postgres_data_backups: {}
services:
django: &django
build:
context: .
dockerfile: ./compose/local/django/Dockerfile
image: risky_dog_local_django
depends_on:
- postgres
- mailhog
- redis
links:
- redis
volumes:
- .:/app
env_file:
- ./.envs/.local/.django
- ./.envs/.local/.postgres
ports:
- "8000:8000"
command: /start
postgres:
build:
context: .
dockerfile: ./compose/production/postgres/Dockerfile
image: risky_dog_production_postgres
volumes:
- local_postgres_data:/var/lib/postgresql/data
- local_postgres_data_backups:/backups
env_file:
- ./.envs/.local/.postgres
mailhog:
image: mailhog/mailhog:latest
ports:
- "8025:8025"
redis:
image: redis:3.2
celeryworker:
<<: *django
image: risky_dog_local_celeryworker
depends_on:
- redis
- postgres
- mailhog
links:
- redis
ports: []
command: /start-celeryworker
celerybeat:
<<: *django
image: risky_dog_local_celerybeat
depends_on:
- redis
- postgres
- mailhog
links:
- redis
ports: []
command: /start-celerybeat
flower:
<<: *django
image: risky_dog_local_flower
ports:
- "5555:5555"
command: /start-flower
`
models.py `
from django.contrib.auth.models import AbstractUser
from django.db.models import CharField
from django.urls import reverse
from django.utils.translation import ugettext_lazy as _
from datetime import timedelta, datetime
from django.utils.timezone import now
from .tasks import send_bid_alert
class User(AbstractUser):
# First Name and Last Name do not cover name patterns
# around the globe.
name = CharField(_("Name of User"), blank=True, max_length=255)
def get_absolute_url(self):
return reverse("users:detail", kwargs={"username": self.username})
def save(self, *args, **kwargs):
super().save()
send_bid_alert.apply_async(eta=datetime.now() + timedelta(minutes=3))
`
tasks.py`
from __future__ import absolute_import, unicode_literals
from celery import shared_task
from django.utils import timezone
@shared_task
def send_bid_alert():
print("hello there")
result = 23
return result`
Это мои конфигурационные файлы. Я пытаюсь добиться того, чтобы я создал задачу и хотел, чтобы она работала с цветком. В настоящее время это мгновенно отображается в командной строке, когда я создаю нового пользователя, но мне нужно, чтобы оно отображалось всякий раз, когда мой планировщик хочет.