Express/Node.jsを使用してAmazon SNSポスト本体にアクセスするには

Question

Expressフレームワークの上にあるNode.jsにPHPアプリケーションを再構築しています。

アプリケーションの一部は、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'); 

をアプリ。JSを含むによって呼び出さ：app.jsファイル内

app.use(express.bodyParser()); 

前

app.use(util.overrideContentType()); 

。これは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 
    } 
    }); 

EDIT：問題は、標準のボディパーサーは、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ポストに動作します。

また、text/plainを処理するように本体パーザーを変更することもできますが、ミドルウェアを変更することはできません。上記のコードを使用してください。

Answer 3

これは、このコメントAlexGadのanswer.Particularlyに基づいています。

標準特急パーサが唯一のアプリケーション/ JSON、アプリケーション/ X-WWW-形式でエンコードおよびマルチパート/フォームデータを処理しますが。上記のコードをあなたのボディパーサの前に追加しました。

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('')) 
    }) 
})