airflow.providers.celery.cli.celery_command

Celery 命令。

模組內容

函數

flower(args)

啟動 Flower，Celery 監控工具。

logger_setup_handler(logger, **kwargs)

重新設定記錄器。

worker(args)

啟動 Airflow Celery 工作節點。

stop_worker(args)

發送 SIGTERM 訊號給 Celery 工作節點。

屬性

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)[原始碼]

重新設定記錄器。

  • 移除任何先前設定的處理器

  • 嚴重性為錯誤或以上的日誌會輸出到 stderr，

  • 嚴重性低於錯誤的日誌會輸出到 stdout。

airflow.providers.celery.cli.celery_command.worker(args)[原始碼]

啟動 Airflow Celery 工作節點。

airflow.providers.celery.cli.celery_command.stop_worker(args)[原始碼]

發送 SIGTERM 訊號給 Celery 工作節點。

此條目是否有幫助？