AWS Lambda通过Scan/Query从DynamoDB获取指定数据失败问题排查

核心思路：优先用Query而非Scan #

DynamoDB的Scan是全表扫描后过滤，效率极低且成本高，针对排序键sk的精准查询，必须用Query——但Query要求指定分区键（pk），或者通过全局二级索引（GSI）将sk作为索引的分区键来查询。

场景1：已知分区键固定值（比如所有宠物的pk都是"LOST_PET"） #

假设你的表结构是pk（分区键）固定为某个值，sk（排序键）是petID，直接用QueryCommand精准匹配：

import { DynamoDBClient, QueryCommand } from "@aws-sdk/client-dynamodb";
import { unmarshall } from "@aws-sdk/util-dynamodb";

const client = new DynamoDBClient({ region: "你的区域" });

export const handler = async (event) => {
  // 解析POST请求体的petID参数
  const { petID } = JSON.parse(event.body);
  
  const params = {
    TableName: "petalert-lost",
    // 精准匹配分区键+排序键
    KeyConditionExpression: "pk = :pkVal AND sk = :petIDVal",
    ExpressionAttributeValues: {
      ":pkVal": { S: "LOST_PET" }, // 替换为你的实际分区键值
      ":petIDVal": { S: petID }
    },
    // 可选：只返回需要的字段，减少数据传输
    ProjectionExpression: "pk, sk, petName, contactInfo"
  };

  try {
    const response = await client.send(new QueryCommand(params));
    // 将DynamoDB格式的数据转为普通JSON
    const items = response.Items.map(item => unmarshall(item));
    return {
      statusCode: 200,
      body: JSON.stringify(items)
    };
  } catch (error) {
    return {
      statusCode: 500,
      body: JSON.stringify({ error: error.message })
    };
  }
};

场景2：不知道分区键，需创建全局二级索引（GSI） #

如果你的表的分区键不是固定值，无法直接通过Query匹配sk，需要给表添加一个GSI：

• GSI的分区键设为sk（即petID）
• 索引名称比如sk-index

创建GSI后，修改Query参数指定索引：

const params = {
  TableName: "petalert-lost",
  IndexName: "sk-index", // 你的GSI名称
  KeyConditionExpression: "sk = :petIDVal",
  ExpressionAttributeValues: {
    ":petIDVal": { S: petID }
  }
};

为什么你之前用FilterExpression失败？ #

如果非要用Scan（强烈不推荐），正确的FilterExpression写法应该是这样（注意占位符和数据类型匹配）：

import { DynamoDBClient, ScanCommand } from "@aws-sdk/client-dynamodb";
import { unmarshall } from "@aws-sdk/util-dynamodb";

const client = new DynamoDBClient({ region: "你的区域" });

export const handler = async (event) => {
  const { petID } = JSON.parse(event.body);
  
  const params = {
    TableName: "petalert-lost",
    FilterExpression: "sk = :petIDVal",
    ExpressionAttributeValues: {
      ":petIDVal": { S: petID } // 必须和DynamoDB中sk的类型一致（这里假设是字符串S）
    }
  };

  try {
    const response = await client.send(new ScanCommand(params));
    const items = response.Items.map(item => unmarshall(item));
    return {
      statusCode: 200,
      body: JSON.stringify(items)
    };
  } catch (error) {
    return {
      statusCode: 500,
      body: JSON.stringify({ error: error.message })
    };
  }
};

失败的常见原因：

• 数据类型不匹配：比如DynamoDB中sk是字符串，你传了数字类型（{ N: petID }）
• 占位符写错：比如FilterExpression用了sk = petID而不是sk = :petIDVal
• 权限问题：Lambda角色没有DynamoDB的Query或Scan权限

内容的提问来源于stack exchange，提问作者Seb St Johnston