У меня есть javascript с mqtt, и я написал paho python для подписки, но я не получаю никакого результата. Я хочу распечатать полученное сообщение
var mqtt = require('mqtt');
var client = mqtt.connect('mqtt://127.0.0.1',{
username: process.env.TOKEN
});
client.on('connect', function () {
console.log('connected');
client.subscribe('v1/devices/me/rpc/request/+')
});
client.on('message', function (topic, message) {
console.log('request.topic: ' + topic);
console.log('request.body: ' + message.toString());
var requestId = topic.slice('v1/devices/me/rpc/request/'.length);
//client acts as an echo service
client.publish('v1/devices/me/rpc/response/' + requestId, message);
});
`
Соответствующий python для сабвуфера не публикуется, но я не получаю никакого результата
def on_connect(client, userdata, flags, rc):
print("Connected with result code "+str(rc))
client.subscribe('v1/devices/me/rpc/request/+')
def on_message(client, userdata, msg):
print( msg.payload.decode())
client.disconnect()
client = mqtt.Client()
client.username_pw_set("5vTGKxGAHzv5TbsW2Jv1")
client.connect("127.0.0.1",1882,60)
client.on_connect = on_connect
client.on_message = on_message
client.loop_forever()
Заранее спасибо