airflow.providers.celery.cli.celery_command¶

Celery 命令.

属性¶

`WORKER_PROCESS_NAME`
`log`

`flower`(args)	启动 Flower，Celery 监控工具.
`logger_setup_handler`(logger, **kwargs)	重新配置日志记录器.
`worker`(args)	启动 Airflow Celery worker.
`stop_worker`(args)	向 Celery worker 发送 SIGTERM 信号.

airflow.providers.celery.cli.celery_command.WORKER_PROCESS_NAME = 'worker'[源码]¶

airflow.providers.celery.cli.celery_command.flower(args)[源码]¶: 启动 Flower，Celery 监控工具.

airflow.providers.celery.cli.celery_command.logger_setup_handler(logger, **kwargs)[源码]¶

重新配置日志记录器.

airflow.providers.celery.cli.celery_command.worker(args)[源码]¶: 启动 Airflow Celery worker.

airflow.providers.celery.cli.celery_command.stop_worker(args)[源码]¶: 向 Celery worker 发送 SIGTERM 信号.