`airflow.providers.google.cloud.triggers.cloud_batch`¶

模块内容¶

类¶

CloudBatchJobFinishedTrigger

Cloud Batch 触发器，用于检查模板作业是否已完成。

属性¶

DEFAULT_BATCH_LOCATION

airflow.providers.google.cloud.triggers.cloud_batch.DEFAULT_BATCH_LOCATION = 'us-central1'[源代码]¶

class airflow.providers.google.cloud.triggers.cloud_batch.CloudBatchJobFinishedTrigger(job_name, project_id, location=DEFAULT_BATCH_LOCATION, gcp_conn_id='google_cloud_default', impersonation_chain=None, polling_period_seconds=10, timeout=None)[源代码]¶

基类: airflow.triggers.base.BaseTrigger

Cloud Batch 触发器，用于检查模板作业是否已完成。

参数

job_name (str) – 必需。作业的名称。
project_id (str | None) – 必需。启动作业的 Google Cloud 项目 ID。
location (str) – 可选。执行作业的位置。如果设置为 None，则将使用 DEFAULT_BATCH_LOCATION 的值
gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐户，或获取列表中最后一个帐户的 access_token 所需的链接帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须授予原始帐户服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。
poll_sleep – 检查状态的轮询周期（秒）

serialize()[源代码]¶

序列化类参数和类路径。

async run()[源代码]¶

获取作业状态或产生某些事件。

类的主循环，其中获取作业状态并产生某些事件。

如果作业状态为成功，则产生具有成功状态的 TriggerEvent；如果作业状态为失败，则产生具有错误状态的 TriggerEvent；如果正在删除作业，则产生具有删除状态的 TriggerEvent。在任何其他情况下，触发器将等待存储在 self.polling_period_seconds 变量中的指定时间量。

airflow.providers.google.cloud.triggers.cloud_batch¶

模块内容¶

类¶

属性¶

`airflow.providers.google.cloud.triggers.cloud_batch`¶