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')[源码]¶