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)

檢查 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)[原始碼]

檢查 Exception 是否表示暫時性錯誤並需要重試。

此函式用於防止 ‘No agent available’ 錯誤。當使用者嘗試建立資源或 Job 時，偶爾會出現此錯誤。此問題存在於 Kubernetes 內部，目前尚無解決方案。作為臨時解決方案，我們決定每次出現此錯誤時都重試 Job 或資源建立請求。關於此問題的更多資訊，請參閱：https://github.com/cert-manager/cert-manager/issues/6457

這個條目對您有幫助嗎？