使用托管在Google基础架构上的可靠,多对多的异步消息传递来连接您的服务。 Cloud Pub / Sub会根据您的需要自动扩展,并为构建您自己的强大全球服务奠定基础。
为什么我的 GCP Pub/Sub 消息中有 50% 是重复的?
我正在运行分析管道。 吞吐量约为每秒 11 条消息。 我的 Pub/Sub 主题保存了大约 200 万条已安排的消息。 80 个 GCE 实例并行拉取消息。 这是我的主题...
我对 Spring 集成以及下面所述的几乎所有内容都是新手。 我有一个 inboundChannelAdapter 来从 pubsub 中的订阅中提取消息。 事实上,它正在从 p 中提取消息...
如何在 Cloud Build 失败时向 Google Pub/Sub 主题发送消息?
我想设置我的 Cloud Build 管道,以便在构建失败时向 Google Pub/Sub 中的特定主题发送消息。有没有一种简单的方法可以使用 Cloud Build 来做到这一点?有点像“终于...
以编程方式将 Google Cloud Storage 中每个文件名中的空格 (" ") 替换为下划线 ("_")
我有许多表格数据的 .csv 文件存储在 Cloud Storage 存储桶的不同文件夹中,这些文件是从外部数据源导入的。每天,每个
Raspberry PI 和 SPA 应用程序之间的 Websockets
我有一个连接到本地网络的 Raspberry PI,我在其中使用 WebsocketServer 设置了 NodeJS。现在,在我的 PHP/JavaScript 应用程序本地实例中,我连接到 RPI 的本地地址 ws://192.16...
使用 Cloud Functions 使用来自 Pub/Sub 的消息,直到主题为空
我面临着使用发布/订阅主题的消息处理系统的技术挑战,其中我的云功能单独处理消息。然而,我遇到过一种情况,如果有...
我从 GCP 文档中获取了一些订阅 GCP pubsub 消息的代码。当我在我的个人笔记本电脑上运行此代码时,它工作正常,我可以看到我从
解决发生错误:403 组织策略禁止请求的步骤有哪些。 vpcServiceControlsUniqueIdentifier:pubsub 中出现错误
我正在尝试将消息从云运行服务发布到 pubsub 推送订阅,触发另一个 cloudrun post 端点来接收消息数据,我已确保我的服务帐户有一个
我已在我们的平台中集成了 GMB API,并与 PubSub 合作来获取实时评论通知。 为此我已经完成了以下步骤: 在 google PubSub 云上创建了主题。 铬...
说明与 Cloud Dataflow 一起使用时 Google Cloud PubSub 的成本
有关 pubsub 定价的文档非常少。有人可以解释以下场景的成本吗? 每个事件的数据大小 = 0.5 KB 每天的数据大小 = 1 TB 只有一个公共...
如何每 90 分钟安排一次 Firebase 函数,但仅在 00:00 =>(午夜)开始
我正在尝试使用 Pubsub 安排 Firebase 功能,该功能将每 90 分钟运行一次,但我需要此功能从当天开始每天午夜运行 我尝试了很多方法,但...
我想将消息从 Google PubSub 推送到 AWS SQS。在我的 PubSub 订阅的设置中,我提供了 SQS 的 url 作为推送端点。 我需要什么样的额外设置...
我有一个用例,可以在以下条件下从 PubSub 在 GCS 存储桶中创建文件: 窗口大小限制 发布到 PubSub 主题的消息大小超过 500MB 例如, i) 如果我们指定窗口 si...
io.grpc.StatusRuntimeException:PERMISSION_DENIED:用户无权执行此操作
我尝试实现 Spring Cloud Config + Spring Cloud Bus 的简单示例。 所以我已经实施了 客户端服务器应用程序 配置服务器应用程序 在单独的存储库中我放入了
Gmail API/PUB SUB 收到新电子邮件时发送 2 条消息
我试图在每次电子邮件到达邮箱时触发Google云功能。 我已经使用 Google Cloud Function 和“PUSH”Delivery Ty 配置了 pub sub 订阅...
在google pub/sub中,如果创建了主题,我们可以设置保留策略 通过点击、编辑、编辑主题、更新 是否可以通过编程方式更新该值? 我看到有这样的配置...
我有一个场景,有 4 个 kubernetes pod 运行相同的 pubsub 订阅者代码,该代码将 PullStreamRequest 发送到单个订阅。 我正在使用 Go pubsub 客户端库 - http...
要求:在 google cloud pubsub 订阅中,我尝试将 min-retry-delay 设置为 30 分钟。有什么办法可以做到吗?
根据 pubsub 订阅的谷歌云文档,最小重试延迟可以设置为 0 到 600 秒。 重试策略选项。重试策略指定 Cloud Pub/Sub 如何重试消息传送......
Node.js PubSub new v1.SubscriberClient() 拉取请求拉取很少的消息
我需要拉取 2500 条消息,因此我将 maxMessages 设置为 2500,但它仍然最多只拉取 500 条消息,而且通常也拉取不到 10 条消息。鉴于我同时拉取消息,我...
通过 Airflow 插件向 PubSub 发送通知后 Airflow 任务失败 - psycopg2 和 SQLAlchemy 出现错误
一般说明 我的自定义 Apache Airflow 插件遇到问题,该插件会根据各种任务事件向 Google Cloud PubSub 发送通知。发送 PubSub 通知后