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)[源代码]¶
基础类：
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 Data Transfer Service 位置。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务账号，用于使用短期凭据进行模拟，或用于获取列表中最后一个账号的 access_token 的一连串账号列表，该令牌将在请求中用于模拟。如果设置为字符串，该账号必须授予发起账号 Service Account Token Creator IAM 角色。如果设置为序列，列表中的身份必须授予直接前一个身份 Service Account Token Creator IAM 角色，列表中的第一个账号将此角色授予发起账号（模板化）。