airflow.providers.celery.cli.celery_command

Celery 命令。

模块内容

函数

flower(args)

启动 Flower，Celery 监控工具。

logger_setup_handler(logger, **kwargs)

重新配置日志记录器。

worker(args)

启动 Airflow Celery worker。

stop_worker(args)

向 Celery worker 发送 SIGTERM 信号。

属性

WORKER_PROCESS_NAME

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)[来源]

重新配置日志记录器。

  • 移除任何先前配置的处理程序

  • 严重级别为 error 及以上的日志输出到 stderr，

  • 严重级别低于 error 的日志输出到 stdout。

airflow.providers.celery.cli.celery_command.worker(args)[来源]

启动 Airflow Celery worker。

airflow.providers.celery.cli.celery_command.stop_worker(args)[来源]

向 Celery worker 发送 SIGTERM 信号。

此条目是否有帮助？