google-cloud-pubsub 相关问题

使用托管在Google基础架构上的可靠,多对多的异步消息传递来连接您的服务。 Cloud Pub / Sub会根据您的需要自动扩展,并为构建您自己的强大全球服务奠定基础。

为什么我的 GCP Pub/Sub 消息中有 50% 是重复的?

我正在运行分析管道。 吞吐量约为每秒 11 条消息。 我的 Pub/Sub 主题保存了大约 200 万条已安排的消息。 80 个 GCE 实例并行拉取消息。 这是我的主题...

回答 2 投票 0

spring集成中poller的查询

我对 Spring 集成以及下面所述的几乎所有内容都是新手。 我有一个 inboundChannelAdapter 来从 pubsub 中的订阅中提取消息。 事实上,它正在从 p 中提取消息...

回答 1 投票 0

如何在 Cloud Build 失败时向 Google Pub/Sub 主题发送消息?

我想设置我的 Cloud Build 管道,以便在构建失败时向 Google Pub/Sub 中的特定主题发送消息。有没有一种简单的方法可以使用 Cloud Build 来做到这一点?有点像“终于...

回答 1 投票 0

以编程方式将 Google Cloud Storage 中每个文件名中的空格 (" ") 替换为下划线 ("_")

我有许多表格数据的 .csv 文件存储在 Cloud Storage 存储桶的不同文件夹中,这些文件是从外部数据源导入的。每天,每个

回答 1 投票 0

Raspberry PI 和 SPA 应用程序之间的 Websockets

我有一个连接到本地网络的 Raspberry PI,我在其中使用 WebsocketServer 设置了 NodeJS。现在,在我的 PHP/JavaScript 应用程序本地实例中,我连接到 RPI 的本地地址 ws://192.16...

回答 1 投票 0

使用 Cloud Functions 使用来自 Pub/Sub 的消息,直到主题为空

我面临着使用发布/订阅主题的消息处理系统的技术挑战,其中我的云功能单独处理消息。然而,我遇到过一种情况,如果有...

回答 1 投票 0

Google pubsub 订阅者在公司网络内不提取消息

我从 GCP 文档中获取了一些订阅 GCP pubsub 消息的代码。当我在我的个人笔记本电脑上运行此代码时,它工作正常,我可以看到我从

回答 1 投票 0

解决发生错误:403 组织策略禁止请求的步骤有哪些。 vpcServiceControlsUniqueIdentifier:pubsub 中出现错误

我正在尝试将消息从云运行服务发布到 pubsub 推送订阅,触发另一个 cloudrun post 端点来接收消息数据,我已确保我的服务帐户有一个

回答 1 投票 0

GMB API - 与 PubSub 合作获取实时评论通知

我已在我们的平台中集成了 GMB API,并与 PubSub 合作来获取实时评论通知。 为此我已经完成了以下步骤: 在 google PubSub 云上创建了主题。 铬...

回答 2 投票 0

说明与 Cloud Dataflow 一起使用时 Google Cloud PubSub 的成本

有关 pubsub 定价的文档非常少。有人可以解释以下场景的成本吗? 每个事件的数据大小 = 0.5 KB 每天的数据大小 = 1 TB 只有一个公共...

回答 2 投票 0

如何每 90 分钟安排一次 Firebase 函数,但仅在 00:00 =>(午夜)开始

我正在尝试使用 Pubsub 安排 Firebase 功能,该功能将每 90 分钟运行一次,但我需要此功能从当天开始每天午夜运行 我尝试了很多方法,但...

回答 1 投票 0

Google PubSub 到 AWS SQS

我想将消息从 Google PubSub 推送到 AWS SQS。在我的 PubSub 订阅的设置中,我提供了 SQS 的 url 作为推送端点。 我需要什么样的额外设置...

回答 1 投票 0

GCP PubSub 到 GCS 数据流

我有一个用例,可以在以下条件下从 PubSub 在 GCS 存储桶中创建文件: 窗口大小限制 发布到 PubSub 主题的消息大小超过 500MB 例如, i) 如果我们指定窗口 si...

回答 1 投票 0

io.grpc.StatusRuntimeException:PERMISSION_DENIED:用户无权执行此操作

我尝试实现 Spring Cloud Config + Spring Cloud Bus 的简单示例。 所以我已经实施了 客户端服务器应用程序 配置服务器应用程序 在单独的存储库中我放入了

回答 3 投票 0

Gmail API/PUB SUB 收到新电子邮件时发送 2 条消息

我试图在每次电子邮件到达邮箱时触发Google云功能。 我已经使用 Google Cloud Function 和“PUSH”Delivery Ty 配置了 pub sub 订阅...

回答 2 投票 0

Google Pub/Sub 集以编程方式启用主题消息保留

在google pub/sub中,如果创建了主题,我们可以设置保留策略 通过点击、编辑、编辑主题、更新 是否可以通过编程方式更新该值? 我看到有这样的配置...

回答 0 投票 0

将多个订阅者发布/订阅到一个订阅消息路由

我有一个场景,有 4 个 kubernetes pod 运行相同的 pubsub 订阅者代码,该代码将 PullStreamRequest 发送到单个订阅。 我正在使用 Go pubsub 客户端库 - http...

回答 1 投票 0

要求:在 google cloud pubsub 订阅中,我尝试将 min-retry-delay 设置为 30 分钟。有什么办法可以做到吗?

根据 pubsub 订阅的谷歌云文档,最小重试延迟可以设置为 0 到 600 秒。 重试策略选项。重试策略指定 Cloud Pub/Sub 如何重试消息传送......

回答 1 投票 0

Node.js PubSub new v1.SubscriberClient() 拉取请求拉取很少的消息

我需要拉取 2500 条消息,因此我将 maxMessages 设置为 2500,但它仍然最多只拉取 500 条消息,而且通常也拉取不到 10 条消息。鉴于我同时拉取消息,我...

回答 1 投票 0

通过 Airflow 插件向 PubSub 发送通知后 Airflow 任务失败 - psycopg2 和 SQLAlchemy 出现错误

一般说明 我的自定义 Apache Airflow 插件遇到问题,该插件会根据各种任务事件向 Google Cloud PubSub 发送通知。发送 PubSub 通知后

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.