airflow.providers.google.cloud.triggers.kubernetes_engine

模組內容

類別

GKEStartPodTrigger

觸發器，用於檢查 Pod 狀態直到其工作完成。

GKEOperationTrigger

觸發器，用於檢查操作狀態。

GKEJobTrigger

GKEJobTrigger 在觸發器工作程序上執行，以檢查 Job 的狀態。
class airflow.providers.google.cloud.triggers.kubernetes_engine.GKEStartPodTrigger(pod_name, pod_namespace, cluster_url, ssl_ca_cert, base_container_name, trigger_start_time, cluster_context=None, poll_interval=2, in_cluster=None, get_logs=True, startup_timeout=120, on_finish_action='delete_pod', should_delete_pod=None, gcp_conn_id='google_cloud_default', impersonation_chain=None, *args, **kwargs)[原始碼]

基底類別： airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger

觸發器，用於檢查 Pod 狀態直到其工作完成。

參數

  • pod_name (str) – Pod 的名稱。

  • pod_namespace (str) – Pod 的命名空間。

  • cluster_url (str) – 指向叢集的 URL。

  • ssl_ca_cert (str) – 用於向 Pod 進行身份驗證的 SSL 憑證。

  • cluster_context (str | None) – 指向 Kubernetes 叢集的 Context。

  • poll_interval (float) – 檢查狀態的輪詢間隔（秒）。

  • trigger_start_time (datetime.datetime) – 觸發器啟動時的 Datetime 格式時間

  • in_cluster (bool | None) – 使用 in_cluster 配置執行 Kubernetes client。

  • get_logs (bool) – 取得容器的 stdout 作為任務的日誌。

  • startup_timeout (int) – 啟動 Pod 的逾時時間（秒）。

  • base_container_name (str) – Pod 中基礎容器的名稱。如果 get_logs 為 True，則此容器的日誌將顯示為此任務日誌的一部分。預設為 None。如果為 None，將查詢類別變數 BASE_CONTAINER_NAME（預設為 “base”）以取得要使用的基礎容器名稱。

  • on_finish_action (str) – 當 Pod 達到其最終狀態或執行中斷時要執行的動作。如果為 “delete_pod”，則無論其狀態如何，Pod 都將被刪除；如果為 “delete_succeeded_pod”，則僅刪除成功的 Pod。您可以設定為 “keep_pod” 以保留 Pod。

  • should_delete_pod (bool | None) – 當 Pod 達到其最終狀態或執行中斷時要執行的動作。如果為 True（預設），則刪除 Pod；如果為 False，則保留 Pod。已棄用 - 請改用 on_finish_action。

serialize()[原始碼]

序列化 KubernetesCreatePodTrigger 引數和類別路徑。

hook()[原始碼]
class airflow.providers.google.cloud.triggers.kubernetes_engine.GKEOperationTrigger(operation_name, project_id, location, gcp_conn_id='google_cloud_default', impersonation_chain=None, poll_interval=10)[原始碼]

基底類別： airflow.triggers.base.BaseTrigger

觸發器，用於檢查操作狀態。

serialize()[原始碼]

序列化 GKEOperationTrigger 引數和類別路徑。

async run()[原始碼]

取得操作狀態並產生相應的事件。

class airflow.providers.google.cloud.triggers.kubernetes_engine.GKEJobTrigger(cluster_url, ssl_ca_cert, job_name, job_namespace, pod_name, pod_namespace, base_container_name, gcp_conn_id='google_cloud_default', poll_interval=2, impersonation_chain=None, get_logs=True, do_xcom_push=False)[原始碼]

基底類別： airflow.triggers.base.BaseTrigger

GKEJobTrigger 在觸發器工作程序上執行，以檢查 Job 的狀態。

serialize()[原始碼]

序列化 KubernetesCreateJobTrigger 引數和類別路徑。

async run()[原始碼]

取得當前 Job 狀態並產生 TriggerEvent。

hook()[原始碼]
pod_manager()[原始碼]

此條目是否有幫助？