airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters

在 Kubernetes POD 中执行任务。

函数

convert_volume(volume)

将 Airflow Volume 对象转换为 k8s.V1Volume。

convert_volume_mount(volume_mount)

将 Airflow VolumeMount 对象转换为 k8s.V1VolumeMount。

convert_port(port)

将 Airflow Port 对象转换为 k8s.V1ContainerPort。

convert_env_vars(env_vars)

强制转换 Kubernetes 的环境变量集合。

convert_env_vars_or_raise_error(env_vars)

用于转换 Kubernetes 环境变量集合的独立函数,如果类型仍然错误则抛出错误。

convert_pod_runtime_info_env(pod_runtime_info_envs)

将 PodRuntimeInfoEnv 转换为 k8s.V1EnvVar。

convert_image_pull_secrets(image_pull_secrets)

将 PodRuntimeInfoEnv 转换为 k8s.V1EnvVar。

convert_configmap(configmaps)

将字符串转换为 k8s.V1EnvFromSource。

convert_affinity(affinity)

将字典转换为 k8s.V1Affinity。

convert_toleration(toleration)

将字典转换为 k8s.V1Toleration。

模块内容

airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters.convert_volume(volume)[源码]

将 Airflow Volume 对象转换为 k8s.V1Volume。

参数:

volume

airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters.convert_volume_mount(volume_mount)[源码]

将 Airflow VolumeMount 对象转换为 k8s.V1VolumeMount。

参数:

volume_mount

airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters.convert_port(port)[源码]

将 Airflow Port 对象转换为 k8s.V1ContainerPort。

参数:

port

airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters.convert_env_vars(env_vars)[源码]

强制转换 Kubernetes 的环境变量集合。

如果集合是字符串到字符串的字典,则将其转换为 V1EnvVar 变量的列表。

airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters.convert_env_vars_or_raise_error(env_vars)[源码]

用于转换 Kubernetes 环境变量集合的独立函数,如果类型仍然错误则抛出错误。

这在模板字符串渲染后使用。

airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters.convert_pod_runtime_info_env(pod_runtime_info_envs)[源码]

将 PodRuntimeInfoEnv 转换为 k8s.V1EnvVar。

参数:

pod_runtime_info_envs

airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters.convert_image_pull_secrets(image_pull_secrets)[源码]

将 PodRuntimeInfoEnv 转换为 k8s.V1EnvVar。

参数:

image_pull_secrets

airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters.convert_configmap(configmaps)[源码]

将字符串转换为 k8s.V1EnvFromSource。

参数:

configmaps

airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters.convert_affinity(affinity)[源码]

将字典转换为 k8s.V1Affinity。

airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters.convert_toleration(toleration)[源码]

将字典转换为 k8s.V1Toleration。

这篇内容有帮助吗?