使用Next.js(getServerSideProps)调用Lambda的Elasticsearch返回502错误

核心问题分析 #

502错误提示Lambda返回无效JSON，大概率是以下原因导致：

• Lambda未捕获异常，抛出的错误导致无法返回合法JSON响应
• 返回的数据中包含无法JSON序列化的内容（如Date对象、undefined值、循环引用）
• Lambda执行超时，未完成响应就被强制终止

具体修复步骤 #

1. 给Lambda添加异常捕获机制 #

当前Lambda代码没有处理Elasticsearch查询可能出现的错误，一旦查询失败会直接抛出异常，导致CloudFront收到无效响应。修改代码如下：

app.get('/searchlist', async (req, res) => {
  try {
    const { query } = req.query;
    const client = new Client({
      node: "https://elastic-cloud....",
      auth: {
        username: process.env.USERNAME,
        password: process.env.PASSWORD
      }
    });

    const searchQuery = {
      query: {
        multi_match: {
          query: query,
          type: "phrase",
          fields: [
            'manufacturerTypeDescription^8',
            'manufacturerName^6',
            'ean^4',
            '_id^2',
          ]
        }
      }
    };

    const typeSearch = {
      index: "product",
      size: 50,
      body: searchQuery
    };

    const r = await client.search(typeSearch);
    const hits = r.body.hits;
    const items = hits.hits.map((hit) => ({
      _id: hit._id,
      ...hit._source,
    }));

    res.json({
      success: 'get call succeed!',
      items
    });
  } catch (err) {
    console.error('Lambda执行错误:', err);
    // 返回合法的错误JSON响应
    res.status(500).json({
      success: false,
      error: err.message || '查询失败'
    });
  }
});

2. 处理不可序列化的字段 #

Elasticsearch返回的hit._source中可能包含无法直接JSON序列化的内容（比如Date类型对象、undefined值），可以在map时手动转换：

const items = hits.hits.map((hit) => {
  const source = { ...hit._source };
  // 遍历字段，转换Date为字符串，移除undefined
  Object.keys(source).forEach(key => {
    if (source[key] instanceof Date) {
      source[key] = source[key].toISOString();
    } else if (source[key] === undefined) {
      delete source[key];
    }
  });
  return {
    _id: hit._id,
    ...source,
  };
});

3. 调整Lambda配置 #

• 超时时间：默认Lambda超时为3秒，查询50条数据可能耗时更长，建议调整到10秒（根据实际查询耗时调整）
• 内存分配：如果Elasticsearch查询需要较多资源，可适当提高Lambda内存（比如从128MB调到256MB或更高）

4. 优化Next.js端的响应处理 #

Next.js的getServerSideProps中，因设置了response: true，API.get返回的是完整响应对象，当前代码的esItems.data.items逻辑正确，但可以加一层更严谨的防御性判断：

export async function getServerSideProps(context) {
  let esItems;
  try {
    const { query } = context.query;
    const apiName = 'APINAME';
    const path = '/searchlist';
    const myInit = {
      response: true,
      queryStringParameters: { query: query }
    };
    const response = await API.get(apiName, path, myInit);
    esItems = response;
  } catch (err) {
    console.log('API调用错误:', err);
  }

  return {
    props: {
      allProducts: esItems?.data?.items || [],
    }
  };
}

测试建议 #

1. 在Lambda控制台直接测试函数，传入查询参数，查看返回的JSON是否合法
2. 用Postman直接调用Amplify REST API，确认返回的JSON格式正确
3. 查看CloudWatch日志，检查Lambda执行时的错误信息（如果有）

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