airflow.providers.google.cloud.sensors.bigtable

此模組包含 Google Cloud Bigtable 感測器。

模組內容

類別

BigtableTableReplicationCompletedSensor

感測器,等待 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 角色授予緊鄰的前一個身分,清單中的第一個帳戶將此角色授予原始帳戶 (已套用範本)。

REQUIRED_ATTRIBUTES = ('instance_id', 'table_id')[原始碼]
template_fields: collections.abc.Sequence[str] = ('project_id', 'instance_id', 'table_id', 'impersonation_chain')[原始碼]
poke(context)[原始碼]

覆寫衍生此類別時。

此條目是否有幫助?