Celery 執行器命令¶
注意
以下 CLI 命令自 Airflow 2.7.0+ 起由 provider 提供。在此之前，它們是核心 Airflow 的一部分，因此如果您使用的 Airflow 版本低於 2.7.0，請參閱核心 Airflow 文件以獲取可用的 CLI 命令和引數列表。
Usage: airflow [-h] GROUP_OR_COMMAND ...
位置引數¶
- GROUP_OR_COMMAND
可能選項: celery
子命令¶
celery¶
啟動 celery 元件。僅在使用 CeleryExecutor 時有效。更多資訊請參閱 https://airflow.apache.tw/docs/apache-airflow/stable/executor/celery.html
airflow celery [-h] COMMAND ...
位置引數¶
- COMMAND
可能選項: flower, stop, worker
子命令¶
flower¶
啟動一個 Celery Flower
airflow celery flower [-h] [-A BASIC_AUTH] [-a BROKER_API] [-D]
[-c FLOWER_CONF] [-H HOSTNAME] [-l LOG_FILE]
[--pid [PID]] [-p PORT] [--stderr STDERR]
[--stdout STDOUT] [-u URL_PREFIX] [-v]
命名引數¶
- -A, --basic-auth
使用基本認證保護 Flower。接受 user:password 對，以逗號分隔。示例: flower_basic_auth = user1:password1,user2:password2
預設值: “”
- -a, --broker-api
Broker API
- -D, --daemon
以守護程序模式執行，而不是前臺
預設值: False
- -c, --flower-conf
Flower 配置檔案
- -H, --hostname
設定執行伺服器的主機名
預設值: “0.0.0.0”
- -l, --log-file
日誌檔案位置
- --pid
PID 檔案位置
- -p, --port
執行伺服器的埠
預設值: 5555
- --stderr
將 stderr 重定向到此檔案
- --stdout
將 stdout 重定向到此檔案
- -u, --url-prefix
Flower 的 URL 字首
預設值: “”
- -v, --verbose
使日誌輸出更詳細
預設值: False
stop¶
優雅地停止 Celery worker
airflow celery stop [-h] [--pid [PID]] [-v]
命名引數¶
- --pid
PID 檔案位置
- -v, --verbose
使日誌輸出更詳細
預設值: False
worker¶
啟動一個 Celery worker 節點
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
worker 自動縮放的最小和最大數量
- -H, --celery-hostname
如果您在同一臺機器上部署了多個 worker，設定 Celery worker 的主機名
- -c, --concurrency
worker 程序的數量
預設值: 16
- -D, --daemon
以守護程序模式執行，而不是前臺
預設值: False
- -l, --log-file
日誌檔案位置
- --pid
PID 檔案位置
- -q, --queues
要服務的佇列列表，以逗號分隔
預設值: “default”
- -s, --skip-serve-logs
不隨 worker 一起啟動日誌服務程序
預設值: False
- --stderr
將 stderr 重定向到此檔案
- --stdout
將 stdout 重定向到此檔案
- -u, --umask
在守護程序模式下設定 Celery worker 的 umask
- -v, --verbose
使日誌輸出更詳細
預設值: False
- --without-gossip
不訂閱其他 worker 的事件
預設值: False
- --without-mingle
啟動時不同步其他 worker
預設值: False