2

我正在研究 AWS IoT，试图创建 API 来更新影子事物。

我做了什么（在 ClaudiaJS 中）

参考https://github.com/aws/aws-iot-device-sdk-js

var awsIot = require('aws-iot-device-sdk');

api.post(PREFIX + '/iot/test/{property}', function (request) {

var property = request.pathParams.property;

var thingShadows = awsIot.thingShadow({
   keyPath: <YourPrivateKeyPath>,
  certPath: <YourCertificatePath>,
    caPath: <YourRootCACertificatePath>,
  clientId: <YourUniqueClientIdentifier>,
      host: <YourCustomEndpoint>
});

var clientTokenUpdate;

thingShadows.on('connect', function() {

    thingShadows.register( 'IoTTestThing', {}, function() {

       var shadowState = {"state":{"desired":{"property": property}}};

       clientTokenUpdate = thingShadows.update('IoTTestThing', shadowState  );

       if (clientTokenUpdate === null)
       {
          console.log('update shadow failed, operation still in progress');
       }
    });
});

thingShadows.on('status', 
    function('IoTTestThing', stat, clientToken, stateObject) {
       console.log('received '+stat+' on '+thingName+': '+
                   JSON.stringify(stateObject));
       return 'IoT status updated';

    });

thingShadows.on('delta', 
    function('IoTTestThing', stateObject) {
       console.log('received delta on '+thingName+': '+
                   JSON.stringify(stateObject));
       return 'IoT delta updated';
    });

 }

我运行 API，没有任何反应，我知道我还没有在我的代码中实现 Promise 的原因。但我不知道如何在 AWS IoT SDK 中做到这一点，尽管 AWS SDK 支持 Promise（https://aws.amazon.com/blogs/developer/support-for-promises-in-the-sdk/）

任何建议都非常感谢。

4

2 回答 2

1

我遇到了同样的问题，但我能够使用此代码解决此问题，我提供了链接和代码，如果需要任何帮助，请告诉我 https://gist.github.com/dave-malone/ 611800d7afa90561f3b40ca6b2380faf

const AWS = require('aws-sdk')

AWS.config.region = process.env.AWS_REGION

const iotdata = new AWS.IotData({
endpoint: process.env.MQTT_BROKER_ENDPOINT,
accessKeyId: process.env.ACCESS_KEY_ID,
secretAccessKey: process.env.SECRET_ACCESS_KEY
})

const openState = "open"
const closedState = "closed"

let currentState = closedState

function toggleGarageDoor() {
return new Promise((resolve, reject) => {
let desiredState = (currentState === closedState) ? openState : closedState

var params = {
  payload: `{"state":{"desired":{"door":"${desiredState}"}}}`,
  thingName: process.env.THING_NAME
}

iotdata.updateThingShadow(params, (err, data) => {
  if (err){
    console.log(err, err.stack)
    reject(`Failed to update thing shadow: ${err.errorMessage}`)
  }else{
    console.log(`update thing shadow response: ${JSON.stringify(data)}`)
    currentState = desiredState
    resolve({"update thing shadow response": data})
  }
})
})
}

exports.handler = async (event, context, callback) => {
await toggleGarageDoor()
.then((result) => callback(null, result))
.catch((err) => callback(err))
}
于 2019-03-18T13:27:55.580 回答
-1

也许我猜你需要 on('foreignStateChange')

于 2020-04-08T09:25:37.637 回答