动态数据库查询可获取超过 100 万的数据 - Java 中的示例

Question

我正在尝试运行一个查询并获取所有项目。似乎没有检索到所有项目，我需要使用start键再次运行查询。

从文件中

对于Query或Scan操作，如果操作没有返回表中所有匹配的项目，DynamoDB可能会返回LastEvalatedKey值。要获取匹配项的完整计数，请从上一个请求中获取LastEvalatedKey值，并在下一个请求中将其用作ExunisiveStartKey值。重复此操作，直到DynamoDB不再返回LastEvalatedKey值。

能否给出一个代码示例，如何包装这段代码，用lastEvaluatedKey再次运行查询？

        QuerySpec spec = new QuerySpec()
    .withKeyConditionExpression("userName = :userName and #a between :startRange and :endRange")
    .withValueMap(valueMap)
    .withScanIndexForward(false)
    .withNameMap(nameMap);
        
    ItemCollection<QueryOutcome> items = table.query(spec);

    Iterator<Item> iterator = items.iterator();
    while (iterator.hasNext()) { ....

Answer 1

看起来您使用的是DynamoDB文档API，而不是低级API。当您使用文档API进行查询时，所有低级别的考虑事项(如分页)都会考虑到，但是您可以选择与这些低级别的方面进行交互。

根据您提供的代码片段，当您到达每个页面的末尾时，文档API库将负责加载其他页面，因此您不需要做任何额外的工作，您的代码应该可以工作！这是使用文档API的真正好处，因为它为常见用例处理了大量冗余的锅炉板代码。