我正在使用MQTT发送和接收消息从谷歌的IoT核心(遥测信息)。然后将消息传递到不同的Pub/Sub主题。
我想在我的消息中添加自定义属性。
目标是在我的主题上使用不同的订阅。然后,根据我的自定义属性过滤传入的消息,最后在我的数据流管道上通过“主题”获取我的消息。
我知道当我们使用Pub/Sub客户端时我们可以做到这一点,但是我无法从mqtt客户端成功地做到这一点。
我正在使用python客户端。
因此,根据要求,我补充了一些细节。这是一种非常经典的情况。我使用的是一个MQTT客户端,如这里的谷歌示例:。然后使用相同文档中的发布代码: (我只是替换了
for i in range(0,