Cloud Storage 订阅

Cloud Storage 订阅是一种导出订阅,它会在收到消息时将其写入现有 Cloud Storage 存储桶。您无需配置单独的订阅者客户端。使用 Google Cloud 控制台、Google Cloud CLI、客户端库或 Pub/Sub API 可以创建、更新、列出、分离或删除 Cloud Storage 订阅。

如果没有 Cloud Storage 订阅类型,则您需要拉取或推送订阅,以及读取消息并将其写入 Cloud Storage 存储桶的订阅程序(例如 Dataflow)。如果将消息存储在 Cloud Storage 存储桶中之前不需要进行额外处理,则不需要运行 Dataflow 作业的开销;您可以改用 Cloud Storage 订阅。

但是,对于一些数据转换必须先进行数据转换的 Pub/Sub 系统,我们仍建议使用 Dataflow 流水线,然后才能将数据存储在 Cloud Storage 存储桶中。

如需了解如何使用 Dataflow 通过转换将数据从 Pub/Sub 流式传输到 Cloud Storage,请参阅使用 Dataflow 从 Pub/Sub 流式传输消息

准备工作

在阅读本文档之前,请确保您熟悉以下内容:

Cloud Storage 订阅工作流

下图显示了 Cloud Storage 订阅与 Cloud Storage 之间的工作流。

Cloud Storage 订阅的消息流

图 1. Cloud Storage 订阅的工作流

以下是对参考图 1 的工作流的简要说明:

  1. Pub/Sub 使用 Cloud Storage API 将数据发送到 Cloud Storage 存储桶。写入操作成功完成后,API 会返回 OK 响应。

  2. 这些消息会批量发送到 Cloud Storage 存储桶。 一个批次对应于存储在 Cloud Storage 存储桶中的一个对象。您可以根据对象大小和自对象创建以来经过的时间来配置批量设置。

  3. 将对象写入 Cloud Storage 存储桶的工作流需要两个 OK 响应。当消息成功写入对象时,系统会发送第一个 OK 响应。包含该消息的对象最终确定后,系统会发送第二个 OK 响应。消息只有在包含它的 Cloud Storage 对象成功最终确定后,才会在存储桶中显示。

  4. 如果写入操作期间发生任何失败,则 Pub/Sub 消息本身会得到否定确认。然后,该消息会重新发送。如果消息写入操作失败的次数足够多,并且您在订阅上配置了死信主题,则该消息会移至死信主题。

Cloud Storage 订阅的属性

创建 Cloud Storage 订阅时,您必须指定一些其他属性。这些属性包括常见的订阅属性、文件名和格式要求、存储要求等。如需详细了解这些属性,请参阅 Cloud Storage 订阅属性

Pub/Sub 服务帐号权限

如需创建 Cloud Storage 订阅,Pub/Sub 服务帐号必须具有向特定 Cloud Storage 存储桶写入数据以及读取存储桶元数据的权限。

如需了解详情,请参阅为 Pub/Sub 服务帐号分配 Cloud Storage 角色

处理消息失败

如果 Pub/Sub 消息无法写入 Cloud Storage 存储桶,则无法确认该消息。如需转发此类无法传送的消息,请在 Cloud Storage 订阅上配置死信主题

配额

每个区域的 Cloud Storage 订阅者吞吐量均有配额限制。如需了解 Cloud Storage 订阅的配额,请参阅 Pub/Sub 配额和限制中的导出订阅者配额限制。

价格

如需了解 Cloud Storage 订阅的价格,请参阅 Pub/Sub 价格页面

后续步骤