使用托管在Google基础架构上的可靠，多对多的异步消息传递来连接您的服务。 Cloud Pub / Sub会根据您的需要自动扩展，并为构建您自己的强大全球服务奠定基础。
在文档中我们可以找到： 否定确认消息（nacked）。订阅者取消消息会导致 Pub/Sub 立即重新传送该消息。当订阅者拒绝消息时...
我正在寻找一种延迟一分钟发布 pubsub 消息的方法。我已经浏览了他们的 API 但根本找不到方法。有人可以在这方面对我有帮助吗？ 很好的描述...
仅当 ack-mode 设置为 MANUAL 时，才可以在使用 Spring Cloud Stream 时手动确认 gcp pub sub 消息
我有一个使用 Spring Cloud Stream Binder 的 GCP pub sub 实现。 仅当 ackMode 设置为 MANUAL 时，我才想对消息进行手动确认。 目前我正在使用 @豆
使用 Spring Cloud Stream 与 gcp pub sub 和 Rabbit 绑定的应用程序失败
我正在尝试构建一个简单的测试 Spring Boot 应用程序，以使用 Spring Cloud Stream 使用来自 GCP pubsub 和 RabbitMq 的消息。 我在尝试使用 spring.cloud.stream.binders 时遇到问题 我是
Java 客户端不会从 GCP Pub/Sub 主题检索未确认的消息
我有一个配置了 Spring Boot 客户端 春天： 云： 全局控制点： 发布订阅： 出版商： 启用消息排序： true 订户： 流量控制： ...
带有 Pub/Sub 触发器的云函数无法将电子邮件附件保存到云存储
我正在构建一个带有 Pub/Sub 触发器的 Google Cloud Function 来处理电子邮件附件。该功能应该将允许的电子邮件地址中的附件保存到指定的云存储中
从 GCP Composer (Airflow) 到 GCP PubSub 的连接错误
我尝试订阅 GCP PubSub 以从 GCP Composer 获取消息，但出现以下错误： airflow.exceptions.AirflowException：未定义 conn_id `google_cloud_default` 我的...
更新 GCP pubsub 中的消息保留期限是否具有追溯效力？
文档没有明确说明此更改（从当前的 7 天到 31 天）是否追溯执行。更具体地说，这部分： 配置订阅以保留已确认的状态
如何在 Google Cloud 中为推送订阅设置正确的端点 URL？
我最近遇到了删除默认 Pub/Sub 订阅后未调用 Google Cloud Function 的问题。 为了排除故障，我使用
kotlin / java 中的 Google Pub/Sub 客户端出现意外的 TLS 异常
我正在android上编写一个应用程序，它利用Google pubsub并且已经用go编写了相应的客户端。 请提前原谅我，因为这是我的第一个 Android 应用程序，也是第一次使用 k...
使用 OpenTelemetry 与 Spring Cloud Trace 进行 Spring Cloud GCP PubSub 跟踪
我正在尝试跨不同的 Spring 微服务跟踪 PubSub 消息传递。我们在 GKE 上运行两个 Spring 微服务。服务 1 发布到 PubSub，服务 2 订阅同一主题....
我正在尝试在本地计算机上从 Google 运行此示例。我正在使用 PubSub 模拟器和 Beam 2.60.0，通过 --runner=DirectRunner 执行。 ... 选项.setStreaming(true); 选项.setPubsubRoot...
为什么 GCP Cloud Run 在使用 Python pub/sub 库时不使用 Compute Engine SA 进行身份验证？
我正在尝试使用 Python 库从云运行将消息发布到 pubsub 主题。我已向 Compute Engine 服务帐户授予 pubsub 管理员角色，并通过 gcloud 命令，我能够
如何通过golang包为google pubsub设置重试策略
通过 go pubsub 包似乎根本不可能影响订阅的重试策略。 https://pkg.go.dev/cloud.google.com/go/pubsub#SubscriptionConfig 包含重试策略，w...
如何在Python中使用属性作为变量将消息发布到GCP pub/sub主题
在这个Python示例代码中，我想将“origin”和“username”作为变量。 C++代码有一个例子，但对于python没有具体的例子 从 google.cloud 导入
我有一个订阅主题的 Google Cloud Function。当云调度程序每 5 分钟调用 GCP Pub/Sub 时，我们的 GCP Pub/Sub 会向该主题发布一条消息。问题是云功能...
我们有一个场景，我们希望使用 GCP pub sub 来订购消息传递。 我有一个关于我们在
我正在开发一些电子邮件自动化，需要使用 GMail API 和 PubSub，如 Google 文档中所述：https://developers.google.com/gmail/api/guides/push。 此设置需要
使用 GCP pubsub 订阅，我们目前以这种方式拉取消息： 与订阅者客户端： 尝试： self.subscriber_future =subscriber_client.subscribe(
使用 Google Bigtable 和 Cloud Pubsub 的组合偶尔会挂起
我使用Gunicorn（Gevent）+ Flask链制作了一个Web API应用程序。 当它收到数据时，它使用单例模式从 Bigtable 中的 5 个不同表中读取行，然后执行 cpu 密集型任务。 之后...