airflow.providers.cncf.kubernetes.kubernetes_helper_functions

模块内容

函数

create_unique_id([dag_id, task_id, max_length, unique])

根据 dag_id 和/或 task_id 生成唯一的 pod 或 job ID。

annotations_to_key(annotations)

基于 pod 注释构建 TaskInstanceKey。

get_logs_task_metadata()

annotations_for_logging_task_metadata(annotation_set)

should_retry_creation(exception)

检查异常是否指示瞬时错误并需要重试。

属性

log

alphanum_lower

POD_NAME_MAX_LENGTH

airflow.providers.cncf.kubernetes.kubernetes_helper_functions.log[源代码]
airflow.providers.cncf.kubernetes.kubernetes_helper_functions.alphanum_lower[源代码]
airflow.providers.cncf.kubernetes.kubernetes_helper_functions.POD_NAME_MAX_LENGTH = 63[源代码]
airflow.providers.cncf.kubernetes.kubernetes_helper_functions.create_unique_id(dag_id=None, task_id=None, *, max_length=POD_NAME_MAX_LENGTH, unique=True)[源代码]

根据 dag_id 和/或 task_id 生成唯一的 pod 或 job ID。

参数

  • dag_id (str | None) – DAG ID

  • task_id (str | None) – 任务 ID

  • max_length (int) – 最大字符数

  • unique (bool) – 是否应添加随机字符串后缀

返回

Kubernetes pod 名称的有效标识符

返回类型

str

airflow.providers.cncf.kubernetes.kubernetes_helper_functions.annotations_to_key(annotations)[源代码]

基于 pod 注释构建 TaskInstanceKey。

airflow.providers.cncf.kubernetes.kubernetes_helper_functions.get_logs_task_metadata()[源代码]
airflow.providers.cncf.kubernetes.kubernetes_helper_functions.annotations_for_logging_task_metadata(annotation_set)[源代码]
airflow.providers.cncf.kubernetes.kubernetes_helper_functions.should_retry_creation(exception)[源代码]

检查异常是否指示瞬时错误并需要重试。

此函数用于防止 “没有可用代理” 错误。当用户尝试创建资源或作业时，会不时出现此错误。此问题存在于 Kubernetes 内部，目前没有解决方案。作为临时解决方案，我们决定每次出现此错误时都重试作业或资源创建请求。有关此问题的更多信息，请参阅：https://github.com/cert-manager/cert-manager/issues/6457

此条目是否有帮助？