airflow.providers.google.cloud.triggers.kubernetes_engine¶

类¶

`GKEStartPodTrigger`	用于检查 Pod 状态直到其完成工作的 Trigger。
`GKEOperationTrigger`	检查操作状态的 Trigger。
`GKEJobTrigger`	GKEJobTrigger 在 Trigger Worker 上运行以检查 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)[source]¶

基类: airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger

用于检查 Pod 状态直到其完成工作的 Trigger。

参数:

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) – Trigger 启动时的日期时间格式时间
in_cluster (bool | None) – 使用 in_cluster 配置运行 Kubernetes 客户端。
get_logs (bool) – 获取容器的标准输出作为任务日志。
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。

pod_name[source]¶

pod_namespace[source]¶

trigger_start_time[source]¶

base_container_name[source]¶

poll_interval = 2[source]¶

cluster_context = None[source]¶

in_cluster = None[source]¶

get_logs = True[source]¶

startup_timeout = 120[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

serialize()[source]¶

序列化 KubernetesCreatePodTrigger 参数和类路径。

property hook: airflow.providers.google.cloud.hooks.kubernetes_engine.GKEKubernetesAsyncHook[source]¶

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)[source]¶

基类: airflow.triggers.base.BaseTrigger

检查操作状态的 Trigger。

operation_name[source]¶

project_id[source]¶

location[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

poll_interval = 10[source]¶

serialize()[source]¶

序列化 GKEOperationTrigger 参数和类路径。

async run()[source]¶

获取操作状态并生成相应的事件。

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]¶