Pub/Sub

适用于事件驱动型系统和流式分析的消息传递和事件提取服务。

免费试用 Pub/Sub
  • action/check_circle_24px 使用 Sketch 创建。

    利用拉取和推送模式进行大规模有序消息传送

  • action/check_circle_24px 使用 Sketch 创建。

    支持从零到每秒数百 GB 的吞吐量,可实现自动扩缩和自动预配

  • action/check_circle_24px 使用 Sketch 创建。

    面向发布者和订阅者的独立配额计算和结算功能

  • action/check_circle_24px 使用 Sketch 创建。

    可在全球范围内路由消息,从而简化多地区系统

轻松实现高可用性

跨区域的同步消息复制和对每条消息的接收情况跟踪可确保任何规模的消息都能安全可靠地送达。

无需规划,一切自动执行

可自动扩缩和自动预配,而无需设置分区,因此可以免去提前规划的麻烦,并确保工作负载从一开始便可用于生产环境。

内置高级特性

在不牺牲规模的前提下实现过滤、死信传送和指数退避算法,帮助简化您的应用

主要特性

流式分析和连接器

原生集成 Dataflow,支持以可靠且具有表现力的方式对 Java、Python 和 SQL 事件数据流进行一次性处理和集成。

大规模按序传送

可选的按键排序(Beta 版)功能可简化有状态应用逻辑而不影响横向扩容能力,并且无需分区。

使用 Pub/Sub Lite 以更优的性价比提取事件

作为 Pub/Sub 的补充,Pub/Sub Lite(Beta 版)是适合提取大量事件的费用最低的一种方案。Pub/Sub Lite 是区域级功能,让您可以掌控容量管理。

查看所有特性

客户

Sky 案例
Sky 通过 Pub/Sub 扩大事件发布规模,打造新一代 Sky Q 机顶盒。
阅读案例

案例亮点

  • 每天最多发布 6 亿个事件

  • 数百万 Sky Q 机顶盒实现诊断数据零损失

  • 在短短六周内替换了本地平台

行业

文档

Google Cloud 基础知识
什么是 Pub/Sub?

从核心概念和消息流到常见使用场景和集成,全面了解 Pub/Sub。

教程
有序消息传送

了解可规模化的消息排序的工作原理以及何时使用此功能。

教程
选择 Pub/Sub 或 Pub/Sub Lite

了解如何充分利用这两种产品。

快速入门
快速入门:使用客户端库

了解 Pub/Sub 服务如何让应用可靠、快速地异步交换消息。

快速入门
快速入门:使用 Dataflow 进行流处理

了解如何使用 Dataflow 读取发布到 Pub/Sub 主题的消息,按时间戳确定消息的窗口时间,以及向 Cloud Storage 写入消息。

使用场景

使用场景
流式分析

Google 的数据流分析使数据更有条理、更加有用,并从其生成的一刻起就可访问。我们的流处理解决方案以 Pub/Sub 以及 Dataflow 和 BigQuery 为基础而构建,可预配所需的资源来提取、处理和分析数量不断波动的实时数据,提供实时业务数据洞见。这种抽象化的预配降低了复杂性,使数据分析师和数据工程师都能进行流式分析。

使用场景
异步微服务集成

对于传统服务集成,Pub/Sub 充当着消息传递中间件的角色,而对于现代微服务,则充当着简单通信媒介的角色。推送订阅向 Cloud FunctionsApp EngineCloud Run 上的无服务器网络钩子或者 Kubernetes EngineCompute Engine 上的自定义环境传送事件。如果不可公开网络钩子,或者希望高效处理高吞吐量数据流,则可以使用低延迟拉取传送。

所有特性

至少送达一次 跨区域的同步消息复制和对每条消息的接收情况跟踪可确保任何规模的消息都能至少送达一次。
开放式 开放式 API 和七种语言的客户端库为跨云部署和混合部署提供支持。
一次性处理 Dataflow 支持以可靠且具有表现力的方式对 Pub/Sub 数据流进行一次性处理。
无需预配,一切自动执行 Pub/Sub 没有分片或分区。您只需要设置配额,然后发布并使用即可。
合规性与安全性 Pub/Sub 是符合 HIPAA 标准的服务,提供精细的访问权限控制和端到端加密。
Google Cloud 原生集成 利用与多种服务(例如 Cloud Storage、Gmail 更新事件、Cloud Functions)的集成,实现无服务器的事件驱动型计算。
第三方和 OSS 集成 Pub/Sub 与第三方产品相集成,例如与 Splunk 和 Datadog 的集成(用于日志记录)以及与 Striim 和 Informatica 的集成(用于数据集成)。此外,还通过适用于 Apache Kafka 和 Knative Eventing 的 Confluent Cloud 实现了 OSS 集成,可用于处理基于 Kubernetes 的无服务器工作负载。
还原与重放 将积压消息队列回滚到任何时间点或快照,以便重新处理消息。您也可以快进并舍弃过时的数据。
死信主题 死信主题支持将订阅者应用无法处理的消息搁置在一边供离线检查和调试,以便系统能够无延迟地处理其他消息。
过滤 Pub/Sub 可以根据特性过滤消息,从而减少传送给订阅者的数据量。

价格

Pub/Sub 价格取决于每月数据量。每个月的前 10 GB 数据是免费的。

每月数据量1 每 TB 价格2
前 10 GB $0.00
超过 10 GB 的部分 $40.00

1 如需详细了解价格信息,请参阅价格指南

2 TB 指太比字节,即 240 字节。

如果您使用非美元货币付费,请参阅 Cloud Platform SKU 上以您的币种列出的价格。