使用NodeJS从DynamoDB二级索引按排序键前缀查询数据

核心问题 #

你当前的代码无法实现需求的原因是：DynamoDB的Query操作要求分区键必须精确匹配，而你在GSI的分区键（对应原表的SK）上使用了BEGINS_WITH条件，这不符合Query的规则——BEGINS_WITH仅能用于排序键的条件过滤。

你的ReversedRGIndex将原表的SK作为GSI的分区键，原表的PK作为GSI的排序键。要查询所有原SK以PR#开头的项，可根据业务场景选择以下两种方案：

方案一：基于现有GSI使用Scan（快速实现，适合数据量小的场景） #

利用Scan操作遍历ReversedRGIndex，再通过过滤条件筛选出SK（GSI的PK）以PR#开头的项。

代码实现 #

const { DynamoDBClient, ScanCommand } = require("@aws-sdk/client-dynamodb");
const client = new DynamoDBClient({});

exports.GetAllRules = async () => {
    let allItems = [];
    let params = {
        TableName: "RequestGroup",
        IndexName: 'ReversedRGIndex',
        FilterExpression: "BEGINS_WITH(PK, :pr_prefix)",
        ExpressionAttributeValues: {
            ":pr_prefix": {"S": "PR#"}
        }
    };

    do {
        const command = new ScanCommand(params);
        const result = await client.send(command);
        allItems = allItems.concat(result.Items);
        params.ExclusiveStartKey = result.LastEvaluatedKey;
    } while (params.ExclusiveStartKey);

    return allItems;
};

注意事项 #

• Scan会遍历GSI中的所有数据后再过滤，数据量大时性能较差，且存在单次返回数据量限制，需要通过LastEvaluatedKey处理分页。

方案二：调整GSI设计（高效查询，适合数据量大的场景） #

如果允许修改索引结构，建议创建一个新的GSI，将固定字符串作为分区键，原表的SK作为排序键，这样就能用Query高效查询前缀匹配的项。

新GSI结构 #

• 索引名：PRPrefixIndex
• 分区键（PK）：固定字符串（例如REQUEST_GROUP_PR，所有SK以PR#开头的项都使用这个值作为GSI的分区键）
• 排序键（SK）：原表的SK属性

代码实现 #

const { DynamoDBClient, QueryCommand } = require("@aws-sdk/client-dynamodb");
const client = new DynamoDBClient({});

exports.GetAllRules = async () => {
    let allItems = [];
    let params = {
        TableName: "RequestGroup",
        IndexName: 'PRPrefixIndex',
        KeyConditionExpression: "PK = :fixed_pk AND BEGINS_WITH(SK, :pr_prefix)",
        ExpressionAttributeValues: {
            ":fixed_pk": {"S": "REQUEST_GROUP_PR"},
            ":pr_prefix": {"S": "PR#"}
        }
    };

    do {
        const command = new QueryCommand(params);
        const result = await client.send(command);
        allItems = allItems.concat(result.Items);
        params.ExclusiveStartKey = result.LastEvaluatedKey;
    } while (params.ExclusiveStartKey);

    return allItems;
};

优势 #

• Query仅扫描匹配分区键且排序键符合前缀的项，性能远优于Scan，是DynamoDB推荐的高效查询方式。

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