2

我使用 node.js lambda 向远程 api 发出 post 请求，远程 api 安装在几个远程位置。
我无权访问远程 api 代码或日志。
lambda 由我也无法控制的外部应用程序使用 HTTP 网关调用。

它适用于除一个以外的所有位置。对于一个位置，我收到此错误：

411 长度要求。

我试图中和 HTTP 网关，并运行带有测试事件的 lambda 帖子。
我得到相同的结果。

我已将相同的确切请求发送到其他位置，并得到了响应。我确实发送了标头，因此找不到问题ContentLength。

这是 lambda 代码：

const https = require("https");
const iconv =  require("iconv-lite");
const charset  =  require("charset");
const qs  =  require("qs");
const url  =  require("url");

exports.handler = (event, context, callback) => {
  event = JSON.parse(JSON.stringify(event));

    let enc ="";
    let multiValueHeaders = event["multiValueHeaders"]["Content-Type"];
    let PostParams = null;
    let domain = event["queryStringParameters"]["domain"] ;

    let buf = Buffer.from(JSON.stringify(event["body"]), "base64"); 
    let tstring =   buf.toString("utf8");
    PostParams  = qs.parse(tstring);
     
    var postData = PostParams ?  qs.stringify(PostParams) : {};
    
    let ContentLength = new Buffer.from(postData).length;
    let headers = "" ;
    headers += (multiValueHeaders) ? (' { "Content-Type": "'+ multiValueHeaders + '",') : '{';
    headers += ('"Content-Length":'+ ContentLength + '}');
    headers = JSON.parse(headers);
   
    var q = url.parse(domain, true);
    let options = {
      'method': 'POST',
      'hostname': q.hostname,
      'path': q.pathname,
      'headers':  {headers}
    };
    
      var req = http.request(options, function (res) {
      let chunks = [];
    
      res.on("data", function (chunk) {
        chunks.push(chunk);
        enc = charset(res.headers, chunk);
      });
    
      res.on("end", function (chunk) {
          var decodedBody = iconv.decode(Buffer.concat(chunks), enc);
   
          const response = {
              statusCode: 200,
              body: decodedBody
          };
          callback(null ,response );
      });
    
      res.on("error", function (error) {
        console.error(error);
      });
    }); 
  
    
    if (PostParams != null) req.write(postData);
    req.end();  
     
  
}

当一个请求直接发送到端点邮递员时，没有错误。仅来自 lambda。

4

2 回答 2

2

除了这个为什么event = JSON.parse(JSON.stringify(event));？

除此之外，这是构建对象的一种非常丑陋的方式headers：

let headers = "";
headers += (multiValueHeaders) ? (' { "Content-Type": "'+ multiValueHeaders + '",') : '{';
headers += ('"Content-Length":'+ ContentLength + '}');
headers = JSON.parse(headers);

我会写成：

const headers = { "Content-Length": ContentLength };
if(multiValueHeaders) headers["Content-Type"] = multiValueHeaders;

您的问题的根本原因在于这一行：

'headers':  {headers}

它需要在以下方面进行更改：

'headers': headers

希望这可以帮助

于 2020-07-05T01:01:38.483 回答
2

411当服务器要求有效时返回Content-Length

event通过 HTTP 网关传递的参数是整个客户端请求对象。你不必解析它。

event.body是一个转义字符串。双重转义它会给出错误的内容长度。例如，

JSON.stringify({'double': 2}) !== JSON.stringify(JSON.stringify({'double': 2))
// false

考虑到这一点，您可以像这样执行您的请求：

exports.handler = (event, context, callback) => {
    let enc = "";
    let multiValueHeaders = event["multiValueHeaders"];
    let domain = event["queryStringParameters"]["domain"] ;
    

    const postHeaders = {...multiValueHeaders};
    let postData = null;
    if (event.body !== null) {
       postData = qs.stringify(
          qs.parse(
             Buffer.from(event.body, "base64").toString("utf-8")
          )
       );
       postHeaders['Content-Length'] = [ Buffer.byteLength(postData) ];
    }
   
    var q = url.parse(domain, true);
    let options = {
      'method': 'POST',
      'hostname': q.hostname,
      'path': q.pathname,
      'headers':  postHeaders
    };
    
    var req = http.request(options, function (res) {
      let chunks = [];
    
      res.on("data", function (chunk) {
        chunks.push(chunk);
        enc = charset(res.headers, chunk);
      });
    
      res.on("end", function (chunk) {
          var decodedBody = iconv.decode(Buffer.concat(chunks), enc);
   
          const response = {
              statusCode: 200,
              body: decodedBody
          };
          callback(null, response);
      });
    
      res.on("error", function (error) {
        console.error(error);
      });
    }); 
  
    if (postData !== null) req.write(postData);
    req.end();  
}
于 2020-07-05T08:36:51.447 回答