Невозможно просмотреть задачи в инструменте мониторинга 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`

Это мои конфигурационные файлы. Я пытаюсь добиться того, чтобы я создал задачу и хотел, чтобы она работала с цветком. В настоящее время это мгновенно отображается в командной строке, когда я создаю нового пользователя, но мне нужно, чтобы оно отображалось всякий раз, когда мой планировщик хочет.

0 ответов

Другие вопросы по тегам