Kubernetes 执行器命令

注意

以下 CLI 命令由 Airflow 2.7.0+ 的 provider 使用。之前它们是 Airflow 核心的一部分,因此如果您使用的是 Airflow 2.7.0 以下的版本,请查看 Airflow 核心文档以获取可用的 CLI 命令和参数列表。

Usage: airflow [-h] GROUP_OR_COMMAND ...

位置参数

GROUP_OR_COMMAND

可能的选择:kubernetes

子命令

kubernetes

用于帮助运行 KubernetesExecutor 的工具

airflow kubernetes [-h] COMMAND ...

位置参数

COMMAND

可能的选择:cleanup-pods,generate-dag-yaml

子命令

cleanup-pods

清理 Kubernetes Pod(由 KubernetesExecutor/KubernetesPodOperator 创建),这些 Pod 处于 evicted/failed/succeeded/pending 状态

airflow kubernetes cleanup-pods [-h]
                                [--min-pending-minutes MIN_PENDING_MINUTES]
                                [--namespace NAMESPACE] [-v]
命名参数
--min-pending-minutes

在时间间隔之前创建的处于 Pending 状态的 Pod 将被清理,以分钟为单位。默认值为 30(m)。最小值是 5(m)。

默认值:30

--namespace

Kubernetes 命名空间。默认值是配置中的 [kubernetes] namespace

默认值:“default”

-v,--verbose

使日志输出更加详细

默认值:False

generate-dag-yaml

为 DAG 中的所有任务生成 YAML 文件。有助于在不启动集群的情况下调试任务

airflow kubernetes generate-dag-yaml [-h] [-o OUTPUT_PATH] [-S SUBDIR] [-v]
                                     dag_id logical_date
位置参数
dag_id

DAG 的 ID

logical_date

DAG 的逻辑日期

命名参数
-o,--output-path

生成的 yaml 文件的输出路径

默认值:“[CWD]”

-S,--subdir

查找 DAG 的文件位置或目录。默认值为 ‘[AIRFLOW_HOME]/dags’,其中 [AIRFLOW_HOME] 是您在 ‘airflow.cfg’ 中设置的 ‘AIRFLOW_HOME’ 配置的值

默认值:“[AIRFLOW_HOME]/dags”

-v,--verbose

使日志输出更加详细

默认值:False

此条目是否有帮助?