将DynamoDB Scan转换为Query的方法咨询（主键为ID）

把DynamoDB Scan改成Query的实操指南（基于主键ID） #

嗨，我完全懂你的顾虑——Scan确实会遍历整张表，数据量越大成本越高、速度越慢，换成Query就好多了，它只针对主键匹配的分区读取数据，性能和成本都友好很多。咱们结合你的主键是ID的情况，一步步来改：

核心前提：Query的规则 #

DynamoDB的Query必须指定分区键（也就是你的ID）的匹配条件，这是和Scan最大的区别——Scan是先扫全表再过滤，Query是直接定位到符合主键条件的数据，所以首先要确保你的查询需求是基于ID的（如果是按其他非主键字段筛选，那得建全局二级索引GSI，后面我也提一句）。

情况1：API Gateway + Lambda 集成 #

假设你之前用Lambda写的Scan代码大概是这样（以Node.js为例）：

const AWS = require('aws-sdk');
const dynamodb = new AWS.DynamoDB.DocumentClient();

exports.handler = async (event) => {
  // 原来的Scan参数
  const scanParams = {
    TableName: '你的表名',
    FilterExpression: 'ID = :idVal', // Scan用FilterExpression事后过滤
    ExpressionAttributeValues: { ':idVal': event.queryStringParameters.id }
  };
  const scanResult = await dynamodb.scan(scanParams).promise();
  return { statusCode: 200, body: JSON.stringify(scanResult.Items) };
};

改成Query的话，只需要修改参数结构和调用方法：

const AWS = require('aws-sdk');
const dynamodb = new AWS.DynamoDB.DocumentClient();

exports.handler = async (event) => {
  // 新的Query参数
  const queryParams = {
    TableName: '你的表名',
    KeyConditionExpression: 'ID = :idVal', // Query用KeyConditionExpression指定主键匹配
    ExpressionAttributeValues: { ':idVal': event.queryStringParameters.id }
  };
  const queryResult = await dynamodb.query(queryParams).promise();
  return { statusCode: 200, body: JSON.stringify(queryResult.Items) };
};

关键改动点：

• 把scan()方法换成query()
• 把FilterExpression换成KeyConditionExpression——这是Query的必填项，必须包含分区键（ID）的匹配条件
• 如果ID是数值类型，记得把ExpressionAttributeValues里的值改成数字（比如event.queryStringParameters.id是字符串的话，要转成Number(event.queryStringParameters.id)）

情况2：API Gateway 直接集成 DynamoDB（无Lambda） #

如果是用API Gateway的直接集成（VTL模板），原来的Scan请求模板可能是这样：

{
  "TableName": "你的表名",
  "FilterExpression": "ID = :id",
  "ExpressionAttributeValues": {
    ":id": { "S": "$input.params('id')" }
  }
}

改成Query需要两步：

1. 修改VTL请求模板为Query格式：

{
  "TableName": "你的表名",
  "KeyConditionExpression": "ID = :id",
  "ExpressionAttributeValues": {
    ":id": { "S": "$input.params('id')" }
  }
}

• 注意：如果ID是数值类型，把"S"改成"N"，比如":id": { "N": "$input.params('id')" }

2. 在API Gateway的集成设置里，把DynamoDB的操作从Scan改成Query——这步很容易忘，一定要改！

额外补充：如果不是按ID查询怎么办？ #

如果你的需求是按非主键字段筛选（比如按用户状态、创建时间），那直接用Query不行，得给那个字段创建全局二级索引（GSI），然后对GSI执行Query，原理和上面一样，只是TableName换成IndexName指定你的索引名，KeyConditionExpression用GSI的分区键。

最后再确认下：Query的成本是按实际读取到的符合条件的项数计算，而Scan是按扫描过的所有项数计算，所以表越大，Query的成本优势越明显，改完后你可以去CloudWatch里看看DynamoDB的读取指标，肯定会有优化~

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