所有 Pub/Sub 精简版代码示例

此页面由 Cloud Translation API 翻译。

删除精简版主题

删除精简版主题。

PubSub Lite
Go
Python
Java

在 Apache Kafka 中接收消息

使用用于 Kafka Consumer API 的 shim，从 Pub/Sub Lite 主题接收消息

PubSub Lite
Java

创建一个 Lite 订阅，用于将消息写入 Pub/Sub 主题

PubSub Lite
Python
Java
Go

获取精简版预留

获取 Pub/Sub 精简版预留

PubSub Lite
Java
Go
Python

列出精简版预留

精简版 Pub/Sub 精简版预留

PubSub Lite
Go
Python
Java

更新精简版预留

更新 Pub/Sub 精简版预留

PubSub Lite
Python
Java
Go

删除精简版预留

删除 Pub/Sub 精简版预留

PubSub Lite
Python
Java
Go

创建精简版预留

创建 Pub/Sub 精简版预留

PubSub Lite
Python
Java
Go

还原到 Pub/Sub Lite 订阅中的某个位置

还原到 Pub/Sub Lite 订阅中的某个位置，以开始从该位置接收消息。

PubSub Lite
Python
Go
Java

发布

将消息发布到单分区精简版主题，并异步解决发布 Future。

PubSub Lite
Python
Go
Java

删除精简版订阅

删除精简版订阅。

PubSub Lite
Go
Java
Python

获取精简版主题

输出精简版主题的名称、保留配置和分区配置。

PubSub Lite
Python
Go
Java

使用 Dataflow 将 Pub/Sub Lite 流式传输到 Cloud Storage

本示例介绍如何创建一个 Apache Beam 流处理流水线，该流水线可从 Pub/Sub 精简版中读取消息，使用固定大小的窗口函数对消息进行分组，并将其写入 Cloud Storage。

PubSub Lite
Java

创建精简版主题

创建单分区精简版主题，并配置其保留期限、每个分区的存储空间和发布吞吐量缩放比例。

PubSub Lite
Python
Go
Java

更新精简版订阅

更新精简版订阅的传送模式。

PubSub Lite
Python
Java
Go

从 Spark 读取 Pub/Sub 精简版（流式传输）

在流式传输模式下从 Spark 集群读取来自 Pub/Sub 精简版订阅的消息。

PubSub Lite
Python

获取精简版订阅

输出精简版订阅的名称、主题路径和传送配置。

PubSub Lite
Python
Go
Java

通过自定义特性进行发布

发布具有自定义属性的消息。

PubSub Lite
Java
Go
Python

列出精简版主题

列出项目中的精简版主题。

PubSub Lite
Go
Java
Python

列出主题中的精简版订阅

列出精简版主题中的精简版订阅。

PubSub Lite
Python
Java
Go

从 Apache Kafka 发布消息

使用用于 Kafka Producer API 的 shim，将消息发布到 Pub/Sub Lite 主题

PubSub Lite
Java

通过排序键进行发布

使用排序键发布消息。系统会对排序键进行哈希处理以映射到分区。具有相同排序键的消息会被发布到同一分区。如果分区被填满，最早的消息会被覆盖。

PubSub Lite
Java
Go
Python

创建精简版订阅

使用选定的递送模式创建 Lite 订阅。

PubSub Lite
Go
Java
Python

使用批处理设置发布

使用批处理设置发布消息。

PubSub Lite
Go
Java
Python

列出项目中的精简版订阅

列出项目中的精简版订阅。

PubSub Lite
Go
Java
Python

更新精简版主题

更新精简版主题的保留期限、缩放比例（吞吐量容量）和每个分区字节数（存储容量）。

PubSub Lite
Java
Go
Python

从 Spark 写入 Pub/Sub 精简版（流式传输）

在流式模式下将消息从 Spark 集群写入 Pub/Sub 精简版主题。

PubSub Lite
Python

所有 Pub/Sub Lite 代码示例

过滤条件