Node.js 18.x升级后API Gateway Lambda出现格式错误代理响应求助

核心问题分析 #

1. Async函数响应处理错误：Node.js 18.x中，Lambda的async函数必须通过返回值传递响应，使用context.succeed()/context.fail()等旧方法会导致响应格式不符合API Gateway代理要求，触发Malformed Lambda proxy response错误。
2. 请求头拼接逻辑错误：options.headers += event.headers会将对象强制转为字符串（如[object Object]），导致请求头无效，进而可能引发Event字段解析异常。
3. 响应头覆盖问题：直接用上游响应的resp.headers覆盖自定义的安全头和CORS头，会丢失关键配置，同时可能导致头格式不符合要求。

分步修复方案 #

1. 替换旧的context响应方式

将context.succeed(response)和context.fail(error)替换为return response和返回错误响应，因为async函数的返回值会被Lambda作为响应处理。

2. 修复请求头合并逻辑

使用对象合并（扩展运算符）将Event中的请求头合并到options.headers中，避免字符串拼接错误。

3. 兼容Event字段的undefined情况

调整查询参数的判断逻辑，兼容queryStringParameters为undefined的场景（无查询参数时该字段为undefined而非null）。

4. 合并响应头而非覆盖

保留自定义的安全头和CORS头，同时合并上游响应的头信息，避免关键头丢失。

修改后的完整代码 #

import needle from "needle";
import qs from "querystring";

"use strict";

exports.endpoint = async (event) => {
  // 初始化默认响应，保留安全头和CORS配置
  const baseHeaders = {
    "Content-Type": "application/json",
    "Access-Control-Allow-Origin": "*",
    "Access-Control-Allow-Methods": "POST, GET",
    "Access-Control-Allow-Credentials": true,
    "X-XSS-Protection": "1; mode=block",
    "X-Frame-Options": "DENY",
    "X-Content-Type-Options": "nosniff",
    "Strict-Transport-Security": "max-age=31536000;",
    "Cache-Control": "no-cache, no-store, must-revalidate"
  };

  const response = {
    statusCode: 500,
    body: JSON.stringify({ 
      error: { errorCode: 500, errorMessage: "Internal Server Error - Try after sometime" } 
    }),
    headers: { ...baseHeaders }
  };

  try {
    console.log("Received Event:", JSON.stringify(event));

    // 处理路径和查询参数
    let requestPath = event.path || "";
    if (event.queryStringParameters) {
      const queryParamsString = qs.stringify(event.queryStringParameters);
      if (queryParamsString) {
        requestPath += `?${queryParamsString}`;
      }
    }

    const URL = `${process.env.routing_eks_host}:${process.env.routing_eks_port}${requestPath}`;
    console.log("Target URL:", URL);

    // 合并请求头
    const options = {
      method: event.httpMethod,
      headers: {
        "Content-Type": "application/json",
        ...event.headers // 正确合并Event中的请求头
      }
    };

    // 调用上游API
    const resp = await needle(event.httpMethod, URL, event.body, options);
    console.log("Upstream Response Code:", resp.statusCode);

    // 合并响应头，优先保留自定义安全头
    response.headers = { ...baseHeaders, ...resp.headers };
    response.statusCode = resp.statusCode;
    response.body = JSON.stringify(resp.body);

    return response; // 返回响应，替代context.succeed
  } catch (error) {
    console.error("API Call Error:", error.message);
    // 返回错误响应，而非context.fail
    return {
      ...response,
      body: JSON.stringify({ 
        error: { errorCode: 500, errorMessage: error.message } 
      })
    };
  }
};

额外注意事项 #

• 模块导入兼容：Node.js 18.x同时支持ES模块和CommonJS，若保留require写法也可正常运行，按需选择即可。
• API Gateway配置检查：确认API Gateway的集成类型为Lambda Proxy Integration，否则Event结构会与代码预期不符，导致字段为null/undefined。
• 环境变量验证：确保routing_eks_host和routing_eks_port环境变量已正确配置，避免URL拼接错误。

内容的提问来源于stack exchange，提问作者Geeta Joshi