airflow.providers.google.cloud.sensors.bigtable
¶
此模組包含 Google Cloud Bigtable 感測器。
模組內容¶
類別¶
感測器,等待 Cloud Bigtable 表格完全複製到其叢集。 |
- class airflow.providers.google.cloud.sensors.bigtable.BigtableTableReplicationCompletedSensor(*, instance_id, table_id, project_id=PROVIDE_PROJECT_ID, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[原始碼]¶
基底類別:
airflow.sensors.base.BaseSensorOperator
,airflow.providers.google.cloud.operators.bigtable.BigtableValidationMixin
感測器,等待 Cloud Bigtable 表格完全複製到其叢集。
如果執行個體或表格不存在,則不會引發例外。
有關表格叢集狀態的更多詳細資訊,請參閱參考文獻: https://googleapis.github.io/google-cloud-python/latest/bigtable/table.html#google.cloud.bigtable.table.Table.get_cluster_states
另請參閱
有關如何使用此運算子的更多資訊,請參閱指南: BigtableTableReplicationCompletedSensor
- 參數
instance_id (str) – Cloud Bigtable 執行個體的 ID。
table_id (str) – 要檢查複製狀態的表格 ID。
project_id (str) – (選填) Google Cloud 專案的 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – (選填) 要模擬使用的短期憑證服務帳戶,或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單,這將在請求中模擬。如果設定為字串,則帳戶必須授予原始帳戶 Service Account Token Creator IAM 角色。如果設定為序列,則清單中的身分必須將 Service Account Token Creator IAM 角色授予緊鄰的前一個身分,清單中的第一個帳戶將此角色授予原始帳戶 (已套用範本)。
- template_fields: collections.abc.Sequence[str] = ('project_id', 'instance_id', 'table_id', 'impersonation_chain')[原始碼]¶