使用 Java SDK 2 查询超过 100 个与分区键匹配的 DynamoDB 项目？

如何解决使用 Java SDK 2 查询超过 100 个与分区键匹配的 DynamoDB 项目？

如何使用 aws java sdk 2 查询 dynamodb 表中与特定分区键匹配的 100 多个项目？

如果需要使用匹配哈希键 exceeds 100 then the batchGetItemPaginator method 的行数。此方法接受需要 BatchGetItemRequest 的 KeysAndAttributes。

当我只用一个散列键而不是一个排序键构造一个 KeysAndAttributes 时，我得到以下异常

DynamoDbException: 提供的关键元素与架构不匹配

但是，如果我在 KeysAndAttributes 中提供排序键，那么 batchGetItemPaginator 方法就可以正常工作。

那么如何使用仅一个主键（没有排序键）来构造 BatchGetItemRequest ？

注意：我的问题不是 this question 的重复。如果行数超过 100，则另一个问题不涉及所需的分页。

预先感谢您的考虑和回复。

解决方法

主键>>分区+HashKey

GetItem 用于通过主键获取一项。

BatchGetItem 用于使用多个主键从多个表中获取多个项目。所以，我们需要传递 Partition & HashKey 的列表

我们永远不能使用部分键（即只有分区键）执行 getItem 或 batchGetItem。

要仅通过分区键获取项目，我们必须使用 query api，它最多返回 1 MB 的数据。要获取具有特定分区键的所有记录，我们可以通过使用 excludeStartKey 多次调用查询 api 进行分页

.exclusiveStartKey(exclusiveStartKey) 帮助我们在特定记录之后开始。

.limit(10) 通常设置为一个合理的数字，总大小不超过 1 MB。如果没有任何项目不是问题，我们可以排除这一点。

response.lastEvaluatedKey() 从响应中捕获此信息以用于下一个查询。

public static Map<String,AttributeValue> queryTable(DynamoDbClient ddb,String tableName,String partitionKeyName,String partitionKeyVal,Map<String,AttributeValue> exclusiveStartKey) {

    Map<String,AttributeValue> lastEvaluatedKey = null;

    HashMap<String,AttributeValue> attrValues = new HashMap<String,AttributeValue>();
    attrValues.put(":" + partitionKeyName,AttributeValue.builder().s(partitionKeyVal).build());
    QueryRequest queryReq = QueryRequest.builder().tableName(tableName).exclusiveStartKey(exclusiveStartKey)
            .keyConditionExpression(partitionKeyName + " = :" + partitionKeyName)
            .expressionAttributeValues(attrValues).limit(10).build();

    try {
        QueryResponse response = ddb.query(queryReq);
        lastEvaluatedKey = response.lastEvaluatedKey();
    } catch (DynamoDbException e) {
        System.err.println(e.getMessage());
        System.exit(1);
    }
    return lastEvaluatedKey;
}

表 test 上的示例测试，以 pk 作为值 1 的分区键

public static void main(String[] args) {

    Region region = Region.US_EAST_1;
    DynamoDbClient ddb = DynamoDbClient.builder().region(region).build();

    Map<String,AttributeValue> lastEvaluatedKey = null;
    // Loop until we don't get lastEvaluatedKey 
    do {
        System.out.println("---------DynamoDb Query with Exclusive Start Key------------" + lastEvaluatedKey);
        lastEvaluatedKey = queryTable(ddb,"test","pk","1",lastEvaluatedKey);
    } while (lastEvaluatedKey != null && !lastEvaluatedKey.isEmpty());

    ddb.close();
}