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.org.cn/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