airflow.providers.google.cloud.triggers.cloud_run¶

属性¶

DEFAULT_BATCH_LOCATION

类¶

`RunJobStatus`	表示作业运行状态的枚举。
`CloudRunJobFinishedTrigger`	Cloud Run trigger，用于检查模板化作业是否已完成。

模块内容¶

airflow.providers.google.cloud.triggers.cloud_run.DEFAULT_BATCH_LOCATION = 'us-central1'[source]¶

class airflow.providers.google.cloud.triggers.cloud_run.RunJobStatus[source]¶

基类: enum.Enum

表示作业运行状态的枚举。

SUCCESS = 'Success'[source]¶

FAIL = 'Fail'[source]¶

TIMEOUT = 'Timeout'[source]¶

class airflow.providers.google.cloud.triggers.cloud_run.CloudRunJobFinishedTrigger(operation_name, job_name, project_id, location=DEFAULT_BATCH_LOCATION, gcp_conn_id='google_cloud_default', impersonation_chain=None, polling_period_seconds=10, timeout=None)[source]¶

基类: airflow.triggers.base.BaseTrigger

Cloud Run trigger，用于检查模板化作业是否已完成。

参数:

operation_name (str) – 必需。操作的名称。
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 所需的账户链，该账户将在请求中被模拟。如果设置为字符串，则该账户必须授予原始账户 Service Account Token Creator IAM 角色。如果设置为序列，则列表中的身份必须授予紧前身份 Service Account Token Creator IAM 角色，列表中的第一个账户将此角色授予原始账户（模板化）。
poll_sleep – 轮询状态的周期（秒）。

超时:

操作失败前的等待时间。

project_id[source]¶

job_name[source]¶

operation_name[source]¶

location = 'us-central1'[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

polling_period_seconds = 10[source]¶

timeout = None[source]¶

impersonation_chain = None[source]¶

serialize()[source]¶

序列化类参数和类路径。

async run()[source]¶

在异步上下文中运行 trigger。

Trigger 应在想要触发事件时 yield 一个 Event，并在完成后返回 None。单事件 trigger 因此应该先 yield 然后立即返回。

如果它 yield，很可能会很快恢复，但也不一定（例如，如果工作负载被移动到另一个 triggerer 进程，或者多事件 trigger 被用于单事件任务延迟）。

无论哪种情况，Trigger 类都应假定它们会被持久化，并在不再需要时依赖 cleanup() 被调用。