从python服务器订阅aws iot主题
我基本上需要从python服务器向设备发送命令，设备将发布对主题的回复，我需要捕获回复服务器端。要从服务器发布到设备，我正在使用boto3物联网数据模块。但是我如何订阅另一个主题以从设备获得回复？似乎没有办法使用aws python库。我需要使用像paho这样的遗传MQTT客户机吗？
谢谢你。
共有1个答案
您是正确的，AWS SDK for Python不提供订阅MQTT主题的方法。您可以使用AWS Python IoT SDK，也可以使用泛型MQTT客户机（如Paho）。
-
我试图利用固有的WSO2ESB主题发布到jms队列。我已经创建了主题，并提供了一个订阅者URL：jms：/topictest？transport.jms.destinationtype=queue。然而，当我将消息发布到主题时，它不能被传递到队列。日志生成以下内容 “系统无法从jms：/queue？destination=topictest URL推断传输信息。” 另外，我似乎不知道如何发布到WS
-
我有一个使用ActiveMQ的JMS生产者/订阅者的简单Spring应用程序，配置如下： 我试过所有可能的解决办法，但没有一个奏效。我们非常感谢任何帮助
-
我在spring中有一个服务，它需要使用十种不同的方法获取数据。 我希望这些方法并行执行，以执行一些DB操作并返回到父线程。但是父线程应该等到所有响应出现，然后返回响应。 在我当前的方法中，我使用反应式mono异步执行所有方法，但主线程不等待订阅者方法完成。 下面是我订阅的两种方法 下面是我的主要方法 以下是我的输出： 我的输出显示，主线程没有等待订阅服务器完成其任务，因此我如何处理这种情况？
-
我想使用PublishSubject创建一个广播系统，一个后台任务将轮询一些endpoint，并定期使用该主题广播结果。我希望在第一个订阅者订阅主题时开始轮询，并在没有更多订阅者时停止轮询。如果有新订阅者订阅，则应继续轮询。
-
我正在尝试使用spring-integration-kafka-2.1.0。在我公司的项目中发布。但是，由于下面列出的例外情况，它不起作用：org。springframework。信息。MessageDeliveryException:Dispatcher没有频道“org”的订户。springframework。网状物上下文WebApplicationContext:/order。“奥Kafka”
-
这似乎是最简单的解决办法。让我们看看流程： 第三方向RESTful API发送请求，以获取Windows Azure服务总线连接字符串-凭据-。 一旦拥有连接字符串，第三方就会连接到Windows服务总线，并开始从某个主题订阅接收消息。注意：连接字符串是在服务器端加密的，只能由接受的客户端解密。 优点 null null 第三方请求一个类似于RESTful的TCP API，以便订阅一些Window