使用DynamoDB Scan筛选用户数据时遇Internal server error及HttpErrorResponse问题

场景说明 #

需要扫描DynamoDB表，仅返回与登录用户cognitoUserName匹配的数据（实现用户数据隔离）。表结构：分区键certificateId（唯一值），排序键userName（存在重复记录）。当前Lambda Handler执行后返回502错误及"Internal server error"提示。

错误详情 #

error: {message: 'Internal server error'}
headers: HttpHeaders "Http failure response for https://duth-1.amazonaws.com/dev/certificateList: 502 OK"
name: "HttpErrorResponse"
ok: false
status: 502
statusText:"OK"
url: "https://uth-1.amazonaws.com/dev/certificateList"

关联代码片段 #

// My handler Function
// 分区键：certificateId（唯一）
// 排序键：userName（可能重复）

module.exports.getAllCertificate = async (event, context, cb) => {
  context.callBackWaitsForEmptyEventLoop = false;
  let data = JSON.parse(event.body);
  cognitoUserName= data.email;
  try{
    var params = {
      TableName: CERTIFICATE_TABLE_NAME,
      FilterExpression: "userName = :userName",
      ExpressionAttributeValues:{
        ":userName": cognitoUserName
      }
  };
    const certiificates = await documentClient.scan(params).promise()
    console.log(JSON.stringify(certiificates));
    cb(null,send(200, certiificates));
  } catch(err){
   
    cb(null,send(500,err.message));
  }
};

可能的问题及修复方案 #

1. 未声明变量导致语法错误 #

代码中cognitoUserName未使用var/let/const声明，严格模式下会抛出ReferenceError，直接终止Lambda执行。
修复：添加变量声明关键字

const cognitoUserName = data.email;

2. documentClient未初始化 #

代码直接调用documentClient但未初始化实例，会抛出ReferenceError。
修复：在代码顶部添加DynamoDB客户端初始化逻辑

const AWS = require('aws-sdk');
// 可指定区域，或依赖Lambda环境变量配置的区域
const documentClient = new AWS.DynamoDB.DocumentClient({ region: '你的AWS区域' });

3. send函数未定义 #

代码中使用的send()函数未实现，会导致响应构造失败，触发API Gateway 502错误。
修复：实现符合API Gateway要求的响应构造函数

const send = (statusCode, data) => {
  return {
    statusCode: statusCode,
    headers: {
      'Content-Type': 'application/json',
      'Access-Control-Allow-Origin': '*' // 根据业务需求配置CORS
    },
    body: JSON.stringify(data)
  };
};

4. event.body格式异常 #

如果请求无body或body不是合法JSON，JSON.parse(event.body)会抛出SyntaxError，进入catch块后仍因send函数问题导致响应格式错误。
修复：添加格式校验与空值处理

let data = {};
if (event.body) {
  try {
    data = JSON.parse(event.body);
  } catch (parseErr) {
    return cb(null, send(400, '请求体格式无效'));
  }
}
const cognitoUserName = data.email;
if (!cognitoUserName) {
  return cb(null, send(400, '缺少email参数'));
}

5. 环境变量CERTIFICATE_TABLE_NAME未配置 #

Lambda未配置该环境变量时，params.TableName为undefined，DynamoDB调用会失败。
修复：在Lambda控制台的「环境变量」中添加CERTIFICATE_TABLE_NAME，值为目标DynamoDB表名。

6. Lambda权限不足 #

Lambda执行角色无DynamoDB扫描权限时，会抛出AccessDeniedException，导致执行失败。
修复：给Lambda角色添加以下权限策略：

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": "dynamodb:Scan",
      "Resource": "arn:aws:dynamodb:你的区域:你的账号ID:table/你的表名"
    }
  ]
}

7. Async函数与回调混用冲突 #

当前代码为async函数，但同时使用cb回调，可能导致响应处理逻辑混乱，API Gateway因格式错误返回502。
修复：改用async函数返回值替代回调（推荐写法）

module.exports.getAllCertificate = async (event) => {
  context.callbackWaitsForEmptyEventLoop = false;
  let data = {};
  try {
    if (event.body) {
      data = JSON.parse(event.body);
    }
    const cognitoUserName = data.email;
    if (!cognitoUserName) {
      return send(400, '缺少email参数');
    }
    const params = {
      TableName: process.env.CERTIFICATE_TABLE_NAME,
      FilterExpression: "userName = :userName",
      ExpressionAttributeValues:{
        ":userName": cognitoUserName
      }
    };
    const certificates = await documentClient.scan(params).promise();
    console.log(JSON.stringify(certificates));
    return send(200, certificates);
  } catch(err){
    console.error('执行错误:', err);
    return send(500, err.message);
  }
};

8. 性能优化：替换Scan实现数据隔离 #

当前用Scan+FilterExpression效率极低，数据量大时会消耗大量读取容量且响应缓慢。建议优化表结构：

• 改为以userName为分区键，certificateId为排序键，可通过Query直接获取指定用户的所有证书，效率远高于Scan。
• 若无法修改表结构，可创建全局二级索引（GSI），以userName为分区键，通过Query GSI获取数据。

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