airflow.providers.google.cloud.sensors.bigquery_dts¶
此模块包含一个 Google BigQuery 数据传输服务传感器。
模块内容¶
类¶
等待数据传输服务运行完成。 |
- class airflow.providers.google.cloud.sensors.bigquery_dts.BigQueryDataTransferServiceTransferRunSensor(*, run_id, transfer_config_id, expected_statuses=TransferState.SUCCEEDED, project_id=PROVIDE_PROJECT_ID, gcp_conn_id='google_cloud_default', retry=DEFAULT, request_timeout=None, metadata=(), location=None, impersonation_chain=None, **kwargs)[源]¶
基类:
airflow.sensors.base.BaseSensorOperator等待数据传输服务运行完成。
另请参阅
有关如何使用此传感器的更多信息，请参阅本指南：手动启动传输运行
- 参数
expected_statuses (set[str | google.cloud.bigquery_datatransfer_v1.TransferState | int] | str | google.cloud.bigquery_datatransfer_v1.TransferState | int) – 操作的预期状态。请参阅： https://cloud.google.com/storage-transfer/docs/reference/rest/v1/transferOperations#Status
run_id (str) – 传输运行的 ID。
transfer_config_id (str) – 要使用的传输配置的 ID。
project_id (str) – 应在其中创建传输配置的 BigQuery 项目 ID。如果设置为 None 或缺失，则使用 Google Cloud 连接中的默认 project_id。
retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 用于重试请求的重试对象。如果指定 None，则不会重试请求。
request_timeout (float | None) – 等待请求完成的时间（以秒为单位）。请注意，如果指定了重试，则超时适用于每次单独的尝试。
metadata (collections.abc.Sequence[tuple[str, str]]) – 提供给方法的附加元数据。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该 access_token 将在请求中被模拟。如果设置为字符串，则该帐户必须授予原始帐户“服务帐户令牌创建者”IAM 角色。如果设置为序列，则列表中的身份必须将“服务帐户令牌创建者”IAM 角色授予紧接其之前的身份，列表中的第一个帐户将此角色授予原始帐户（已模板化）。
- 返回
一个
google.cloud.bigquery_datatransfer_v1.types.TransferRun实例。
- template_fields: collections.abc.Sequence[str] = ('run_id', 'transfer_config_id', 'expected_statuses', 'project_id', 'impersonation_chain')[源]¶