使用托管在Google基础架构上的可靠，多对多的异步消息传递来连接您的服务。 Cloud Pub / Sub会根据您的需要自动扩展，并为构建您自己的强大全球服务奠定基础。
Workload Identity 在使用 gevent monkey patching 时停止工作
我有一个应用程序，其中包括一个 Flask API 服务器和一个 worker 来处理来自 PubSub 的消息。它们作为单独的容器在 Kubernetes 中的单独 pod 上运行。 我已经迁移到使用 Workload
我目前正致力于将一个简单的发布/订阅功能部署到 Firebase 功能。 以下是我完成的步骤： 在 Cloud Pub/Sub 中创建主题名称 subscription-listener 启用 Cloud Run（我
如何将 Firebase 模拟器与 Google 云发布/订阅一起使用？
我正在使用 Firebase 函数来收听云发布/订阅消息。但是，当我在 firebase 本地模拟器上运行时，我无法从消息中获取结果 我做了什么： 设置 firebase 函数 p...
我在项目 B 中创建了一个需要身份验证的 Cloud Run 应用程序，其服务帐户为：test 在项目 A 中，我有一个 pubsub 主题：ProjectATopic 我部署了 cloud run 并添加了权限...
Spring StreamBridge 在处理流桥上的批量消息时内存不足
我正在使用流桥通过 pubsub 发送消息 我有一些 100k 消息需要推送到 pubsub。我正在使用 5 个线程的执行程序池来完成这项工作 private void fetchAndPublish(列表<
我正在尝试在谷歌云中创建一个计划函数，该函数从云函数触发器发送的事件开始，运行一段时间，然后根据条件或其他条件停止
PERMISSION_DENIED 使用带有 API 密钥的 GCP PubSub REST API 时
给出 curl --request POST 'https://pubsub.googleapis.com/v1/projects/myproject/topics/mytopic:publish?key=[API_KEY]' --header 'Content-Type: application/json' --data '{"messages":[]}'...
我有两个源，它们有很多消息（太多无法在内存中或在一台机器上处理它们），我必须组合这些消息以进行进一步处理。为了实现这一点，我想...
我创建了一个发布/订阅功能，它试图从我的 Firestore 数据库中获取一些数据，对其进行处理，然后通过电子邮件将其发送出去。看起来我正在从数据库调用中按顺序获取数据，但是
探索从 Gmail 中实时抓取彭博电子邮件而不会产生 Pub/Sub API 成本
我正在尝试开发一个脚本，可以实时从我的 Gmail 收件箱中抓取彭博电子邮件。看完Gmail的文档，发现可以使用Push来实现
无法在 GCP 监控上获取指标比率：错误 400：分子是增量指标但分母不是增量指标
我正在尝试根据 PubSub 订阅中失败消息的比率创建警报策略。我喜欢使用 pubsub.googleapis.com/subscription/dead_letter_message_count 作为分子，并且
如何给谷歌云 Eventarc 正确的权限，以便它可以触发云功能？
我已经根据谷歌教程成功部署了带有存储触发器的第二代云功能。 当我在 shell 中运行测试命令时，Cloud Function 起作用。但如果我尝试真正的
PubSub BigQuery 订阅具有不同 publish_time 的重复消息
最近，我们实施了 PubSub BigQuery 订阅，并注意到使用以下配置将重复消息推送到 BigQuery。 写入元数据：已启用 删除未知字段：已禁用
如果订阅者之一未能在 Google Pubsub 中确认，订阅者消息接收机制是什么
如果订阅者之一未能在 ackDeadline 内确认消息，我将了解 Google PubSub 消息重新传递机制的一些概念。我想澄清一些问题......
我使用 GCP 客户端库在我的 spring-boot 应用程序中实现 pub/sub 模型。为了进行身份验证，我正在使用 GOOGLE_APPLICATION_CREDENTIALS 路径环境变量。它适用于其他版本...
通过 pub sub 推送通知运行多次在存储桶中上传文件触发的云运行
我有一个 Cloud Run 服务（Express Endpoint），它在文件上传到 Cloud Storage 存储桶时由 Pub/Sub 推送通知触发。然而，Cloud Run 服务被触发了
我很好奇了解 GCP 的 PubSub 的实现。虽然 Pubsub 似乎指向遵循 Publish-Subscribe 设计模式，但它似乎更接近 AWS 的 SQS（队列）而不是 AWS SNS（那个......
Google 云 - 发布/订阅 - 使用元数据写入 Bigquery - 缺少字段
我正在尝试通过创建一个名为 dl_topic 的新主题和一个名为 dl_subs 的订阅来启用死信主题。对于 dl_subs 订阅，我正在启用 Write to BigQuery 选项...
我有 terraform 脚本定义一个 pubsub 订阅推送数据到 bigquery 如下： 资源“google_pubsub_subscription”“我的订阅”{ 名字=“我的-
GCP VM Autoscaling 实例根据未确认的发布/订阅消息生成比预期更长的时间
我有一个应用程序可以进行视频转码和图像分类。现在，每个作业大约需要 2-5 分钟，我正在根据