如何从 lambda 发布到 AWS Shadow

Question

这是我正在使用的代码，

var AWS = require('aws-sdk');

var iotdata = new AWS.IotData({
  endpoint: '###########.iot.ap-south-1.amazonaws.com'
});

exports.handler = async (event) => {

  var params = {
  payload: Buffer.from('...') || 'STRING_VALUE'  
  encoded on your behalf */, /* required */
  thingName: 'ESP32', /* required */
  //shadowName: 'STRING_VALUE'
 };
 iotdata.updateThingShadow(params, function(err, data) {
  if (err) console.log(err, err.stack); // an error occurred
  else     console.log(data);           // successful response
 });
  
};

我从给定的链接中提到了这一点， https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/IotData.html#updateThingShadow-property

但我无法更新我的影子。 我也不明白应该以哪种格式包含有效负载。

我在 Nodejs 12.x 环境中的 AWS Lambda 函数上运行它。我在 cloudwatch 中也没有收到任何错误。 Cloudwatch 告诉我执行结果成功了？你能帮帮我吗？

我已经授权 Lambda 更新Shadow。

Answer 1

这是最终正确的代码.....

var AWS = require('aws-sdk');

var iotdata = new AWS.IotData({
  endpoint: '#######.iot.ap-south-1.amazonaws.com'
});

exports.handler = async (event) => {

var POST_DATA = JSON.stringify({"state":{"desired":{"state":10}}});
await new Promise((resolve, reject) => {
   var params = {
  payload:POST_DATA , 
  
  thingName: 'ESP32', /* required */
  //shadowName: 'STRING_VALUE'
 };
  iotdata.updateThingShadow(params, function(err, data) {
      if (err) { 
         console.log(err, err.stack); 
         console.log("error................")// an error occurred
         reject(err);
      } else {
         console.log(data);           // successful response
         resolve(data)
      }
 });
})

}

Answer 2

这里的问题是您使用的是异步 Lambda 处理程序。因此，当您的 updateThingShadow() 调用正在进行时，Lambda 函数完成并退出。您需要等待该调用完成。有两种方法可以做到这一点-

方法 1：（更简单的 async-await 语法）

var AWS = require('aws-sdk');

var iotdata = new AWS.IotData({
  endpoint: '###########.iot.ap-south-1.amazonaws.com'
});

exports.handler = async (event) => {

  var params = {
  // Define params
  };
  try {
        const data = await iotdata.updateThingShadow(params).promise();
        console.log(data);
  } catch (err) {
        console.log(err);
  }
};

方法2：（如果您更喜欢使用回调方法）

var AWS = require('aws-sdk');

var iotdata = new AWS.IotData({
  endpoint: '###########.iot.ap-south-1.amazonaws.com'
});

exports.handler = async (event) => {

  var params = {
  // Define params
  };
  await new Promise((resolve, reject) => {
      iotdata.updateThingShadow(params, function(err, data) {
         if (err) { 
            console.log(err, err.stack); // an error occurred
            reject(err); // End the promise with an error
         } else {
            console.log(data); // successful response
            resolve(data); // End the promise with success
         }
      });
   }) 
};