使用托管在Google基础架构上的可靠，多对多的异步消息传递来连接您的服务。 Cloud Pub / Sub会根据您的需要自动扩展，并为构建您自己的强大全球服务奠定基础。
如何检查 Cloud Pub/Sub 模拟器是否已启动并正在运行？
我有 GC 功能，我使用 Cloud Pub/Sub 模拟器在本地开发和测试。 我希望能够从 Go 代码中检查 Cloud Pub/Sub 模拟器是否已启动并运行。如果没有，我会...
Google Cloud Functions：Pub/Sub 与 Rest 触发
Pub/Sub 是否是 Kubernetes Engine (GKE) api 服务器和云功能 (GCF) 之间的通信速度明显更快的方式？ GK之间是否可以使用Pub/Sub进行这样的通信...
是否可以使用访问令牌对谷歌云 PUB/SUB Node.js API 客户端进行身份验证？
是否可以在没有服务帐户的情况下使用通过 oAuth 流程收到的访问令牌来验证 google cloud pub/sub Nodejs 客户端？ 我在开始部分之前尝试过，但它需要服务......
我有一个容器化的 API，并在云运行中运行。如何获取正在执行云运行的当前项目 ID？我努力了： 我在日志中的文本有效负载中看到它，但我不...
GCP Pub Sub 中的订阅确认设置是否会自动被拉取订阅的客户端库覆盖？
我们正在使用 GCP Pub Sub 客户端库 (com.google.cloud.pubsub.v1) 来处理来自订阅的消息。 请求订阅的默认 ACK 截止时间为 10 秒。 寻找一些
Google Cloud - 在cloudbuild中设置云功能的默认重试
我想知道是否有办法直接在云函数的yaml中配置“失败重试”触发策略。 至于现在，我找到了有关工作流程的文档，或者只是将其标记为...
我不明白为什么AWS kinesis在配置模式下的吞吐量非常低。 文档参考 每个分片可支持高达 1 MB/秒或 1,000 条记录/秒的写入吞吐量或高达 2 MB/秒或...
我有一个订阅 PubSub 订阅的 Cloud Run FastAPI 应用程序。它将处理突发流量，因此在给定时间可能有 0 个实例，也可能有 20 个实例。 假设我有 10 个
我正在尝试从 PCF 环境（Spring boot 应用程序）连接 google Pub/Sub。应用程序已成功从credentials.json 文件加载凭据并打印项目ID。但正在打印...
我们有一个使用 GCP pubsub 构建的系统，其中有一个主要的“事件”主题，该主题从多个来源接收不同的消息并将所有这些消息发布到许多不同的子主题...
我使用表架构设置了对 Pub/Sub 主题的 BigQuery 订阅，但是当我向该主题发布消息时，数据不会写入 BigQuery 表。我按照谷歌的问题解决...
将数据写入云存储时，将 GCP Pub Sub 上的文件名前缀设计为 YYYY/MM/DD
在将流数据写入存储时，我想将其打印到相关年月日的文件夹中。订阅中的发布/订阅 文件名前缀设置中应该使用哪个函数？ 我期待
如何在 Firebase Functions 第二代中删除 x 分钟后重试的事件
我正在将一些 Firebase Functions 代码从第一代迁移到第二代。在我的第一代函数中，我使用 shouldDropEvent 帮助器，它查看上下文的时间戳并决定删除事件
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)。首先文件是