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 的账号链列表，该账号将在请求中被模拟。如果设置为字符串，则该账号必须授予发起账号 Service Account Token Creator IAM 角色。如果设置为序列，则列表中身份必须授予 Service Account Token Creator 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')[源码]¶