airflow.providers.google.cloud.triggers.bigquery_dts¶
模块内容¶
类¶
用于监视传输运行状态以确定作业何时完成的触发器类。 |
- class airflow.providers.google.cloud.triggers.bigquery_dts.BigQueryDataTransferRunTrigger(project_id, config_id, run_id, poll_interval=10, gcp_conn_id='google_cloud_default', location=None, impersonation_chain=None)[source]¶
基类:
airflow.triggers.base.BaseTrigger用于监视传输运行状态以确定作业何时完成的触发器类。
- 参数
project_id (str | None) – 传输配置所在的 BigQuery 项目 ID
config_id (str) – 要监视的传输运行配置的 ID。
run_id (str) – 要监视的传输运行 ID。
poll_interval (int) – 可选。定义触发器检查作业状态的频率的间隔。
gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。
location (str | None) – 用于区域传输的 BigQuery 传输服务位置。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或获取列表中最后一个帐户的 access_token 所需的帐户链列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须授予原始帐户服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须将服务帐户令牌创建者 IAM 角色授予紧邻的前一个身份，列表中的第一个帐户将此角色授予原始帐户（已模板化）。