使用托管在Google基础架构上的可靠,多对多的异步消息传递来连接您的服务。 Cloud Pub / Sub会根据您的需要自动扩展,并为构建您自己的强大全球服务奠定基础。
NodeJs Unable to detect a Project Id in the current environment Pubsub
我们正在实施 PubSub Using Client Libraries 以使用 Linux 和 NodeJs 发布数据。还遵循了 Quickstart: Using Client Libraries 的所有步骤。 但是我们收到以下错误...
cloud run - 403 User not authorized to perform this action (PUB/SUB)
我有一个附加到我的云运行的服务帐户,它可以访问秘密和 api 密钥等服务。 我最近添加了一个新角色,如 pub sub publisher 和 get topics 和 list topic...
我正在尝试销售 Google 订阅产品。 当用户在应用程序中购买订阅产品时,通知会自动发送到 Google Pub/Sub,并通过推送订阅发送到后端 ...
多个谷歌云项目链接到 play console 中的 API 访问
我们在一个开发者帐户中上传了多个应用程序,这些应用程序具有应用程序订阅功能。上传到游戏控制台的所有应用程序都有相应的谷歌云项目有发布子集......
为什么我们需要在 GCP 中使用 Cloud Scheduler 发布/订阅?
我正在读这个 https://cloud.google.com/scheduler/docs/tut-pub-sub 他们使用如下设置: Cloud Scheduler -> PubSub -> Cloud Function -> 外部服务 如果我有一份 cron 工作...
我有一个 python 代码,可以从 Pub/Sub 读取记录并写入 Google Cloud Storage Bucket。 我在本地运行代码并且它运行良好,我将它部署在云函数中(在同一个程序中......
我为我的 Pub/Sub 订阅(订阅类型 PUSH)配置了一个死信,最大投递尝试次数为 5 次。不过,我在日志中看到超过 5 次重试。发布者和订阅者...
我正在编写一个 gcp pub/sub 应用程序,但我无法正确地 nack() 一条消息。您能否查看以下代码并提供帮助 - @成分 公开课 PubSubEventConsu...
在 python 中使用 apache beam 从 pubsub 输出中提取列值
我正在尝试从 PubSub 订阅中提取数据,最后,一旦数据被提取,我想做一些转换。目前,它是字节格式。我尝试了多种方法来提取...
在 Apache Beam 中使用 PubsubIO.writeStrings() 的优势
Apache Beam 提供 PubsubIO.writeStrings() 方法,该方法返回一个 PTransform,可用于直接从 PCollection 将消息写入 Pubsub:示例。 有没有什么明显的优势...
如何消费来自pubsub的多条消息?这似乎是一个简单的问题,应该有简单的解决方案,但目前我可以找到简单的方法来使用 spring-
我正在尝试在 pubsub 中创建一个模式,我计划在创建主题时使用它。 我的 avro 模式是嵌套的,它看起来像这样: “类型”:“记录”, “名字”:...
将 Pandas Dataframe 行发布为 PubSub 消息
我的任务是将 pandas 数据框的行发布为 pubsub 消息。 最好的做法是什么?我的熊猫数据框可能包含大约 100 万条记录。 这是我的一个例子......
我有一个包含各种发布/订阅主题的 GCP 项目,我想订阅所有这些主题并在创建它们时自动附加它们(我的用例是我...
我遇到了一个问题,内存分配峰值每天发生 ~3 次。我设置了一个带有端点/webhook 的云运行实例,它获取请求并将它们发布到 pub-...
Pubsub 订阅推送 Bq 中不支持的块类型“bigquery_config”
你好👋我正在尝试创建Pubsub Subscription Push Bq 这是我的供应商: 供应商“谷歌”{ 地区=“欧洲西部1” 版本 = "~> 4.14.0" 项目 = ...
Google pubsub - 每天发布到主题的消息数量指标
我们怎样才能看到每天(或者说每小时)有多少条消息发布到一个主题?有可用的指标吗?
Google App Engine Deploy 已于 2023 年停止工作 - 无法读取未定义的属性“@google-cloud/pubsub”
我有一个在节点 14 上运行的 App Engine 项目。它是一个 Next.JS 应用程序,它是通过云构建构建然后部署的。 当我在 2022 年 12 月提交代码时,它运行得非常好。豪...
GCP Custom Slack notification alert [关闭]
我需要一种方法来根据与给定查询匹配的日志在 GCP 警报策略中自定义松弛警报通知,例如在通知消息中显示日志详细信息,我该怎么做。
我有一个 spring boot 应用程序部署到谷歌云(通过自动 github 构建)。 不幸的是,我的 pub/sub 订阅者在部署后立即被删除 :( 有谁知道 t 的原因......