airflow.providers.google.cloud.sensors.bigquery_dts¶
此模組包含 Google BigQuery Data Transfer Service 感測器。
模組內容¶
類別¶
等待 Data Transfer Service 執行完成。 |
- 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等待 Data Transfer Service 執行完成。
參見
有關如何使用此感測器的更多資訊，請查看指南： 手動啟動傳輸執行
- 參數
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) – 等待請求完成的時間量（以秒為單位）。請注意，如果指定了 retry，則逾時適用於每個個別嘗試。
metadata (collections.abc.Sequence[tuple[str, str]]) – 提供給方法的其他元數據。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務帳戶，用於使用短期憑證模擬身分，或取得列表中最後一個帳戶的 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')[原始碼]¶