如何使用Express/Node.js访问Amazon SNS邮件正文

Question

我正在重建Node.js中的PHP应用程序，并在Express框架之上。

应用程序的一部分是Amazon SNS notification过帐的回调URL。

从SNS的POST体目前在PHP（工作）阅读下面的方法：

$notification = json_decode(file_get_contents('php://input')); 

在表达我曾尝试以下：

app.post('/notification/url', function(req, res) { 
    console.log(req.body); 
}); 

然而，看着控制台，这个帖子只会记录以下内容：

{} 

因此，重复任务ion：您如何使用Express/Node.js访问Amazon SNS邮件正文

Answer 1

另一种方法是固定的Content-Type首部。

这里是中间件的代码来做到这一点：

exports.overrideContentType = function(){ 
    return function(req, res, next) { 
    if (req.headers['x-amz-sns-message-type']) { 
     req.headers['content-type'] = 'application/json;charset=UTF-8'; 
    } 
    next(); 
    }; 
} 

这是假定有一个名为util.js中位于根项目目录有：

util = require('./util'); 

在

您app。JS通过和调用包括：

app.use(util.overrideContentType()); 

前

app.use(express.bodyParser()); 

在

app.js文件。这使得bodyParser（）来解析人体正常...

较少干扰，然后你可以访问req.body正常。

Answer 2

看看AWS Node.js SDK - 它可以访问所有AWS服务端点。

var sns = new AWS.SNS(); 

    // subscribe 
    sns.subscribe({topic: "topic", Protocol: "https"}, function (err, data) { 
     if (err) { 
     console.log(err); // an error occurred 
     } else { 
     console.log(data); // successful response - the body should be in the data 
    } 
    }); 


    // publish example 
    sns.publish({topic: "topic", message: "my message"}, function (err, data) { 
     if (err) { 
     console.log(err); // an error occurred 
     } else { 
     console.log(data); // successful response - the body should be in the data 
    } 
    }); 

编辑：问题是标准身材分析器不处理纯/文这就是SNS发送的内容类型。这里是提取原始身体的代码。你的身体解析器之前将其放置：

app.use(function(req, res, next) { 
    var d= ''; 
    req.setEncoding('utf8'); 
    req.on('d', function(chunk) { 
     d+= chunk; 
    }); 
    req.on('end', function() { 
     req.rawBody = d; 
     next(); 
    }); 
}); 

然后，您可以使用：

JSON.stringify(req.rawBody)); 

路线内创建一个JavaScript对象，并在SNS运营后适当。

您也可以修改body parser来处理text/plain，但修改中间件不是一个好主意。只需使用上面的代码。

Answer 3

这是基于AlexGad的answer.Particularly此评论：

标准快递解析器将只处理应用程序/ JSON，应用程序/ x-WWW的形式编码和多/表单数据。我在上面添加了一些代码，放在你的body parser之前。

app.post('/notification/url', function(req, res) { 
    var bodyarr = [] 
    req.on('data', function(chunk){ 
     bodyarr.push(chunk); 
    }) 
    req.on('end', function(){ 
     console.log(bodyarr.join('')) 
    }) 
})