使用AWS Lambda查询DynamoDB非分区键匹配项及返回报错问题

DynamoDB不支持直接对非主键属性执行高效查询，针对你要按bookyear筛选的场景，根据查询频率选对应方案即可：

• 高频查询场景：给表创建全局二级索引（GSI），将bookyear设为GSI的分区键，后续直接用query接口查询该GSI，性能远高于全表扫描，读容量消耗也更低，是生产环境的标准方案。
• 低频临时查询场景：无需修改表结构，直接在现有scan操作中增加FilterExpression过滤条件即可，仅适合小表、查询频率极低的场景，大表使用会产生极高的读容量成本和延迟。

代码示例 #

GSI + Query 方案（推荐） #

假设你已经创建了以bookyear为分区键的GSI，索引名为bookyear-index，代码如下：

app.get(path, function (req, res) {
  var params = {
    TableName: tableName,
    IndexName: 'bookyear-index', // 替换为你实际的GSI名称
    KeyConditionExpression: 'bookyear = :targetYear',
    ExpressionAttributeValues: {
      ':targetYear': 1997 // 也可以改成从请求参数动态取值
    }
  };

  dynamodb.query(params, (err, data) => {
    if (err) {
      return res.json({ error: 'Could not load items: ' + err.message });
    }
    // 类型转换避免返回报错
    const formattedItems = data.Items.map(item => AWS.DynamoDB.Converter.unmarshall(item));
    res.json({ data: formattedItems });
  });
});

Scan + 过滤 方案（仅临时使用） #

app.get(path, function (req, res) {
  var params = {
    TableName: tableName,
    Select: 'ALL_ATTRIBUTES',
    FilterExpression: 'bookyear = :targetYear',
    ExpressionAttributeValues: {
      ':targetYear': { N: '1997' } // DynamoDB原生格式需要指定数据类型
    }
  };

  dynamodb.scan(params, (err, data) => {
    if (err) {
      return res.json({ error: 'Could not load items: ' + err.message });
    }
    const formattedItems = data.Items.map(item => AWS.DynamoDB.Converter.unmarshall(item));
    res.json({ data: formattedItems });
  });
});

你遇到的返回报错基本是两个原因导致的：

1. 错误处理分支没有加return，即使触发了err逻辑，代码还会继续执行后面的res.json，导致重复返回响应触发异常，上面的代码示例里已经补上了return。
2. DynamoDB原生返回的data.Items是带类型标记的DynamoDB格式对象，比如数字会被封装为{N: '1997'}，字符串为{S: 'xxx'}，直接序列化返回会触发API网关或者Lambda的序列化异常，只需要用AWS.DynamoDB.Converter.unmarshall方法把每个Item转换成普通JS对象再返回即可，上面的示例已经包含了这部分逻辑。
   如果你用的是AWS SDK v3，需要先引入@aws-sdk/util-dynamodb包的unmarshall方法，用法和SDK v2完全一致。

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