使用 Java 读取变更数据流

Java 版 Cloud Bigtable 客户端库提供处理数据更改记录的初级方法。不过,在大多数情况下,我们建议您使用 Dataflow 流式传输更改,而不是使用本页面中描述的方法,因为 Dataflow 会为您处理分区拆分和合并。

准备工作

在使用 Java 读取变更数据流之前,请务必先熟悉变更数据流概览。然后,完成以下前提条件。

设置身份验证

如需在本地开发环境中使用本页面上的 Java 示例,请安装并初始化 gcloud CLI,然后使用您的用户凭据设置应用默认凭据。

  1. 安装 Google Cloud CLI。

  2. 如果您使用的是外部身份提供方 (IdP),则必须先使用联合身份登录 gcloud CLI

  3. 如果您使用的是本地 shell,请为您的用户账号创建本地身份验证凭证:

    gcloud auth application-default login

    如果您使用的是 Cloud Shell,则无需执行此操作。

    如果系统返回身份验证错误,并且您使用的是外部身份提供方 (IdP),请确认您已 使用联合身份登录 gcloud CLI

如需了解详情,请参阅 为本地开发环境设置身份验证

如需了解如何为生产环境设置身份验证,请参阅 为在 Google Cloud上运行的代码设置应用默认凭据

启用变更数据流

您必须先在表上启用变更数据流,然后才能读取数据流。您还可以创建启用了变更数据流的新表

所需的角色

如需获得读取 Bigtable 变更数据流所需的权限,请让您的管理员授予您以下 IAM 角色。