0

AWS Lambdaという関数がAWS DynamoDBによってトリガーされています。機能チェックDBの動作はINSERTあり、そしてそれがないならば、それはAWS SNSを使用して、新しいプッシュメッセージを送信する場合:Lambda関数を使用してDynamoDBで追加されたアイテムの属性を取得する方法

console.log('Loading function'); 

var AWS = require('aws-sdk'); 
AWS.config.region = 'us-east-1'; 

exports.handler = function(event, context, callback) { 
    console.log("\n\nLoading handler\n\n"); 
    var sns = new AWS.SNS(); 

    console.log(JSON.stringify(event, null, 2)); 
    event.Records.forEach(function(record) { 
     if (record.eventName == "INSERT") { 
      sns.publish({ 
       Subject: 'Test', 
       Message: 'Test publish to SNS from Lambda', 
       TopicArn: 'TOPIC-ARN' 
      }, function(err, data) { 
       if (err) { 
        console.log(err.stack); 
        return; 
       } 
       console.log('push sent'); 
       console.log(data); 
       context.done(null, 'Function Finished!'); 
      }); 
     } 
    }); 
    callback(null, "message"); 
}; 

は、私が新しく追加されたアイテムの属性を得ることができるそこの方法ですか?

+0

その情報は 'event'オブジェクトにあるべきです。あなたが 'event'オブジェクトを記録しているのを見ていますが、そこにデータが表示されていませんか? –

+0

サンプルデータによると、 'record.dynamodb.Keys.Id'は101であると思われますか? – Ido

+0

申し訳ありませんが、あなたの質問は意味をなさない。更新されたレコードの「Id」値はどのようにすべきか –

答えて

-1
var id = record.dynamodb.Keys.Id.N; 
関連する問題