使用NodeJS+AWS Lambda调用DynamoDB查询时出现502错误求助

核心错误点 #

• query方法误用：DynamoDB的query操作必须指定KeyConditionExpression，用于匹配主键（分区键/排序键）。你的代码仅使用FilterExpression，不符合query的参数要求，会直接触发API调用错误。
• 未定义变量tableName：错误提示里的${tableName}未在代码中定义，运行时会抛出ReferenceError，导致Lambda执行失败。
• 错误处理逻辑缺陷：出错后未终止后续响应逻辑，会导致重复调用res.json，触发API Gateway的502错误；同时未输出实际错误信息，无法定位具体问题。
• 特定客户查询效率低下：通过customerId查询单条数据时，应使用get操作（针对主键），而非query或scan，前者性能远高于后者。

修复后的代码 #

1. 获取科罗拉多州客户列表（两种方案）

方案一：使用scan（适合小数据集）

router.get("/customers", (req, res) => {
    const tableName = 'Customer';
    const params = {
      TableName: tableName,
      FilterExpression: "stateOrProvince = :state",
      ExpressionAttributeValues: {
        ":state": "Colorado"
      }
    };
    dynamoDb.scan(params, (error, result) => {
      if (error) {
        console.error("Scan error:", error);
        return res.status(400).json({ error: `Error fetching ${tableName}: ${error.message}` });
      }
      res.json(result.Items);
    });
});

方案二：使用query（需先给stateOrProvince建GSI，适合大数据集）

先在DynamoDB控制台给Customer表创建全局二级索引，索引分区键设为stateOrProvince，再修改代码：

router.get("/customers", (req, res) => {
    const tableName = 'Customer';
    const params = {
      TableName: tableName,
      IndexName: 'StateOrProvinceIndex', // 替换为你的GSI名称
      KeyConditionExpression: "stateOrProvince = :state",
      ExpressionAttributeValues: {
        ":state": "Colorado"
      }
    };
    dynamoDb.query(params, (error, result) => {
      if (error) {
        console.error("Query error:", error);
        return res.status(400).json({ error: `Error fetching ${tableName}: ${error.message}` });
      }
      res.json(result.Items);
    });
});

2. 获取特定客户详情（使用get操作）

router.get("/customers/:customerId", (req, res) => {
    const tableName = 'Customer';
    const id = req.params.customerId;
    const params = {
      TableName: tableName,
      Key: {
        "customerId": id // 假设customerId是表的分区键
      }
    };
    dynamoDb.get(params, (error, result) => {
      if (error) {
        console.error("Get error:", error);
        return res.status(400).json({ error: `Error fetching customer ${id}: ${error.message}` });
      }
      if (!result.Item) {
        return res.status(404).json({ error: `Customer ${id} not found` });
      }
      res.json(result.Item);
    });
});

额外排查建议 #

1. 查看Lambda控制台的CloudWatch日志，里面会记录具体的运行时错误，是定位问题的关键。
2. 确认Lambda执行角色拥有DynamoDB的scan/query/get权限，权限不足也会导致调用失败。
3. 确保customerId是表的主键，否则get操作无法生效，需调整为对应主键字段。

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