使用托管在Google基础架构上的可靠,多对多的异步消息传递来连接您的服务。 Cloud Pub / Sub会根据您的需要自动扩展,并为构建您自己的强大全球服务奠定基础。
Google pubsub:如何为 pubsub 订阅者实现自定义健康活性
更新2024-04-17 这可能是关闭订阅者的代码: if (!StatusUtil.isRetryable(原因)) { ApiException gaxException = ApiExceptionFactory.createException( ...
python 数据流:GroupByKey 无法应用于具有全局窗口和默认触发器的无界 PCollection
我有一个简单的 python 数据流代码,它使用无界 pcollection 。它只是 从 pubsub 读取 解析为带有输出标签 SUCCESS 和 FAILURE 的 json 使用输出标签 SUCCESS 和 F 验证 json...
找不到 PubSubTemplate、Spring Boot 3、GCP PUB/SUB 的 bean
我正在尝试将 GCP pub/sub 与我现有的 Spring Boot 应用程序集成。我在构建中拥有所需的依赖项,并提供了使用订阅配置连接到 GCP 的配置,并且
我用 Go 编写了一个数据流管道,它从 Pub/Sub 订阅中读取数据,执行转换,然后将记录写入 BigQuery。 它看起来运行良好,但我看不到数据......
我有一个用于对象终结的存储桶通知的 pubsub 主题。因此,每当在存储桶中添加新文件时,订阅者都会收到存储桶中的文件名,并且代码会确认消息 af...
有人有如何直接从 shell 通过 CURL 类型的命令将消息发布到 GCP PubSub 主题的工作示例吗? 我试图不使用 CLI 也不使用客户端库,...
使用恶意软件扫描程序(ClamAV)时Google Cloud Storage存储桶上传文件验证
正如标题所说,我如何验证文件是否已成功上传到干净的存储桶。我们有 3 个存储桶(未扫描、干净、隔离)和恶意软件扫描程序 (ClamAV)。首先文件是
Google Cloud Pub/Sub 通过 ID 检索消息
问题:我的用例是我想将数千条消息发布到 Google Cloud Pub/Sub,保留期为 5 分钟,但仅通过 ID 检索特定消息 - 因此云函数将重试...
具有多个 Pod 的 GKE 集群中的 pubsub 拉取订阅
我有一个 pubsub 订阅者,它检查 gs 存储桶中的新文件。一旦文件到达 gs 存储桶,我需要解析它并根据存储桶路径中的 id 发送到特定的 bigquery 表。 为了那个...
Pubsub 到 BigQuery 订阅:架构修订导致 BigQuery 中出现空值
我面临着 pubsub 模式演变的问题,当我添加新字段时,它们的值最终在 BigQuery 中为空。我的项目结构如下。 发布订阅模式 { “命名空间”...
我正在开发一个发布/订阅系统,我需要确保消息按照发布的确切顺序接收,即使使用多个排序键也是如此。我的系统发布了大量...
Dart 错误:错误:当前 Dart 运行时不支持导入 dart:mirrors
我目前正在尝试使用 Flutter 编写一些移动代码。我正在尝试使用 gcloud 库 dart 将数据发布/订阅到 GCP Cloud Pub/Sub。这是 main.dart 的代码: 导入 'dart:io';
如何使用 DataFlow 将数据从 Pub/Sub 流式传输到 Google BigTable?
我想问是否有人可以告诉我,甚至给我展示一个数据流作业模板的示例,最好是用 Python 编写,我可以在其中: 持续从 Pub/Sub 主题读取 JSON 数据 处理这个数据...
我这里有情况。我想找出将 API 流数据从应用程序提取到 GCP BigQuery 的最佳方法,同时进行数据屏蔽。然而,一些下游管理员用户...
我的应用程序基于 2 个 GCP 云函数,它们使用来自不同主题的消息。 第一个云函数使用来自第一个主题的有关对象创建的消息。 第二朵云
google cloud pub sub 具有相同订阅的同一条消息的多个订阅者
我正在致力于使用 GCP Pub/Sub 实现事件驱动。 我有一个名为 order 的主题,该主题将有一个名为 orderPlacedSubscription 的订阅 我有两个服务想要 lis...
我目前正在使用一个接收数百万个事件的系统,我需要一种有效的方法来处理这些事件。我的目标是仅针对某些事件触发云功能,而不是每个事件......
我已经为带有阈值规则的预算设置了警报,如下所示: 扳机 预算百分比 地位 1 90% 实际的 2 100% 实际的 3 110% 实际的 4 110% 预测 设置 2 个通知端点:
Google PubSub Lite 一个订阅者具有多个分区
我想了解当只有 1 个订阅者订阅具有 2 个分区的主题时,Google PubSub Lite 的行为是什么。 订阅者是否从两个
Google Cloud Pub/Sub 用于观看 Gmail
简介 我希望使用 Pub/Sub API 来监控我们组织中帐户的收件箱。它只是一个普通的 Gmail 收件箱,但它会接收对我们很重要的 IT 相关通知