airflow.providers.google.cloud.sensors.bigtable¶
本模組包含 Google Cloud Bigtable Sensor。
類¶
等待 Cloud Bigtable 表完全複製到其叢集的 Sensor。 |
模組內容¶
- 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 表完全複製到其叢集的 Sensor。
如果例項或表不存在，則不會引發異常。
有關表叢集狀態的更多詳細資訊，請參閱參考資料： https://googleapis.github.io/google-cloud-python/latest/bigtable/table.html#google.cloud.bigtable.table.Table.get_cluster_states
另請參閱
有關如何使用此 operator 的更多資訊，請參閱指南： 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')[原始碼]¶