2

我只是想构建一个自动订阅 API 来回发令牌。我可以在 Sinatra 中很容易地做到这一点（从 AWS 渲染 POSTed JSON）——似乎在 Express 中遇到了困难；我确定这只是我缺少的一些愚蠢的东西，尽管我已经尝试了 1000X 组合。

这是 Sinatra 网络服务器：

# application.rb

require 'rubygems'
require 'sinatra'
require 'json'

set :port, 8081

post '/webservice/cloudwatch' do
  content_type :json
  puts "Body: " + request.body.read
end

哪些日志：

- -> /webservice/cloudwatch
Body: {
  "Type" : "SubscriptionConfirmation",
  "MessageId" : "OMIT",
  "Token" : "OMIT",
  "TopicArn" : "OMIT",
  "Message" : "OMIT",
  "SubscribeURL" : "OMIT",
  "Timestamp" : "2012-02-28T21:28:02.082Z",
  "SignatureVersion" : "1",
  "Signature" : "OMIT",
  "SigningCertURL" : "OMIT"
}

这是 Express 网络服务器：

var express, app, stache;
express = require("express"), app = express.createServer();
app.configure(function () {
  app.use(express.methodOverride());
  app.use(express.bodyParser());
  app.use(app.router);
  app.set("view options", {
    layout: false
  });
  app.use(express.errorHandler({
    dumpExceptions: true,
    showStack: true
  }));
});
app.post("/webservice/cloudwatch", function (request, response) {
  request.accepts('application/json');
  console.log("post body: " + JSON.stringify(request.params));
  console.log("post body: " + JSON.stringify(request.body.read));
});  
app.listen(8081);

哪些日志：

post body: []
post body: undefined

请帮忙！

4

3 回答 3

2

当亚马逊向您的端点发送 http post 请求时，它没有指定内容类型。根据他们的回答，这对他们来说是一个已知问题。

与此同时，我一直在测试一个非常hacky的解决方法。我修改了 express 插件中的 bodyParser.js 文件。具体来说，我在 mime 函数中添加了一个 if 检查，以便我可以强制它假装内容类型是application/json必要的。

这是修改后的 mime 函数：

function mime(req) {
    if(req.headers['x-amz-sns-message-type'] == 'SubscriptionConfirmation' && !req.headers.hasOwnProperty['content-type']) {
        req.headers['content-type'] = 'application/json';
    }

    var str = req.headers['content-type'] || '';
    return str.split(';')[0];
}
于 2012-05-25T07:37:27.087 回答
1

您使用哪个请求来测试您的网络服务？正在做：

curl -H "Content-Type: application/json" -d '{"Type":"SubscriptionConfirmation","MessageId":"OMIT","Token":"OMIT","TopicArn":"OMIT","Message":"OMIT","SubscribeURL":"OMIT","Timestamp":"2012-02-28T21:28:02.082Z","SignatureVersion":"1","Signature":"OMIT","SigningCertURL":"OMIT"}' http://localhost:8081/webservice/cloudwatch

（注意内容类型设置为 application/json）并将您的更改console.log为console.log(request.body);应该会给您预期的结果。bodyParser 方法需要知道内容类型才能正确填充 request.body。

于 2012-03-09T10:10:19.330 回答
0

将以下内容添加到您的快速服务器（确保 bodyParser 在 rawbody 之后）。尝试记录 request.rawbody

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

app.use(rawbody);
app.use(express.bodyParser());

感谢：Expressjs 原始正文

于 2014-01-17T19:40:27.440 回答