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