如何用DynamoDB Query实现HashKey与GSI的OR条件查询？

完全可行，利用现有表结构的主表HashKey和GSI，你可以通过两次独立Query请求获取目标数据，彻底避免全表扫描，具体实现思路如下：

核心逻辑 #

你的表结构已经满足高效查询的条件：

• 主表以IP为HashKey，能直接Query出该IP对应的所有条目
• GSI emailIndex以email为HashKey，能直接Query出该email对应的所有条目

只需要分别发起这两个Query，再合并结果并去重即可（避免同时匹配IP和email的条目被重复返回）。

Java代码实现 #

// 1. Query主表，获取匹配IP的所有条目
QueryRequest ipQuery = new QueryRequest()
        .withTableName(tableName)
        .withKeyConditionExpression("IP = :ip")
        .withExpressionAttributeValues(Map.of(":ip", new AttributeValue(ipAddress)));
QueryResult ipResult = dynamoDB.query(ipQuery);
List<Map<String, AttributeValue>> ipItems = ipResult.getItems();

// 2. Query GSI emailIndex，获取匹配email的所有条目
QueryRequest emailQuery = new QueryRequest()
        .withTableName(tableName)
        .withIndexName("emailIndex")
        .withKeyConditionExpression("email = :email")
        .withExpressionAttributeValues(Map.of(":email", new AttributeValue(email)));
QueryResult emailResult = dynamoDB.query(emailQuery);
List<Map<String, AttributeValue>> emailItems = emailResult.getItems();

// 3. 合并结果并去重（以IP+createdAt作为唯一标识）
Set<String> uniqueKeys = new HashSet<>();
List<Map<String, AttributeValue>> finalResult = new ArrayList<>();

// 处理IP查询结果
for (Map<String, AttributeValue> item : ipItems) {
    String key = item.get("IP").getS() + "_" + item.get("createdAt").getS();
    if (uniqueKeys.add(key)) {
        finalResult.add(item);
    }
}

// 处理email查询结果
for (Map<String, AttributeValue> item : emailItems) {
    String key = item.get("IP").getS() + "_" + item.get("createdAt").getS();
    if (uniqueKeys.add(key)) {
        finalResult.add(item);
    }
}

关键说明 #

• 两次Query都是指向特定HashKey的精准查询，只会读取匹配的分区数据，性能远优于全表Scan，且能有效控制读容量消耗
• 去重逻辑依赖你定义的唯一约束（IP+createdAt组合唯一），用这个组合作为去重的key即可确保结果无重复
• 如果需要分页处理大量数据，可以给两个Query请求加上withLimit和withExclusiveStartKey实现分页查询，再逐步合并结果

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