使用托管在Google基础架构上的可靠，多对多的异步消息传递来连接您的服务。 Cloud Pub / Sub会根据您的需要自动扩展，并为构建您自己的强大全球服务奠定基础。
我正在尝试在本地计算机上从 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 密集型任务。 之后...
适用于 Java 的 Google Cloud Pub/Sub 客户端库不使用本地模拟器
我正在尝试使用 Google 云 Pub/Sub 模拟器来测试我的 scala 应用程序。文件说明如下 - 运行 env-init 命令来确定和设置
如何设置将 Cloud Storage 文件内容发布到 GCP 中的 Pub/Sub
我想通过pubsub获取云存储文件的内容并通过arcsight代理收集它 我创建了服务帐户并授予了 pubsub 编辑器和存储对象查看器权限，并且
GCP Pubsub 订阅写入 bigquery - 使用主题架构与表架构
探索使用订阅类型“写入 Bigquery”将数据从 pubsub 主题加载到 Bigquery 表。配置订阅时，有 2 个选项：使用主题架构和使用表
如何向我的 Pub/Sub Cloud Run (gen2) 函数添加类型安全？
我有一个运行 TypeScript/Node.js 的 Google Cloud Run Function（以前称为 Cloud Functions 第二代）。 Pub/Sub 教程中的文档显示您获得了一个 cloudEvent，但如何添加类型...
我需要从 google.cloud 模块导入 Pubsub_v1 和 bigquery。我已经安装了它，pip freeze 显示如下： gapic-google-cloud-pubsub-v1==0.15.4 谷歌云bigquery==0.26.0 谷歌云-p...
Pub/Sub StreamingPull 无法使用节点客户端工作
我正在尝试使用 Pub/Sub 中的 StreamingPull。有消息发布，但我没有看到任何回复。对于以下代码 const {v1 } = require('@google-cloud/pubsub'); 常量请求 = {...
我一直在遵循 Google 教程“将 Pub/Sub 与 Cloud Run 结合使用”教程中的步骤。 一切正常，直到允许 Google 的服务帐户创建身份验证令牌（与 Pub/Sub 2.b 集成） 她...
我目前面临的问题是，有时当发布 pubsub 消息时，该消息会直接进入死信，而不会尝试将其传递给相应的订阅者。
_CHANGE_TYPE 在从 Pub/Sub 流式传输 Google Big Query 行时不起作用
以下链接 (https://cloud.google.com/pubsub/docs/bigquery#change_data_capture) 指出，当从 Pub/Sub 将行流式传输到 Google Big Query 时，我们应该能够设置 _CHANGE_TYPE = 'U. ..
GCP Pub/Sub 到 BigQuery 向 NUMERIC 列写入错误值
我将采用以下格式将 JSON 发布到 Pub/Sub： {“阅读”：“11202.8”} 数字被编码为字符串以强制明确的精度。使用 P...
从 FastAPI 应用程序向 GCP PubSub 发布消息
我通过在 GCP 的 Cloud Run 上运行的 FastAPI 应用程序接收来自 Twilio 的 Webhook。该应用程序接收消息并将其发布到 PubSub 主题。该主题有消息排序...