注入事件以流式插入到 BigQuery、数据湖或运营数据库。
新客户可获得 $300 赠金,用于抵扣在 Pub/Sub 上的支出。所有客户每月可免费获享 10 GB 的消息注入或传递额度,不计入赠金额度。
优势
轻松实现高可用性
跨可用区的同步消息复制和对每条消息的接收情况跟踪可确保任何规模的消息都能安全可靠地送达。
无需规划,一切自动执行
可自动扩缩和自动预配,而无需设置分区,因此可以免去提前规划的麻烦,并确保工作负载从一开始便可用于生产用途。
面向实时数据系统的简单开放基础平台
这是一种快速、可靠的小型记录写入方式,支持任何数据量,可作为实时和批处理流水线的入口点,将数据馈送至 BigQuery、数据湖和运营数据库。您可以将其与 Dataflow 中的 ETL/ELT 流水线搭配使用。
主要特性
原生集成 Dataflow,支持在 Java、Python 和 SQL 环境中对事件数据流进行可靠、表达型的一次性处理和集成。
可选的按键排序功能可简化有状态应用逻辑而不影响横向扩容能力,并且无需分区。
最新资讯
订阅 Google Cloud 简报,了解产品动态、活动安排、特别优惠以及更多资讯。
文档
使用场景
Google 的流式分析让数据从生成的那一刻起便更有条理、更具价值且触手可及。我们的流处理解决方案以 Pub/Sub 以及 Dataflow 和 BigQuery 为基础而构建,可预配所需的资源来注入、处理和分析数量不断波动的实时数据,提供实时业务数据洞见。这种抽象化的预配降低了复杂性,使数据分析师和数据工程师都能进行流式分析。

对于传统服务集成,Pub/Sub 充当着消息传递中间件的角色,而对于现代微服务,则充当着简单通信媒介的角色。推送订阅向 Cloud Functions、App Engine、Cloud Run 上的无服务器 webhook 或者 Google Kubernetes Engine 或 Compute Engine 上的自定义环境传送事件。如果不可公开 webhook,或者希望高效处理高吞吐量数据流,则可以使用低延迟拉取传送。
所有特性
| 至少一次传达 | 跨地区的同步消息复制和对每条消息的接收情况跟踪可确保消息在任何规模下都能至少传达一次。 |
| 开放 | 开放 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 的 Confluent Cloud 和适用于基于 Kubernetes 的无服务器工作负载的 Knative Eventing 提供 OSS 集成。 |
| 跳转与重放 | 将积压消息队列回滚到任何时间点或快照,以便重新处理消息。您也可以快进并舍弃过时的数据。 |
| 死信主题 | 死信主题支持将订阅者应用无法处理的消息搁置在一边供离线检查和调试,以便系统能够无延迟地处理其他消息。 |
| 过滤 | Pub/Sub 可以根据属性过滤消息,从而减少传送给订阅者的数据量。 |
价格
Pub/Sub 价格取决于每月数据量。每个月的前 10 GB 数据是免费的。
每月数据量1 | 每 TB 价格2 |
|---|---|
前 10 GB | $0.00 |
超过 10 GB | $40.00 |