google-cloud-pubsub 相关问题

使用托管在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 ....

回答 1 投票 0

不总是生成已发布消息的时间戳

我正在使用此处提到的message_id和publish_time参数来检索消息ID和消息发布的时间。虽然始终收到消息ID,但时间戳不是......

回答 1 投票 0

Gmail API:仅限观看收件箱标签

我有下面的代码来观看邮箱。如图所示,在lableIds中,我只有一个标签,INBOX因为我只想听新消息。但是,当我运行它时,它会收到通知......

回答 1 投票 1

根据消息内容从Dataflow作业写入动态PubSub主题

我想根据字段的内容动态地将PCollection的不同元素路由到不同的PubSub主题。这些主题并不持久,但假设它们存在......

回答 1 投票 1

批处理PubSub请求

用于批处pubsub请求的NODEJS示例代码如下所示://导入Google Cloud客户端库const PubSub = require(`@ google-cloud / pubsub`); //创建一个客户端const pubsub = ...

回答 1 投票 1

Google PubSub每次拉取的最大邮件数

我正在编写一个ASP .NET Core应用程序,我正在使用Google PubSub模拟器,我可以在其中发布和订阅主题。但是,当我发布1000多个“大量”的消息时,我......

回答 1 投票 0

子目录上的云存储的云发布/子通知

我想听听子桶中GCS的变化我试过这个gsutil通知创建-t my-topic -f json gs:// my-bucket但是它给了我通知所有对象的变化是否有办法......

回答 1 投票 1

将消息发布到Dataflow中的Pubsub主题

将消息发布到Dataflow中的Pub / Sub主题的推荐方法是什么?我使用过客户端API但不认为这是在Dataflow中处理此问题的最佳方法。 PublishResponse回复......

回答 1 投票 0

使用MQTT更改谷歌云物联网中的设备配置

我的应用程序使用MQTT订阅事件主题。但是,要更改设备配置,我需要在此处使用HTTP POST请求:https://cloud.google.com/iot/docs/reference/rest/v1/projects ....

回答 1 投票 0

Google云图像存储库是否会对存储库中的图像推送/拉出发送通知?

当从私有存储库推送/拉出任何图像时,docker存储库向端点提供通知(https://docs.docker.com/registry/notifications/#configuration)。谷歌云...

回答 1 投票 0

如何增加订阅配额7天

来自pubsub docs自发布之日起,在持久存储中保留7天内未确认的消息。有没有办法让订阅的邮件超过7天?不......

回答 1 投票 0

如何订阅包含令牌和主题的Pub / Sub?对于一个环聊聊天机器人

我正在为Google聊天做一个聊天机器人,我看到有一个Cloud Pub / Sub选项。我想使用它,但我不知道如何将对话链接到Pub / Sub系统。聊天给我的只是......

回答 2 投票 -1

带有Pub / Sub源的Apache Beam Python SDK在运行时停留

我正在使用Python SDK在Apache Beam中编写一个程序,从Pub / Sub读取JSON文件的内容,并对接收到的字符串进行一些处理。这是我拉动程序中的一部分......

回答 1 投票 0

Google Cloud Pub / Sub Python SDK一次检索一条消息

问题:我的用例是我希望使用Python Api一次从Google Cloud Pub / Sub接收消息 - 一条消息。所有当前的例子都提到使用Async / callback选项来拉动......

回答 2 投票 1

Grpc System.ObjectDisposedException:已关闭安全句柄

使用Pub / Sub停止服务并在Google App Engine上运行时,会收到以下堆栈跟踪。 System.ObjectDisposedException:System.Runtime已关闭安全句柄....

回答 1 投票 0

如何使用Google Cloud功能和MQTT桥更新设备配置

我正在使用带有Pub / Sub的Google Cloud IoT。我有一个设备读取传感器数据并将其发送到Pub / Sub中的主题。我有一个由此消息触发的主题云功能,我会......

回答 1 投票 1

Google Cloud App Engine Cron服务中断

我昨天中午12点成立了一个cron工作,每分钟运行一次。请参阅下面的cron.yaml文件中的代码。 cron: - 描述:每分钟将一个“tick”推到pubsub上。 url:/ publish / minute-tick ...

回答 1 投票 0

GCP PubSub主题权限

我正在尝试创建一个仅具有特定pubsub主题权限的服务帐户。我创建一个主题:gcloud pubsub主题创建mytopic然后创建一个服务帐户:gcloud iam service -...

回答 1 投票 0

DirectRunner不会按照我在Beam Java SDK中使用FixedWindows指定的方式读取Pub / Sub

我目前正在开发一个Dataflow管道,它使用Apache Beam Java SDK 2.8.0从Pub / Sub读取流数据。该管道只是Google的PubsubToText.java模板。 https://开头的github ....

回答 1 投票 0

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