airflow.providers.google.cloud.triggers.datafusion¶

类¶

DataFusionStartPipelineTrigger

用于检查管道状态直到达到终止状态的 Trigger。

模块内容¶

class airflow.providers.google.cloud.triggers.datafusion.DataFusionStartPipelineTrigger(instance_url, namespace, pipeline_name, pipeline_id, pipeline_type, poll_interval=3.0, gcp_conn_id='google_cloud_default', impersonation_chain=None, success_states=None)[source]¶

基类: airflow.triggers.base.BaseTrigger

用于检查管道状态直到达到终止状态的 Trigger。

参数::

pipeline_name (str) – 您的管道名称。
instance_url (str) – 实例可访问 REST API 的端点。
pipeline_id (str) – 与特定管道关联的唯一管道 ID。
pipeline_type (str) – 您的管道类型。
namespace (str) – 如果您的管道属于 Basic 版实例，命名空间 ID 始终为默认值。如果您的管道属于 Enterprise 版实例，则可以创建命名空间。
gcp_conn_id (str) – 对 Google Cloud 连接 ID 的引用。
poll_interval (float) – 检查状态的轮询周期（秒）。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务账号，用于使用短期凭据进行模拟，或获取列表中最后一个账号的 access_token 所需的账号链，该账号将在请求中被模拟。如果设置为字符串，则该账号必须授予发起账号 Service Account Token Creator IAM 角色。如果设置为序列，则列表中的身份必须授予紧邻的前一个身份 Service Account Token Creator IAM 角色，其中列表中的第一个账号将此角色授予发起账号（模板化）。

instance_url[source]¶

namespace[source]¶

pipeline_name[source]¶

pipeline_id[source]¶

pipeline_type[source]¶

poll_interval = 3.0[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

success_states = None[source]¶

serialize()[source]¶

序列化 DataFusionStartPipelineTrigger 参数和类路径。

async run()[source]¶

获取当前管道状态并产生一个 TriggerEvent。