airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters¶
在 Kubernetes POD 中执行任务。
函数¶
|
将 Airflow Volume 对象转换为 k8s.V1Volume。 |
|
将 Airflow VolumeMount 对象转换为 k8s.V1VolumeMount。 |
|
将 Airflow Port 对象转换为 k8s.V1ContainerPort。 |
|
强制转换 Kubernetes 的环境变量集合。 |
|
用于转换 Kubernetes 环境变量集合的独立函数，如果类型仍然错误则抛出错误。 |
|
将 PodRuntimeInfoEnv 转换为 k8s.V1EnvVar。 |
|
将 PodRuntimeInfoEnv 转换为 k8s.V1EnvVar。 |
|
将字符串转换为 k8s.V1EnvFromSource。 |
|
将字典转换为 k8s.V1Affinity。 |
|
将字典转换为 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