使用托管在Google基础架构上的可靠，多对多的异步消息传递来连接您的服务。 Cloud Pub / Sub会根据您的需要自动扩展，并为构建您自己的强大全球服务奠定基础。
创建 Google Pub/Sub 订阅，并将过期期限设为永不
根据文档，我们可以将 Google Pub/Sub 订阅的过期期限设置为“永不过期” 您能分享一下 Java 代码吗？我目前有以下代码 公开
如何使用 terraform 将发布者和订阅者角色正确分配给死信主题
我有一个在 terraform 中定义的 Cloud Storage 存储桶。该存储桶已启用通知。通知将发布到 Pub/Sub 主题，然后由 Pub/Sub 订阅使用。我有...
llegalStateException：找不到 TLS ALPN 提供商；没有可用的 netty-tcnative、Conscrypt 或 Jetty NPN/ALPN
我正在尝试使用 Google PubSub。该代码相对简单。 PubsubMessage 消息 = PubsubMessage.newBuilder() .setData(ByteString.copyFromUtf8(messageBody)) .putAllAttributes(
使用 GCP PubSub 源时在 Flink 作业上获取 DEADLINE_EXCEEDED
在我正在使用的 Flink 作业中使用 Pub/Sub 源时，以下错误每 15 秒就会重复一次。 https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/pubsub/ 苏...
我正在编写一个计划的云函数，它订阅一个 pubsub 主题并从 pubsub 中提取所有消息，直到队列空闲。我想确认一些消息，但确认其他消息，以便它们
为什么 context.Done() 永远不会在超时上下文中的 select 语句中被调用
这是我的代码，我试图从 google pub sub 读取消息 func (p *PubSubSource) Read(_ context.Context, readRequest 来源dk.ReadRequest, messageCh chan<- sourcesdk.Message) { ...
我们的 Spring Boot 应用程序使用 Messaging Gateway 来发布和使用来自 GCP pubsub 的消息。我们使用的现有主题及其订阅没有启用排序。现在我们想要广告...
我的工作流程 使用云函数将数据从 Pub/Sub 流式传输到 BigQuery。 数据在流缓冲区中保留 90 分钟，因此我无法执行 Update 语句。 我需要更新结果列...
java中的Pub/sub - 长寿与短命的Publisher，哪个是正确的方法？
我们目前正在 Java 项目中实现 pub/sub，我有一个关于 Publisher 对象应该存在多长时间的问题。 大多数教程都相对简单，仅显示以下模式： 打电话给...
我已设置 PubSub BigQuery 订阅。我的主题有一个架构，并且我能够成功写入 BigQuery 表。 我一直在对工作流程进行压力测试，以确保所有消息都...
Google Pubsub Python 客户端库订阅者随机崩溃
有人可以帮助我使用 Google Pubsub Python 客户端库吗？我正在密切关注 https://cloud.google.com/pubsub/docs/pull#pubsub-pull-messages-async-python 上的教程，并发现...
在 Windows 上使用 gcloud CLI 发布消息时，Firebase PubSub 函数中出现 JSON 解析错误
我正在尝试在云函数中设置计费 PubSub 侦听器，以限制计费并防止意外成本。我查看了 youtube 系列，但开始使用 v2 来实现它，如概述的 h...
我想阅读谷歌为特定帐户返回的通知列表。看来我的旧程序无法正常工作，而且我找不到新 API 的示例。 首先，我们需要设置...
如何设置 pubsubTopic 以便在 java 中使用 mybusinessnotifications.googleapis.com 列出 google 帐户中的通知
我想阅读谷歌为特定帐户返回的通知列表。看来我的旧程序无法正常工作，而且我找不到新 API 的示例。回到代码，让我们
如何为我的 GKE 部署的应用程序提供对 Google Pub/Sub 的访问权限？
我部署了一个利用 google cloud pub/sub 的 kotlin 后端应用程序。我最近使用 Cloud Run 部署了该应用程序，它运行良好，可以完全访问 Pub/Sub。 现在因为...
是否可以将 MQTT 代理 mosquitto 桥接到 Cloud PubSub？
我有一个本地 mosquitto 代理，我想将其连接到 Google Cloud pubsub 队列。 我研究了 Google Cloud IOT 核心，但运气不好，我似乎无法连接到它 这是我的蚊子
在我们的项目中，我们使用 GCP pubsub 将异步作业从应用程序路由到工作线程。 为了订阅，我们使用 pubsub_v1.SubscriberClient 中的 subscribe 方法。它返回subscriber.fut...
尝试向 GCP Pubsub 主题发布多条消息时如何修复“上一个频道未正确关闭错误”
我正在尝试使用 Spring Boot 框架将消息发布到 GCP pubsub 主题。偶尔会遇到错误，显示托管通道未关闭，但我不确定我到底需要在哪里......
通过 GCP 云函数在 pub/sub onMessagePublished 事件上使用机密
是否可以在onMessagePublished上使用秘密依赖数组（云函数v2）？ 它看起来不像有一个参数可以接受它，如果我尝试将其包含为...
我有firebase云计划功能。它在前两个时期运行良好，但随后就停止了。我的功能代码如下。我没有 javascript 经验。我的代码有什么错误吗？