所有 Pub/Sub 代码示例
本页面包含 Pub/Sub 的代码示例。如需搜索和过滤其他 Google Cloud 产品的代码示例,请参阅 Google Cloud 示例浏览器。
发布 protobuf 架构类型的消息
将符合协议缓冲区架构的消息发布到附加有协议缓冲区架构的主题。
- Cloud Pub/Sub
- C++
- JavaScript
- TypeScript
- C#
- Node JS
- Java
- Go
- PHP
- Python
- Ruby
更新订阅的“DeadLetterPolicy”
更新关于订阅的“DeadLetterPolicy”。
- Cloud Pub/Sub
- Node JS
- JavaScript
- TypeScript
- PHP
- Python
- Go
- C++
- Ruby
- C#
- Java
发布启用了 OpenTelemetry 跟踪的消息
发布启用了 OpenTelemetry 跟踪的消息,同时使用 Cloud Trace 导出器和 100% 的抽样率。
- Cloud Pub/Sub
- Java
- Node JS
- JavaScript
- Python
- TypeScript
- Go
- C++
使用“DeadLetterPolicy”创建订阅
创建将无法传送的消息转发到死信主题的订阅。
- Cloud Pub/Sub
- TypeScript
- Go
- Ruby
- Node JS
- Java
- JavaScript
- Python
- PHP
- C#
- C++
创建 Cloud Storage 订阅
创建 Cloud Storage 订阅,以便将发布到主题的消息填充到 Cloud Storage 存储分区中
- Cloud Pub/Sub
- PHP
- TypeScript
- Java
- C#
- C++
- Go
- Python
- Node JS
- JavaScript
创建采用“仅传送一次”传送模式的订阅
创建启用了“仅传送一次”功能的订阅。
- Cloud Pub/Sub
- TypeScript
- Node JS
- Java
- PHP
- Go
- Ruby
- JavaScript
- C#
- C++
- Python
接收 Avro 架构类型的消息
接收 Avro 架构类型的消息,将消息数据转换为生成的 Avro 类的对象,然后确认该消息。
- Cloud Pub/Sub
- JavaScript
- C++
- TypeScript
- Go
- Ruby
- Node JS
- Python
- Java
- C#
- PHP
在未先创建订阅的情况下进行乐观订阅
先尝试订阅,然后在收到 NotFound 错误时创建订阅,以最大限度地减少管理操作。
- Cloud Pub/Sub
- Python
- Node JS
- JavaScript
- TypeScript
- C++
- Go
- Java
移除订阅的“DeadLetterPolicy”
移除订阅的“DeadLetterPolicy”。
- Cloud Pub/Sub
- C++
- C#
- TypeScript
- Java
- Ruby
- Go
- PHP
- JavaScript
- Node JS
- Python
创建 BigQuery 订阅
创建 BigQuery 订阅,以便将发布到主题的消息填充到 BigQuery 表中。
- Cloud Pub/Sub
- C#
- Go
- Node JS
- JavaScript
- Java
- Ruby
- Python
- C++
- TypeScript
- PHP
使用流控制设置发布消息
使用自定义流控制设置创建发布者客户端,并使用它来发布一些消息。
- Cloud Pub/Sub
- Ruby
- TypeScript
- JavaScript
- Node JS
- Java
- Go
- Python
- C++
使用 Cloud Storage 提取功能创建主题
创建从 Cloud Storage 存储分区提取数据的 Pub/Sub 主题
- Cloud Pub/Sub
- JavaScript
- Node JS
- TypeScript
- C++
- Java
- Python
- Go
使用排序键恢复发布
使用排序键发布失败时,发布者中具有相同排序键的已排入队列消息以及此排序键的未来发布请求会失败。此示例介绍在发生此类故障时如何恢复启用了排序键的发布。
- Cloud Pub/Sub
- Ruby
- Java
- TypeScript
- C#
- Go
- C++
- Node JS
- Python
- JavaScript
使用“仅传送一次”功能进行订阅
接收已启用“仅传送一次”功能的订阅中的消息。
- Cloud Pub/Sub
- Go
- C#
- Python
- PHP
- JavaScript
- Java
- Ruby
- TypeScript
- C++
- Node JS
发布 Avro 架构类型的消息
将符合 Avro 架构的消息发布到附加有 Avro 架构的主题。
- Cloud Pub/Sub
- C#
- JavaScript
- PHP
- C++
- Go
- Python
- Ruby
- Java
- Node JS
- TypeScript
接收带有传送尝试信息的消息
输出使用“DeadLetterPolicy”的订阅中的消息的尝试字段。
- Cloud Pub/Sub
- Java
- C#
- Ruby
- C++
- TypeScript
- Python
- Node JS
- PHP
- JavaScript
- Go
创建一个用于从 Kinesis 提取消息的主题
创建一个用于从 Kinesis 提取消息的主题
- Cloud Pub/Sub
- Python
- C++
- Java
- Go
- JavaScript
- Node JS
- TypeScript
通过批处理设置进行发布
使用自定义批处理设置创建发布者客户端,并使用它来发布一些消息。
- Cloud Pub/Sub
- Node JS
- C++
- Java
- JavaScript
- TypeScript
- PHP
- Python
- Ruby
- Go
- C#
创建启用了 OpenTelemetry 的订阅方应用
创建启用了 OpenTelemetry 且 100% 跟踪的订阅者应用
- Cloud Pub/Sub
- JavaScript
- TypeScript
- C++
- Java
- Go
- Python
- Node JS
接收 Proto 架构类型的消息
接收协议缓冲区架构类型的消息,将消息数据转换为生成的 Proto 类的对象,然后确认该消息。
- Cloud Pub/Sub
- Python
- C++
- JavaScript
- C#
- Java
- Ruby
- TypeScript
- Node JS
- PHP
- Go
将订阅与主题分离
当主题管理员客户端分离订阅时,订阅不再允许读取该主题中的任何数据,且舍弃此订阅上存储的消息(未确认和确认)。
- Cloud Pub/Sub
- JavaScript
- C#
- C++
- Java
- Node JS
- PHP
- Ruby
- TypeScript
- Python
- Go
使用 Dataflow 从 Pub/Sub 传输到 Cloud Storage
使用 Dataflow 将 Pub/Sub 消息流式传输到 Cloud Storage。
- Cloud Pub/Sub
- Java
- Python