如何解决MQTT发布/订阅,此代码流正确吗?
我是第一次接触AWS IoT和MQTT。我从未真正使用过pubsub模型,因此,我不仅试图更好地理解它,而且还在尝试寻找有关最佳做法的建议。我目前正在使用AWS IoT Python SDK。
当前,我发送到IoT Core的有效负载会触发lambda函数,该函数会生成S3预签名URL。正在发送到我的$response = json_decode($get_data,true);
echo $response["lstsmi"];
主题的有效负载具有一个replyTo键,该键指定主题iot/pre-signed-s3-url-requests
来将URL返回。
在我的代码中,在发布请求之前,我首先订阅了iot/my-thing/pre-signed-s3-url-responses
通配符主题。这样,我可以收到两个回复。对我的初始消息的确认和签名的URL。我的代码如下:
iot/#
我的问题是这些:
- 订阅通配符主题是最好的方法吗?
- 为了使此代码正常工作,我必须在publish方法中添加time.sleep(2)以便给响应时间一些。我需要做些什么来消除time.sleep()打电话吗?
- 在较高级别上,我的代码发布,得到响应,然后关闭。还有其他有用的模式吗?例如,我是否应该有一个订阅某个主题并不断侦听/拦截传入消息的脚本?
任何帮助我更好地理解的建议/信息都将不胜感激。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。