我在 AWS 中使用由我的 CA 签名的设备证书预置了一个设备。另外,我之前已经在 AWS 中注册了我的 CA 和 verifyCert。
现在当我发送数据时,在选项中,
var awsIot = require('aws-iot-device-sdk');
var device = awsIot.device({
privateKey: '--BEGIN RSA PRIVATE KEY--', //private key of my device
clientCert: '--BEGIN CERTIFICATE --', //cat deviceCertificate and registered CA
caCert: '--BEGIN CERTIFICATE--', //Amazon root CA
clientId: 'Thing01',
region: 'us-west-2',
host: xxxxxxxx.iot.us-west-2.amazonaws.com,
secretKey: 'dcvevv',
accessKeyId: 'ferferer'
});
device.on('connect',function(err){
device.publish('$aws/things/Thing01/shadow/update',JSON.stringify({
"state" :{
"desired": {
"color": "blue"
}
}
})
);
})
我得到以下错误
抛出新错误(异常。INVALID_CA_CERT_OPTION);^ 错误:提供的“caCert”选项无效。
谁能让我知道我在上面的代码片段中做错了什么?
Edit1:在选项中进行更正后,以下是代码:
var awsIot = require('aws-iot-device-sdk');
var device = awsIot.device({
host:'xxxxx.iot.us-west-2.amazonaws.com',
keyPath : './certs/deviceTest/5e2570c0605418.key',
certPath : './certs/deviceTest/5e2570c0605418AndCA.crt', //cat of device and Registered CA
caPath : './certs/rootCA.pem', //public cert of AWS root CA1
clientId: 'ManualDevice_01', //ThingName
region : 'us-west-2',
secretKey: 'xxxxxxxxxxxx',
accessKeyId: 'xxxxxxxxxxxxxxxx'
});
console.log("Invoking on connect");
device.on('connect',function(error ){
console.log("In on connect !!");
if(error)
console.log('could not connect');
device.publish('$aws/things/ManualDevice_01/shadow/update',JSON.stringify({
"state" : {
"desired" : {
"color" : "pink",
"power" : "off",
"val":"1"
}
}
} ), function(err){
if(err)
console.log("Could not send : Error : "+err)
else
{
console.log("Sent data")
}
}
);
console.log('Message sent........')
})
device.on('message',function(topic,payload){
console.log('message',topic,payload.toString());
})
device.on('connect') 中的语句没有被执行。我只能看到正在打印“Invoking on connect”
编辑2:问题已解决!!!
在创建设备时,我必须将 Policy 附加到它。然后我可以通过带有证书的 MQTT 以上述指定方式发送数据。