【Rico Board试用体验】Amazon Iot物联网终端之十三 Iot物联网终端在AWS的设置

3、整个设置居于核心的是AWS lambda服务，提供了一个在云端运行的函数，对智能硬件终端传输的数据进行分析，并连接AWS的其他服务，如数据库服务，存储服务，短消息发送等。下面列出，事件处理的核心Node.js程序iotapi.handler，供参照和理解。

// Lambda function acting as API endpoint for Evothings IoT Example

console.log('Loading function');

var AWS = require('aws-sdk');
var DOC = require('dynamodb-doc');

var cw = new AWS.CloudWatch();
var doc = new DOC.DynamoDB();

exports.handler = function(event, context) {
    console.log('Received event:', JSON.stringify(event, null, 2));

    switch(event.operation) {
        case 'update':
            update(event.sensorid, event.value, context);
            break;
        case 'query':
            query(event.sensorid, context);
            break;
    }

};

var update = function(sensorid, value, context) {

    var itemParams = {
        TableName: 'SensorData',
        Item: {
            SensorId: sensorid,
            Timestamp: new Date().toISOString(),
            Value: value
        }};

    doc.putItem(itemParams, function(err, data) {
      if (err) {
        console.log('DDB call failed: ' + err, err.stack);
        context.error(err);
      } else {

        //if all is well - also log the metric to CloudWatch
        logMetric(sensorid, value, function(err, data) {
          if (err) {
            console.log('CW call failed: ' + err, err.stack);
            context.error(err);
          } else {
            context.succeed();
          }
        });
      }
    });
}

var logMetric = function(sensorid, value, callback) {
    var params = {
      MetricData: [{
          MetricName: 'SensorData',
          Dimensions: [{ Name: 'SensorId', Value: sensorid }],
          Timestamp: new Date(),
          Value: value
        }],
      Namespace: 'Sensors'
    };

    cw.putMetricData(params, callback);
}

var query = function(sensorid, context) {
    var params = {
        TableName: 'SensorData',
        Limit: 20,                  //return the 20...
        ScanIndexForward: false,    //... most recent items
        KeyConditions: [doc.Condition('SensorId', 'EQ', sensorid)]
    };

    doc.query(params, function(err, data) {
        if (err) {
            console.log(err, err.stack); // an error occurred
            context.fail(err);
        }
        else {
            console.log(data);           // successful response
            context.succeed(data);
        }
    });

}