Цветочный интерфейс не показывает рабочих

Я настроил воздушный поток для выполнения рабочих процессов с помощью celeryExecuter. Я запустил веб-сервер, планировщик и рабочий, и они работают нормально. Но в цветочном интерфейсе нет рабочих.

Результат airflow worker:

/usr/local/lib/python2.7/dist-packages/psycopg2/__init__.py:144: UserWarning: The psycopg2 wheel package will be renamed from release 2.8; in order to keep installing from binary please use "pip install psycopg2-binary" instead. For details see: <http://initd.org/psycopg/docs/install.html#binary-install-from-pypi>.
  """)
[2018-08-02 11:29:09,827] {__init__.py:57} INFO - Using executor CeleryExecutor
[2018-08-02 11:29:09,983] {driver.py:124} INFO - Generating grammar tables from /usr/lib/python2.7/lib2to3/Grammar.txt
[2018-08-02 11:29:10,052] {driver.py:124} INFO - Generating grammar tables from /usr/lib/python2.7/lib2to3/PatternGrammar.txt

И результат airflow flower:

/usr/local/lib/python2.7/dist-packages/psycopg2/__init__.py:144: UserWarning: The psycopg2 wheel package will be renamed from release 2.8; in order to keep installing from binary please use "pip install psycopg2-binary" instead. For details see: <http://initd.org/psycopg/docs/install.html#binary-install-from-pypi>.
  """)
[2018-08-02 11:29:35,574] {__init__.py:57} INFO - Using executor CeleryExecutor
[2018-08-02 11:29:35,739] {driver.py:124} INFO - Generating grammar tables from /usr/lib/python2.7/lib2to3/Grammar.txt
[2018-08-02 11:29:35,799] {driver.py:124} INFO - Generating grammar tables from /usr/lib/python2.7/lib2to3/PatternGrammar.txt
[I 180802 11:29:36 command:139] Visit me at http://0.0.0.0:5555
[I 180802 11:29:36 command:144] Broker: amqp://guest:**@localhost:5672//
[I 180802 11:29:36 command:147] Registered tasks: 
    [u'celery.accumulate',
     u'celery.backend_cleanup',
     u'celery.chain',
     u'celery.chord',
     u'celery.chord_unlock',
     u'celery.chunks',
     u'celery.group',
     u'celery.map',
     u'celery.starmap']
[I 180802 11:29:36 mixins:224] Connected to amqp://guest:**@localhost:5672//

Но цветок не показывает никакой информации о воркерах или задачах и выдает следующую ошибку в интерфейсе командной строки:

[E 180802 11:29:55 брокер: 82] Ошибка вызова API управления RabbitMQ: [Errno 111] В соединении отказано

Есть идеи относительно того, что не так?


airflow celery flower
person rootkit    schedule 02.08.2018    source источник

Ответы (1)


arrow_upward
1
arrow_downward

Что ж, я смог решить проблему. Оказывается, я должен был добавить export C_FORCE_ROOT=true в свой ~/.bashrc файл перед запуском рабочего. Это происходит, когда вы запускаете воркера с правами root.

person rootkit    schedule 02.08.2018