huaweicloud-iot-device-sdk

const path = require('path');
const huaweiIoT = require('huaweicloud-iot-device-sdk');
 
const options = {
    deviceId: "your deviceId",
    deviceSecret: "your deviceSecret",
    caFilePath: path.join(__dirname, 'hw-iot-root.pem'),
    host:'your iot host'
}
 
 
//建立连接
var client = huaweiIoT.getHuaweiIoTClient(options);
client.on('message', function(topic, message) {
    console.log("topic " + topic)
    console.log("message " + message)
 
})
client.subscribe(`/huawei/v1/devices/${options.deviceId}/command/json`)
 
var topic = `/huawei/v1/devices/${options.deviceId}/data/json`
var postJson = {
    msgType: "deviceReq",
    data: [
        {
            serviceId: "pop",
            serviceData: {
                stackId:4
            }
        }
    ]
}
client.publish(topic, JSON.stringify(postJson))
 
client.end(function (){
    console.log("end")
})
 

client.subscribe(topic)
 

client.publish(topic, 'Hello mqtt')
client.publish(topic, 'Hello mqtt', { qos: 1 })
 

client.on('message', function(topic, message) {
    console.log(topic+"," + message.toString())
})