worker
Описание
Запуск worker-ноды Celery. Вы можете выполнить эту команду с помощью действия Add/Remove components в ADCM.
Использование
$ airflow celery worker [-h] [-a AUTOSCALE] [-H CELERY_HOSTNAME]
[-c CONCURRENCY] [-D] [-l LOG_FILE] [--pid [PID]]
[-q QUEUES] [-s] [--stderr STDERR] [--stdout STDOUT]
[-u UMASK] [-v] [--without-gossip] [--without-mingle]Аргументы
| Параметр | Описание |
|---|---|
-a, --autoscale |
Минимальное и максимальное количество рабочих процессов для автоматического масштабирования |
-H, --celery-hostname |
Имя хоста Сelery worker, если у вас несколько worker на одном хосте |
-c, --concurrency |
Количество рабочих процессов. Значение по умолчанию: |
-D, --daemon |
Запустить выполнение команды в качестве процесса-демона. Значение по умолчанию: |
-l, --log-file |
Расположение логов |
--pid |
Расположение PID-файла |
-q, --queues |
Список очередей для обслуживания, разделенных запятыми. Значение по умолчанию: |
-s, --skip-serve-logs |
Не запускать процесс обработки логов одновременно с процессами обработки. Значение по умолчанию: |
--stderr |
Перенаправить stderr в указанный файл |
--stdout |
Перенаправить stdout в указанный файл |
-u, --umask |
Установить umask для Сelery worker в режиме демона |
--without-gossip |
Не подписываться на события других worker. Значение по умолчанию: |
--without-mingle |
Не синхронизироваться с другими worker на начальном этапе. Значение по умолчанию: |
-h, --help |
Вывести справку для команды |
-v, --verbose |
Более подробный вывод команды |