有没有办法通过社交网络格式化S3通知？

Question

我正在测试存储桶中创建的新对象的SNS通知。当我收到SNS通知时，它看起来就像是一堆带参数的代码。类似于：

{"Records":[{"eventVersion":"2.0","eventSource":"aws:s3","awsRegion":"eu-west-1","eventTime":"2016-08-28T09:12:36.709Z","eventName":"ObjectCreated:Put","userIdentity":.......

我希望将这些数据转换为人类可读的格式，例如：

Time: xxxxxxx
Bucket: xxxxxxxx 
Event: xxxxx

有什么办法可以做到吗？一些我应该知道的演练？

Answer 1

因此，在所有更改之后，这是最终的代码：

var util = require('util');
var AWS = require('aws-sdk');  
AWS.config.region = 'eu-west-1';


exports.handler = function(event, context, callback) {
    // Read options from the event.
    console.log("Reading options from event:\n", util.inspect(event, {depth: 5}));

    var s3Event = event.Records[0];

    var srcBucket = s3Event.s3.bucket.name;
    var srcEvent = s3Event.eventName;
    var time = s3Event.eventTime;
    var nombre = s3Event.s3.object.key;
    var tamano = s3Event.s3.object.size;

    var msg = "Nuevo objeto \r\n" +
              "Hora: " + time + "\r\n" +
              "Bucket: " + srcBucket + "\r\n" + 
              "Evento: " + srcEvent + "\r\n" +
              "Objeto: " + nombre + "\r\n" +
              "Tamaño (en MB): " + tamano/1048576 + "\r\n";

    var sns = new AWS.SNS();

    sns.publish({
        Message: msg,
        TopicArn: 'TOPIC_ARN'
    }, function(err, data) {
        if (err) {
            console.log(err.stack);
            return;
        }
        console.log('push sent');
        console.log(msg);
        context.done(null, 'Function Finished!');  
    });

}

请注意，我添加了两个新变量："nombre“获取所创建文件的名称，"tamano”获取文件大小。最后一个是以字节为单位的，所以我通过一个简单的操作将它转换为兆字节。

Answer 2

我假设你的SNS通知订阅者是电子邮件端点？

我认为最简单的方法是使用AWS Lambda进行格式化。

不是将s3事件发布到SNS，而是将它们发布到AWS Lambda函数。在Lambda函数中，编写一些代码来根据需要格式化事件记录。然后Lambda函数可以将消息发布到SNS主题。

有关设置Lambda函数以便在将图像上载到S3时生成缩略图的教程，请参阅http://docs.aws.amazon.com/lambda/latest/dg/with-s3-example.html。

它演示了如何在lambda函数中访问事件属性。

从这个例子中学习，并根据你的情况进行调整：

var util = require('util');
var AWS = require('aws-sdk');  
AWS.config.region = 'eu-west-1';


exports.handler = function(event, context, callback) {
    // Read options from the event.
    console.log("Reading options from event:\n", util.inspect(event, {depth: 5}));

    var s3Event = event.Records[0];

    var srcBucket = s3Event.s3.bucket.name;
    var srcEvent = s3Event.eventName;
    var time = s3Event.eventTime;

    var msg = "Time: " + time + "\r\n" +
              "Bucket: " + srcBucket + "\r\n" + 
              "Event: " + srcEvent + "\r\n";

    var sns = new AWS.SNS();

    sns.publish({
        Message: msg,
        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!');  
    });

}

(上面还包括了https://gist.github.com/jeremypruitt/ab70d78b815eae84e037关于发布到社交网站的一段代码。)

这只是一个未经测试的示例-我建议您遵循上面的教程，因为它还会告诉您需要进行的各种权限和其他配置-但上面的函数应该作为一个起点。