airflow.providers.google.cloud.triggers.kubernetes_engine¶
模块内容¶
类¶
用于检查 Pod 状态直到其完成作业的触发器。 |
|
检查操作状态的触发器。 |
|
在触发器工作器上运行的 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 集群的上下文。
poll_interval (float) – 检查状态的轮询周期（以秒为单位）。
trigger_start_time (datetime.datetime) – 触发器启动时的时间，格式为 DateTime
in_cluster (bool | None) – 使用 in_cluster 配置运行 Kubernetes 客户端。
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。
- 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检查操作状态的触发器。
- 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)[source]¶
基类：
airflow.triggers.base.BaseTrigger在触发器工作器上运行的 GKEJobTrigger，用于检查 Job 的状态。