flower не может отслеживать пользовательскую очередь

После настройки сельдерея, Redis и цветка я сделал несколько базовых тестов, все работало нормально, используя стандартные celery очередь. После этого я создал несколько пользовательских очередей, а затем flower не смог отслеживать эти пользовательские очереди. Я думаю, что цветок продолжает следить celery очередь. Тем не менее, цветок может контролировать результаты должным образом.

отчет о проекте по сельдерею:

software -> celery:4.2.1 (windowlicker) kombu:4.2.1 py:2.7.15rc1
            billiard:3.5.0.4 redis:2.10.6
platform -> system:Linux arch:64bit imp:CPython
loader   -> celery.loaders.app.AppLoader
settings -> transport:redis results:redis://127.0.0.1:6379/0

broker_url: u'redis://url/0'
result_backend: u'redis://url/0'
task_routes: {
    u'celery.crawler.fbk.download_alt_text': {   u'queue': u'fbk_alt_text'}}

цветочная команда:

celery flower -A downloader -Q fbk_alt_text --broker=redis://url:6379/0

подтверждение концепции: flower_monitor flower_broker

1 ответ

Сельдерей и цветок не настроены правильно, как показано на скриншотах. Убедитесь, что работник из сельдерея выполняет задачи из этой очереди.

Если работник сельдерея потребляет очередь, то flower покажет очереди в секции брокера.

celery worker -l info -A app -Q foo
flower -A app -Q foo

В разделе брокера должно отображаться foo,

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