Celery 执行器命令¶
注意
以下 CLI 命令由 Airflow 2.7.0+ 的提供程序使用。以前它们是核心 Airflow 的一部分，因此如果您使用的是低于 2.7.0 的 Airflow，请查看核心 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。接受以逗号分隔的用户：密码对。示例：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