使用托管在Google基础架构上的可靠，多对多的异步消息传递来连接您的服务。 Cloud Pub / Sub会根据您的需要自动扩展，并为构建您自己的强大全球服务奠定基础。
部署后调用 BigQuery、Pub/Sub 和 Secret Manager 时出现 404 错误
从昨天下午 6:30 开始，每个 BigQuery、Pub/Sub 和 Secret Manager 请求都开始失败，并在每个 API 调用中出现 404 错误。我在这个时候部署了一个新版本 - 所以这看起来像是一个
在订阅上应用过滤器时，Python Pubsub 订阅者客户端不会拉取消息
我在我的 Python Web 应用程序中使用 Pubsub 流式拉取订阅。当我没有应用任何订阅过滤器时，订阅者客户端能够成功从
如何使用PublisherServiceAsyncClient
我正在尝试使用 pubsublite 中的 AsyncPublisherClient pip 安装 google-cloud-pubsublite==1.8.3 从 google.cloud 导入 pubsublite_v1 pubsub = pubsublite_v1.AsyncPublisherClient() 错误：模组...
pubsub 推送启用身份验证的 Spring Boot 应用程序
我正在尝试在 Spring Boot 应用程序中创建一个端点以由 pubsub 消息调用。 该应用程序已经为通过 firebase 登录的用户启用了一些安全性。 安全性
我有一个在 uvicorn 服务器内运行的 python 应用程序。我已经创建了一个 Pub/sub 订阅者并尝试从我的 main.py 中启用它。我正在使用流式拉取订阅。现在，我的
使用 GCP PubSub 源在 Flink 作业上获取 http2 异常
我有一个使用 GCP PubSub 作为源的 flink 作业。尽管我能够处理在 pubsub 主题上收到的消息，但我发现它存在一些问题： 已处理的消息较早...
无法使用 C# .NET Framework 4.8 将消息发布到 Pub/Sub 模拟器
我无法使用 C# .NET Framework 4.8 将消息发布到 Google Pub/Sub 模拟器。在生产中，代码可以工作。 gcloud 模拟器就发生了这种情况。 另外，同样的代码...
每秒向 PubSub 主题发布 5 条消息，无 Worker 的拉动订阅积压不会增长
我正在尝试调整从 PubSub 主题进行请求订阅所需的工作人员数量，每秒获取大约 5 条消息。当我关闭所有工作人员时，我希望看到积压字节开始......
我正在致力于集成 RabbitMQ 和 GCP Pub/Sub。 我正在使用 Pika 库和 Python。连接是通过BlockingConnection 建立的。 我的消费者作为单独的线程运行。最大预期
创建 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 上的教程，并发现...