Celery 执行器命令¶
注意
以下 CLI 命令由 Airflow 2.7.0+ 的提供程序使用。以前它们是 Airflow 核心的一部分，因此如果您使用的是 Airflow 2.7.0 以下版本，请查看核心 Airflow 文档以获取可用的 CLI 命令和参数列表。
Usage: airflow [-h] GROUP_OR_COMMAND ...
位置参数¶
- GROUP_OR_COMMAND
可选值：celery
子命令¶
celery¶
启动 Celery 组件。仅在使用 CeleryExecutor 时有效。有关更多信息，请参阅 https://airflow.apache.org/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 一起启动 serve logs 进程
默认值：False
- --stderr
将 stderr 重定向到此文件
- --stdout
将 stdout 重定向到此文件
- -u, --umask
在守护进程模式下设置 Celery Worker 的 umask
- -v, --verbose
使日志输出更详细
默认值：False
- --without-gossip
不订阅其他 Worker 的事件
默认值：False
- --without-mingle
启动时不同步其他 Worker
默认值：False