airflow.providers.cncf.kubernetes.kubernetes_helper_functions¶

属性¶

`log`
`alphanum_lower`
`POD_NAME_MAX_LENGTH`

函数¶

`rand_str`(num)	生成长度为 num 的随机小写字母数字字符串。
`add_unique_suffix`(*, name[, rand_len, max_len])	在不超过最大长度的情况下，向 pod 或 job 名称添加随机字符串。
`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)	检查 Exception 是否表示瞬态错误并值得重试。

模块内容¶

airflow.providers.cncf.kubernetes.kubernetes_helper_functions.log[source]¶

airflow.providers.cncf.kubernetes.kubernetes_helper_functions.alphanum_lower = 'abcdefghijklmnopqrstuvwxyz0123456789'[source]¶

airflow.providers.cncf.kubernetes.kubernetes_helper_functions.POD_NAME_MAX_LENGTH = 63[source]¶

airflow.providers.cncf.kubernetes.kubernetes_helper_functions.rand_str(num)[source]¶

生成长度为 num 的随机小写字母数字字符串。

airflow.providers.cncf.kubernetes.kubernetes_helper_functions.add_unique_suffix(*, name, rand_len=8, max_len=POD_NAME_MAX_LENGTH)[source]¶

在不超过最大长度的情况下，向 pod 或 job 名称添加随机字符串。

参数:

name (str) – pod 或 job 的名称
rand_len (int) – 要追加的随机字符串的长度
max_len (int) – pod 名称的最大长度

airflow.providers.cncf.kubernetes.kubernetes_helper_functions.create_unique_id(dag_id=None, task_id=None, *, max_length=POD_NAME_MAX_LENGTH, unique=True)[source]¶

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

参数:

dag_id (str | None) – DAG ID
task_id (str | None) – Task ID
max_length (int) – 最大字符数
unique (bool) – 是否应添加随机字符串后缀

返回:

kubernetes pod 名称的有效标识符

返回类型:

str

airflow.providers.cncf.kubernetes.kubernetes_helper_functions.annotations_to_key(annotations)[source]¶

根据 pod 注解构建 TaskInstanceKey。

airflow.providers.cncf.kubernetes.kubernetes_helper_functions.get_logs_task_metadata()[source]¶

airflow.providers.cncf.kubernetes.kubernetes_helper_functions.annotations_for_logging_task_metadata(annotation_set)[source]¶

airflow.providers.cncf.kubernetes.kubernetes_helper_functions.should_retry_creation(exception)[source]¶

检查 Exception 是否表示瞬态错误并值得重试。

此函数用于防止“No agent available”错误。当用户尝试创建 Resource 或 Job 时，此错误会不时出现。这个问题存在于 kubernetes 内部，目前还没有解决方案。作为临时解决方案，我们决定在每次出现此错误时重试 Job 或 Resource 创建请求。有关此问题的更多信息，请参见此处：https://github.com/cert-manager/cert-manager/issues/6457