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

模块内容¶

类¶

DataFusionStartPipelineTrigger

触发器，用于检查管道状态，直到其达到终止状态。

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)[源代码]¶

基类: airflow.triggers.base.BaseTrigger

触发器，用于检查管道状态，直到其达到终止状态。

参数

pipeline_name (str) – 你的管道名称。
instance_url (str) – 实例上可访问 REST API 的端点。
pipeline_id (str) – 与特定管道关联的唯一管道 ID
pipeline_type (str) – 你的管道类型。
namespace (str) – 如果你的管道属于基础版实例，则命名空间 ID 始终为默认值。如果你的管道属于企业版实例，你可以创建一个命名空间。
gcp_conn_id (str) – 指向 google cloud 连接 ID 的引用
poll_interval (float) – 轮询状态的间隔时间，以秒为单位
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭证进行模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须授予原始帐户“服务帐户令牌创建者”IAM 角色。如果设置为序列，则列表中的身份必须将“服务帐户令牌创建者”IAM 角色授予直接前面的身份，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

serialize()[源代码]¶

序列化 DataFusionStartPipelineTrigger 参数和类路径。

async run()[源代码]¶

获取当前管道状态并生成 TriggerEvent。

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

模块内容¶

类¶

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