不使用分区键查询DynamoDB表的全局二级索引

Question

我有一个DynamoDB表，分区键为userID，没有排序键。该表在每个项目中还具有时间戳属性。我想检索在指定范围内具有时间戳的所有项目（无论用户ID如何，即跨所有分区）。在阅读文档并搜索堆栈溢出（此处）后，我发现需要为我的表创建一个GSI。因此，我使用以下键创建了一个GSI：

• 分区键：userID
• 排序键：时间戳

我正在使用Java SDK使用以下代码查询索引：

String lastWeekDateString = getLastWeekDateString();
AmazonDynamoDB client = AmazonDynamoDBClientBuilder.standard().build();
DynamoDB dynamoDB = new DynamoDB(client);

Table table = dynamoDB.getTable("user table");
Index index = table.getIndex("userID-timestamp-index");

QuerySpec querySpec = new QuerySpec()
    .withKeyConditionExpression("timestamp > :v_timestampLowerBound")
    .withValueMap(new ValueMap()
            .withString(":v_timestampLowerBound", lastWeekDateString));

    ItemCollection<QueryOutcome> items = index.query(querySpec);
    Iterator<Item> iter = items.iterator();

while (iter.hasNext()) {
    Item item = iter.next();
    // extract item attributes here
}

执行此代码时出现以下错误：

Query condition missed key schema element: userID

据我所知，我应该能够仅使用排序键查询GSI，而不会在分区键上给出任何条件。请帮助我了解我的实现出了什么问题。谢谢。

编辑：在阅读了这里的线程之后，我们发现我们无法查询排序键上只有一个范围的GSI。那么，通过对属性进行范围查询来查询整个表的替代方法（如果有的话）是什么呢？我在该线程中发现的一个建议是使用year作为分区键。如果所需范围跨越多年，则需要进行多次查询。此外，这并没有将数据均匀地分布在所有分区上，因为只有与当前年份对应的分区将用于一整年的插入。请提出任何替代方案。

Answer 1

对于DDB的任何定制查询需求，最好的解决方案是为GSI设计正确的主键方案。在设计DDB的主键时，主要原则是哈希键应设计用于对整个项目进行分区，排序键应设计用于对分区内的项目进行排序。

话虽如此，我建议您使用时间戳的年份作为哈希键，使用月份日期作为排序键。在这种情况下，最多只需进行2次查询。你是对的，你应该尽量避免过滤或扫描。

例如，您可以这样进行查询，如果开始日期的年份和结束日期的年份相同，您只需要一个查询：

.withKeyConditionExpression("#year = :year and #month-date > :start-month-date and #month-date < :end-month-date")

除此之外：

.withKeyConditionExpression("#year = :start-year and #month-date > :start-month-date")

和

.withKeyConditionExpression("#year = :end-year and #month-date < :end-month-date")

最后，您应该联合来自两个查询的结果集。这最多只消耗2个读取容量单位。

为了更好地比较排序键，您可能需要使用UNIX时间戳。

谢啦

Answer 2

使用dynamodb查询操作时，必须至少指定分区键。这就是为什么会出现需要用户ID的错误。（在AWS查询文档中）

条件必须对单个分区键值执行相等性测试。

获取没有分区键的项目的唯一方法是执行扫描操作（但这不会按排序键排序！）

如果您想对所有项目进行排序，您必须创建一个分区键的GSI，该分区键对您需要的所有项目都是相同的（例如，在所有项目上创建一个新属性，例如“type”：“Item”）。然后您可以查询GSI并指定#type=： Item

QuerySpec querySpec = new QuerySpec()
    .withKeyConditionExpression(":type = #item AND timestamp > :v_timestampLowerBound")
    .withKeyMap(new KeyMap()
            .withString("#type", "type"))
    .withValueMap(new ValueMap()
            .withString(":v_timestampLowerBound", lastWeekDateString)
            .withString(":item", "item"));