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