DynamoDB按ID查询报错，如何通过非分区键字段筛选数据？

我编写了两个DynamoDB查询函数，其中按email查询的函数可正常运行，但按id查询的函数触发错误：[ValidationException: The provided key element does not match the schema]。

我的代码如下：

// 正常运行的函数
async function getUserByEmail(email) {
    var service = new AWS.DynamoDB({ region: REGION });
    var dynamoDb = new AWS.DynamoDB.DocumentClient({ service: service });

    var params = { 
        TableName : TABLE,
        Key: {
            'email': email
        }
    };

    return dynamoDb.get(params).promise();
}


// 报错的函数
async function getUserById(id) {
    var service = new AWS.DynamoDB({ region: REGION });
    var dynamoDb = new AWS.DynamoDB.DocumentClient({ service: service });

    var params = { 
        TableName : TABLE,
        Key: {
            'id': id
        }
    };

    return dynamoDb.get(params).promise();
}

数据表结构为：{ email, user, id }，其中Partition key（分区键）为email，无排序键。我猜测Key参数仅支持email，但想了解如何通过其他字段进行筛选？

你的猜测完全正确，DynamoDB的get方法**必须使用表的主键（分区键+排序键，如果有）**来查询。因为你的表分区键是email，用id作为Key参数不符合表的schema，所以会抛出ValidationException错误。

要通过非主键字段（比如id）查询，有两种常用方案：

1. 使用scan方法全表扫描（仅适合小数据量场景） #

scan会遍历表中所有数据，过滤出符合条件的条目，代码示例：

async function getUserById(id) {
    var service = new AWS.DynamoDB({ region: REGION });
    var dynamoDb = new AWS.DynamoDB.DocumentClient({ service: service });

    var params = { 
        TableName : TABLE,
        FilterExpression: "#id = :idVal",
        ExpressionAttributeNames: { "#id": "id" },
        ExpressionAttributeValues: { ":idVal": id }
    };

    const result = await dynamoDb.scan(params).promise();
    return result.Items[0]; // 假设id是唯一值，取第一个匹配结果
}

⚠️ 注意：全表扫描性能差，数据量大时延迟高、成本高，非必要不使用。

2. 创建全局二级索引（GSI，推荐方案） #

如果需要频繁通过id查询，最优方案是给id字段创建全局二级索引，将id设为GSI的分区键。创建后即可用query方法高效查询：

步骤1：添加全局二级索引 #

在AWS控制台的DynamoDB表管理页面，进入「索引」标签，新增全局二级索引：

• 索引名称：例如id-index
• 分区键：选择id
• 投影属性：选择需要查询返回的字段（或直接选「全部」）

步骤2：修改代码使用GSI查询 #

async function getUserById(id) {
    var service = new AWS.DynamoDB({ region: REGION });
    var dynamoDb = new AWS.DynamoDB.DocumentClient({ service: service });

    var params = { 
        TableName : TABLE,
        IndexName: "id-index", // 填写你创建的GSI名称
        KeyConditionExpression: "#id = :idVal",
        ExpressionAttributeNames: { "#id": "id" },
        ExpressionAttributeValues: { ":idVal": id }
    };

    const result = await dynamoDb.query(params).promise();
    return result.Items[0]; // 假设id唯一
}

这种方式的查询性能和主键查询几乎一致，适合频繁查询非主键字段的场景。

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