一个主题将有一个发布者。比方说每秒1000条消息。这就是我想要做的：( Google Pub/Sub的REST API允许这样做吗？)您可以使用新方法createSharedConsumer创建一个“共享的”非持久订阅。由于两个JVM需要能够识别它们需要共享的订阅，因此它们需要提供一个名称来识别共享的<
浏览 8提问于2017-03-02得票数 2
我正在尝试谷歌物联网和谷歌PubSub。我正在将MQTT消息从设备发送到我所订阅的pubsub队列(我将其称为“服务器”)。在google云控制台中，我更新了设备设置，并在设备中获得了设置消息。google tutorial中的一切都运行得很好，但我想知道是否有可能以另一种方式设置消息传递:即“服务器”发送消息到设备使用MQTT订阅的pubsub队列。末尾的模式让我认为只有"config“mqtt队列(/devices/X
浏览 2提问于2018-04-25得票数 2
例如，您有发布和订阅主题的用户。该主题实际上与REsT端点相关。场景1(典型的pub/sub用法)
根据定义，此发布是向订阅者广播的。我们有一个订阅
浏览 2提问于2016-07-10得票数 0
我通过rest HTTP端点发布了一个自定义API，在发布API之后，我订阅了该API。在订阅期间，我生成生产端点URL令牌，然后尝试访问端点。我能够获得仪表板本身上的api数据。如何在数据库中存储对应的api负载？
浏览 7提问于2016-08-22得票数 0
我们的要求是，我们有一个Azure服务总线主题，我们希望将其设置为在谷歌PubSub主题中的推送订阅者。这样，发布到Google PubSub主题的任何消息都将被推送到Azure主题，而不涉及任何中间层。在纸上，这应该工作，因为消息可以发布到Azure SB主题使用API框架和谷歌PubSub也可以配置API作为推送订户。
我已
浏览 0提问于2019-07-15得票数 1
1回答
GCP发布文档提到了拉模式的负载平衡，不清楚如何使用它。问题：如何配置负载平衡，跨多个订阅服务器？背景：
我们使用多个订阅者进行相同的主题，以实现适应力。(可以从同一个数据存储区查询多个端点的数据)。订阅会持久化消息，但是如果没有out分发，所有订阅都会获得所有消息，从而
浏览 0提问于2018-06-28得票数 2
1回答
我有一个云函数，它将消息发布到PubSub，并触发云运行来执行归档文件过程。当有大文件时，我的cloud Run python代码需要一些时间来处理数据，它看起来像是PubSub在20秒(默认确认截止时间)后重试消息，这将从我的Cloud run触发另一个实例。云函数发布消息代码： # Publishes a message publish_future = publisher.publish(topic_path, data=message_bytesexcept Exception as e
浏览 17提问于2021-07-02得票数 2
回答已采纳
我正在使用带有发布/订阅主题的谷歌云IoT核心。我有一个python脚本，通过MQTT Bridge将数据发布到我的云函数。'/devices/{}/events/Topic'.format(device_id) #Topic 现在我的问题是，可以通过MQTT发送多大的有效负载？我看过两部纪录片。https:&#
浏览 13提问于2020-06-18得票数 0
回答已采纳
我们有一个基于IoT的应用程序设备，它被配置为通过MQTT桥从谷歌、AWS和Azure等各种服务提供商与我们的仪表板进行通信。
浏览 0提问于2018-04-11得票数 1
一个关于MQTT发布和订阅的问题，来自同一设备的不同主题。在发布和订阅中使用不同的主题是否被认为是不好的形式或做法，或者应该使用相同的主题，并使用有效负载增量来限定功能，而不仅仅是通过主题？Publish Topic A, Payload 'some task'
Device 1, Subs
浏览 100提问于2020-07-04得票数 1
回答已采纳
在将Android实时开发者通知( RTDN )设置为接收IAP订阅状态更改到我的web服务器的一种方式后，我实际上只收到来自Google的RTDN webhook的特定推送，该推送从不包含订阅细节。下面是每次从我的应用程序发生购买订阅事件时发送到我的服务器的有效负载结构： "message": {
"data": "longstringof
浏览 22提问于2019-07-03得票数 3
回答已采纳
我正在探索AWS IoT MQTT代理功能以供我将来使用，并且我正在试图弄清楚AWS是否支持“共享订阅”功能。
共享订阅，这是IBM MessageSight引入的相对较新的功能。表示"queue“或"p2p”行为，当具有相同clientID的多个订阅服务器可以连接/订阅到同一主题，并且只有一个订阅服务器实例(负载自动平衡)接收特定消息时。针对pub/sub模
浏览 23提问于2016-08-31得票数 1
回答已采纳
由于Azure Service Bus将队列或主题的最大并发连接数限制为100，我们是否可以使用一种方法来查询队列/主题，以确定有多少个并发连接？我们知道我们可以捕获节流事件，但我们更喜欢主动的方法，在系统负载较重时，我们可以主动增加或减少队列/主题的数量。这里的用例是等待回复消息的流程，其中回复来自长期运行的流程，订阅使用相关筛选器来促进<e
浏览 2提问于2012-09-18得票数 2
回答已采纳
关于AWS SNS的常见问题，他们提到：
问: SNS主题如何与移动推送一起工作？SNS主题可以有来自任何受支持的推送通知平台的订阅者，以及任何其他端点类型，如SMS或email。当您向主题发布通知时，SNS将向订阅该主题的每个端点发送该消息的相
浏览 3提问于2017-07-04得票数 0
1回答
传感器可以使用JSON有效负载通过MQTT发布监视数据。Shelly传感器在主题{SHELLY_ID}/events/rpc，上发布了数据，但是FIWARE只能订阅主题/json/{{api-key}}/{{device-id}}/attrs.现在发布和订阅的主题是不同的在我们的应用程序
浏览 7提问于2022-08-10得票数 0
1回答
我试图在Akka的演员模型之上实现事件总线(Pub)模式。设备内部的参与者可以决定他们想要发布、订阅或取消订阅主题的任
浏览 8提问于2016-01-16得票数 3
回答已采纳
1回答
我想知道如何通过Azure服务总线主题和订阅获得特定的行为。对于我们的应用程序，我们有一个主题和许多订阅。订阅使用筛选器。当消息发布时，它可以由一个或多个订阅进行筛选。我们要做的是让多个使用者实例订阅同一个订阅。但是*只有一个实例可以在给定的时间处理消息。(以这种方式处理的顺序是固定的)。*我
浏览 2提问于2015-02-12得票数 0
回答已采纳
我想知道，当客户端通过从同一个nats服务器发送/接收的消息进行通信时，使用相同的加密/解密机制是否可以获得性能上的好处。用户(C)订阅nats主题"foo.bar"，使用自己的加密密钥(B)加密解密方案(B)。用户(C)订阅nats主题"foo.bar"，使用与发行者完全相同的加解密方案(A)。在这个场景中，我假设nat
浏览 10提问于2021-12-13得票数 1
回答已采纳
事情变得有些不同的地方是，我想将Pub/Sub模型集成到这个体系结构中。因此，当资源被修改时，我希望体系结构支持将相关订阅者排除在外的更新。我的许多问题都与Pub/Sub“主题”与RESTful‘URI’的关系有关。实际上，我只想使用URI作为主题。我觉得在许多情况下，这是完全合理的--但我对此有点怀疑，在野外找不到任何架构来这样做。奇怪的是，有些URI是查询，不太适合这个模型。支持pub/sub动态查询
浏览 0提问于2016-09-15得票数 9
回答已采纳
我正在寻找关于如何摄取来自单个订阅(一个主题)的各种有效负载到大型查询的最佳实践。数据可以以原始格式摄取，但需要以更表格的形式构造，并映射到发布层以供业务使用。我在谷歌上搜索了一些选项，但需要指导如何实时设计发布解决方案的发布消息摄取。应该简单地将与原始消息保持类似结构的所有数据转储为string或Json，还是应该将属性构造为列/结构/数组-
浏览 3提问于2022-08-31得票数 0
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
