使用托管在Google基础架构上的可靠,多对多的异步消息传递来连接您的服务。 Cloud Pub / Sub会根据您的需要自动扩展,并为构建您自己的强大全球服务奠定基础。
当使用Spring Boot 2.0.0.RELEASE与google-cloud-pubsub时,Gradle碰到io.netty的版本
我有一个在最新的2.0.0.M5上运行的Spring Boot应用程序,google-cloud-pubsub:0.0.28。当我将Spring提升到2.0.0时.RELEASE Spring无法启动此错误:引起:java.lang ....
我正在使用此处提到的message_id和publish_time参数来检索消息ID和消息发布的时间。虽然始终收到消息ID,但时间戳不是......
我有下面的代码来观看邮箱。如图所示,在lableIds中,我只有一个标签,INBOX因为我只想听新消息。但是,当我运行它时,它会收到通知......
我想根据字段的内容动态地将PCollection的不同元素路由到不同的PubSub主题。这些主题并不持久,但假设它们存在......
用于批处pubsub请求的NODEJS示例代码如下所示://导入Google Cloud客户端库const PubSub = require(`@ google-cloud / pubsub`); //创建一个客户端const pubsub = ...
我正在编写一个ASP .NET Core应用程序,我正在使用Google PubSub模拟器,我可以在其中发布和订阅主题。但是,当我发布1000多个“大量”的消息时,我......
我想听听子桶中GCS的变化我试过这个gsutil通知创建-t my-topic -f json gs:// my-bucket但是它给了我通知所有对象的变化是否有办法......
将消息发布到Dataflow中的Pub / Sub主题的推荐方法是什么?我使用过客户端API但不认为这是在Dataflow中处理此问题的最佳方法。 PublishResponse回复......
我的应用程序使用MQTT订阅事件主题。但是,要更改设备配置,我需要在此处使用HTTP POST请求:https://cloud.google.com/iot/docs/reference/rest/v1/projects ....
Google云图像存储库是否会对存储库中的图像推送/拉出发送通知?
当从私有存储库推送/拉出任何图像时,docker存储库向端点提供通知(https://docs.docker.com/registry/notifications/#configuration)。谷歌云...
来自pubsub docs自发布之日起,在持久存储中保留7天内未确认的消息。有没有办法让订阅的邮件超过7天?不......
如何订阅包含令牌和主题的Pub / Sub?对于一个环聊聊天机器人
我正在为Google聊天做一个聊天机器人,我看到有一个Cloud Pub / Sub选项。我想使用它,但我不知道如何将对话链接到Pub / Sub系统。聊天给我的只是......
带有Pub / Sub源的Apache Beam Python SDK在运行时停留
我正在使用Python SDK在Apache Beam中编写一个程序,从Pub / Sub读取JSON文件的内容,并对接收到的字符串进行一些处理。这是我拉动程序中的一部分......
Google Cloud Pub / Sub Python SDK一次检索一条消息
问题:我的用例是我希望使用Python Api一次从Google Cloud Pub / Sub接收消息 - 一条消息。所有当前的例子都提到使用Async / callback选项来拉动......
Grpc System.ObjectDisposedException:已关闭安全句柄
使用Pub / Sub停止服务并在Google App Engine上运行时,会收到以下堆栈跟踪。 System.ObjectDisposedException:System.Runtime已关闭安全句柄....
如何使用Google Cloud功能和MQTT桥更新设备配置
我正在使用带有Pub / Sub的Google Cloud IoT。我有一个设备读取传感器数据并将其发送到Pub / Sub中的主题。我有一个由此消息触发的主题云功能,我会......
Google Cloud App Engine Cron服务中断
我昨天中午12点成立了一个cron工作,每分钟运行一次。请参阅下面的cron.yaml文件中的代码。 cron: - 描述:每分钟将一个“tick”推到pubsub上。 url:/ publish / minute-tick ...
我正在尝试创建一个仅具有特定pubsub主题权限的服务帐户。我创建一个主题:gcloud pubsub主题创建mytopic然后创建一个服务帐户:gcloud iam service -...
DirectRunner不会按照我在Beam Java SDK中使用FixedWindows指定的方式读取Pub / Sub
我目前正在开发一个Dataflow管道,它使用Apache Beam Java SDK 2.8.0从Pub / Sub读取流数据。该管道只是Google的PubsubToText.java模板。 https://开头的github ....