airflow.providers.edge3.cli.edge_command

属性

logger

EDGE_WORKER_PROCESS_NAME

EDGE_WORKER_HEADER

SIG_STATUS

ARG_CONCURRENCY

ARG_QUEUES

ARG_EDGE_HOSTNAME

ARG_MAINTENANCE

ARG_MAINTENANCE_COMMENT

ARG_WAIT_MAINT

ARG_WAIT_STOP

EDGE_COMMANDS

函数

force_use_internal_api_on_edge_worker()

确保环境配置为内部 API,无需在外部声明。

worker(args)

启动 Airflow Edge Worker。

status(args)

检查 Airflow Edge Worker 状态。

maintenance(args)

设置或取消设置 Worker 的维护模式。

stop(args)

停止正在运行的 Airflow Edge Worker。

模块内容

airflow.providers.edge3.cli.edge_command.logger[source]
airflow.providers.edge3.cli.edge_command.EDGE_WORKER_PROCESS_NAME = 'edge-worker'[source]
airflow.providers.edge3.cli.edge_command.EDGE_WORKER_HEADER = ''[source]
airflow.providers.edge3.cli.edge_command.force_use_internal_api_on_edge_worker()[source]

确保环境配置为内部 API,无需在外部声明。

这仅适用于 Edge Worker,并且必须在 Click CLI 包装器启动之前完成。这是因为 CLI 包装器会尝试建立数据库连接,这会在函数调用生效之前失败。在 Edge Worker 中,我们需要在启动前“打补丁”环境。

airflow.providers.edge3.cli.edge_command.SIG_STATUS[source]
airflow.providers.edge3.cli.edge_command.worker(args)[source]

启动 Airflow Edge Worker。

airflow.providers.edge3.cli.edge_command.status(args)[source]

检查 Airflow Edge Worker 状态。

airflow.providers.edge3.cli.edge_command.maintenance(args)[source]

设置或取消设置 Worker 的维护模式。

airflow.providers.edge3.cli.edge_command.stop(args)[source]

停止正在运行的 Airflow Edge Worker。

airflow.providers.edge3.cli.edge_command.ARG_CONCURRENCY[source]
airflow.providers.edge3.cli.edge_command.ARG_QUEUES[source]
airflow.providers.edge3.cli.edge_command.ARG_EDGE_HOSTNAME[source]
airflow.providers.edge3.cli.edge_command.ARG_MAINTENANCE[source]
airflow.providers.edge3.cli.edge_command.ARG_MAINTENANCE_COMMENT[source]
airflow.providers.edge3.cli.edge_command.ARG_WAIT_MAINT[source]
airflow.providers.edge3.cli.edge_command.ARG_WAIT_STOP[source]
airflow.providers.edge3.cli.edge_command.EDGE_COMMANDS: list[airflow.cli.cli_config.ActionCommand][source]

本条目有帮助吗?