使用托管在Google基础架构上的可靠，多对多的异步消息传递来连接您的服务。 Cloud Pub / Sub会根据您的需要自动扩展，并为构建您自己的强大全球服务奠定基础。
我有2个云函数，一个云函数发布消息，另一个云函数（transform.js）从发布的消息中触发。现在在变换云函数中，我...
如何设计高效的 Pub/Sub 拉动订阅者以实现最大吞吐量和容错能力？
我正在使用谷歌的发布/订阅将某些任务的处理（由发布/订阅主题上的消息表示）移至后台。由于已知的暂时性错误，某些任务预计会定期失败
卡在 Google Meet 的 Google PubSub 订阅中
我正在尝试使用目标资源建立Google Pub/Sub。 请参阅：https://developers.google.com/workspace/events#supported-events 当我尝试使用 python LINK 订阅资源时失败...
是否可以使用访问令牌对谷歌云 PUB/SUB Node.js API 客户端进行身份验证？
是否可以在没有服务帐户的情况下使用通过 OAuth 流接收的访问令牌来验证 google cloud pub/sub Nodejs 客户端？ 我在开始部分之前尝试过，但它需要服务帐户...
Google Pubsub 云存储订阅，可将消息合并到同一个 avro 文件中
我有一个没有架构强制的 Google Pubsub 主题（我也不希望有架构强制） 我有一个 Google Pubsub 云存储订阅设置，用于： 将消息刷新到 GCS（Google Cl...
事件显示在 Google Home 应用程序中，但未显示在发布/订阅消息中？
正如标题所述，我在 Google Home 应用程序中看到我的有线巢摄像头的事件，但没有消息从它发送到 pub/sub。 我的恒温器和门铃发出的消息都发送得很好，而且......
我的要求是使用Python脚本通过pubsub将文件批处理/流式传输到谷歌云存储中。 我使用了下面的 python 文件，并且能够看到从主题发布到
Google pubsub SubscriberClient AttributeError：“生成器”对象没有属性“add_done_callback”
我正在开发一个项目，必须使用我的 GCP Pubsub 订阅中的一些消息。在本地我可以正常消费消息。 但是当我发布对云中容器的更改时（某些事情
gcloud 发布 Pub/Sub JSON 消息，其中 JSON 属性包含空格字符
我有一个名为 states/list.json 的 JSON 文件，我想使用 gcloud CLI 发布内容。 { “国家”：[ { “id”：“SE”， “name”：“瑞...
我将相当大量的小项目（大约 100k）推送到 PubSub 队列中。然后，云功能将处理手头的任务。此设置导致我出现以下错误。 有谁知道...
如果我们将 GCP pubsub 中的保留期设置为 7 天而不是 2 或 3 天，会对成本产生影响吗？ 假设我保留了 7 天，但无论我积压了什么，一天之内就会被清除。
如何检查 Cloud Pub/Sub 模拟器是否已启动并正在运行？
我有 GC 功能，我使用 Cloud Pub/Sub 模拟器在本地开发和测试。 我希望能够从 Go 代码中检查 Cloud Pub/Sub 模拟器是否已启动并运行。如果没有，我会...
Google Cloud Functions：Pub/Sub 与 Rest 触发
Pub/Sub 是否是 Kubernetes Engine (GKE) api 服务器和云功能 (GCF) 之间的通信速度明显更快的方式？ GK之间是否可以使用Pub/Sub进行这样的通信...
是否可以使用访问令牌对谷歌云 PUB/SUB Node.js API 客户端进行身份验证？
是否可以在没有服务帐户的情况下使用通过 oAuth 流程收到的访问令牌来验证 google cloud pub/sub Nodejs 客户端？ 我在开始部分之前尝试过，但它需要服务......
我有一个容器化的 API，并在云运行中运行。如何获取正在执行云运行的当前项目 ID？我努力了： 我在日志中的文本有效负载中看到它，但我不...
GCP Pub Sub 中的订阅确认设置是否会自动被拉取订阅的客户端库覆盖？
我们正在使用 GCP Pub Sub 客户端库 (com.google.cloud.pubsub.v1) 来处理来自订阅的消息。 请求订阅的默认 ACK 截止时间为 10 秒。 寻找一些
Google Cloud - 在cloudbuild中设置云功能的默认重试
我想知道是否有办法直接在云函数的yaml中配置“失败重试”触发策略。 至于现在，我找到了有关工作流程的文档，或者只是将其标记为...
我不明白为什么AWS kinesis在配置模式下的吞吐量非常低。 文档参考 每个分片可支持高达 1 MB/秒或 1,000 条记录/秒的写入吞吐量或高达 2 MB/秒或...
我有一个订阅 PubSub 订阅的 Cloud Run FastAPI 应用程序。它将处理突发流量，因此在给定时间可能有 0 个实例，也可能有 20 个实例。 假设我有 10 个
我正在尝试从 PCF 环境（Spring boot 应用程序）连接 google Pub/Sub。应用程序已成功从credentials.json 文件加载凭据并打印项目ID。但正在打印...