使用托管在Google基础架构上的可靠，多对多的异步消息传递来连接您的服务。 Cloud Pub / Sub会根据您的需要自动扩展，并为构建您自己的强大全球服务奠定基础。
Elastic Filebeat：利用 Google Pub/Sub 从 Google Cloud Storage 读取日志 – 相当于 AWS 中的 SQS
我的应用程序只能写入 AWS S3 或 Google Cloud Storage。这些应用程序每小时都会生成大量小日志文件。以前，这些日志被写入A...
我正在使用 Google pubsublite。具有单个分区和一些消息的小型虚拟主题。 Python 客户端库。使用回调执行标准 SubscriberCluent.subscribe。回调放置消息...
我有一个 pubsub 主题，其中订阅了一些未确认的消息，我想查看这些消息。是否可以？ REST API 似乎没有允许这样做的方法。受...
Cloud Pub/Sub 中的订购交付是否可以与 Cloud Dataflow 配合使用
我有从 pubsub 读取消息的数据流作业，但是，它以错误的顺序处理元素，我正在使用窗口来获取最近的元素，但有时消息不会被提取...
我正在将 ADC 与服务帐户模拟一起使用。当尝试使用 spring-cloud-gcp-pubsub 项目执行此操作时，我收到以下异常：“从流中读取凭据时出错，'...
如何防止github.com/ory/dockertest将容器分配到随机端口？
我正在尝试编写单元测试，这些测试既可以使用 github.com/ory/dockertest 在本地运行，也可以使用 Docker 执行器在 CircleCI 环境（其中设置了“CI”环境变量）中运行...
我想实现额外创建的服务帐户只能订阅某个特定的发布订阅。 而且，当人们使用此服务帐户列出所有订阅时，它
在此处输入图像描述，就像 openAPI 一样，有一种方法可以为 GCP pubsub 记录 AVRO 架构。 GCP 是否提供像 swagger UI 这样的 UI。或者这里有什么推荐。 据我说...
在 GCP PubSub 中，如果必须重试消息，如果配置了退避，那么在重试尝试之前，它是否会被推送到现有消息的后面？
我想检查特定消息的重试在 GCP 发布-订阅中如何工作？如果必须重试一条消息并且订阅还有其他消息，当前消息是否会被推到后面，或者...
我无法为我的 pubsub 推送订阅选择“仅一次传送”选项。互联网上没有任何地方可以解释为什么它是灰色的。 （见下文） 尝试到处寻找答案...
使用 Eventarc 触发器部署 Cloud Function 时出现服务帐户缺失 iam.serviceAccountTokenCreator 错误
我正在尝试使用 Eventarc 触发器部署云函数。部署时，我收到以下消息： 服务帐户 [[email protected]] 缺少...
部署后调用 BigQuery、Pub/Sub 和 Secret Manager 时出现 404 错误
从昨天下午 6:30 开始，每个 BigQuery、Pub/Sub 和 Secret Manager 请求都开始失败，并在每个 API 调用中出现 404 错误。我在这个时候部署了一个新版本 - 所以这看起来像是一个
在订阅上应用过滤器时，Python Pubsub 订阅者客户端不会拉取消息
我在我的 Python Web 应用程序中使用 Pubsub 流式拉取订阅。当我没有应用任何订阅过滤器时，订阅者客户端能够成功从
如何使用PublisherServiceAsyncClient
我正在尝试使用 pubsublite 中的 AsyncPublisherClient pip 安装 google-cloud-pubsublite==1.8.3 从 google.cloud 导入 pubsublite_v1 pubsub = pubsublite_v1.AsyncPublisherClient() 错误：模组...
pubsub 推送启用身份验证的 Spring Boot 应用程序
我正在尝试在 Spring Boot 应用程序中创建一个端点以由 pubsub 消息调用。 该应用程序已经为通过 firebase 登录的用户启用了一些安全性。 安全性
我有一个在 uvicorn 服务器内运行的 python 应用程序。我已经创建了一个 Pub/sub 订阅者并尝试从我的 main.py 中启用它。我正在使用流式拉取订阅。现在，我的
使用 GCP PubSub 源在 Flink 作业上获取 http2 异常
我有一个使用 GCP PubSub 作为源的 flink 作业。尽管我能够处理在 pubsub 主题上收到的消息，但我发现它存在一些问题： 已处理的消息较早...
无法使用 C# .NET Framework 4.8 将消息发布到 Pub/Sub 模拟器
我无法使用 C# .NET Framework 4.8 将消息发布到 Google Pub/Sub 模拟器。在生产中，代码可以工作。 gcloud 模拟器就发生了这种情况。 另外，同样的代码...
每秒向 PubSub 主题发布 5 条消息，无 Worker 的拉动订阅积压不会增长
我正在尝试调整从 PubSub 主题进行请求订阅所需的工作人员数量，每秒获取大约 5 条消息。当我关闭所有工作人员时，我希望看到积压字节开始......
我正在致力于集成 RabbitMQ 和 GCP Pub/Sub。 我正在使用 Pika 库和 Python。连接是通过BlockingConnection 建立的。 我的消费者作为单独的线程运行。最大预期