gpt4 book ai didi

java - 使用低级 java API 查询 dynamoDB 的本地二级索引

转载 作者:太空宇宙 更新时间:2023-11-04 13:15:39 25 4
gpt4 key购买 nike

我正在尝试使用哈希键查询本地二级索引。

我的表:Table1用户名(hash_key)、Id(range_key)、时间戳......

我的本​​地二级索引(因为我想查询所有用户名并按时间排序)我的LSI:Table1_TimestampLSI用户名(hash_key),时间戳(range_key)

例如用户1 | 123 | 123 2015年12月12日用户1 | 456 | 456 11/01/2015用户2 | 789 | 789 12/01/2015

注意:我不能只将时间戳作为表本身的范围键,因为(用户名+时间戳)不是唯一的。所以我必须创建一个 ID 字段以确保唯一性。

因为我想要异步客户端,所以我使用低级 API(模型而不是文档)java API。

查询索引的函数

HashMap<String, Condition> queryFilter = new HashMap<String, Condition>();
Condition condition = new Condition()
.withComparisonOperator(ComparisonOperator.EQ.toString())
.withAttributeValueList(new AttributeValue().withS(username));
queryFilter.put("Username", condition);

QueryRequest queryRequest = new QueryRequest(tableName + "_TimestampLSI").withQueryFilter(queryFilter);

queryRequest.setScanIndexForward(false);

Future<QueryResult> fQueryResult = dynamoDB.queryAsync(queryRequest,
new AsyncHandler<QueryRequest,QueryResult>() {
public void onSuccess(QueryRequest request, QueryResult result) {
System.out.println("Table: " + result);
}

public void onError(Exception exception) {
System.out.println("Error describing table: " + exception.getMessage());
// Callers can also test if exception is an instance of
// AmazonServiceException or AmazonClientException and cast
// it to get additional information
}
});

System.out.println("Result: " + fQueryResult);

我收到以下错误描述表时出错:必须在请求中指定 KeyConditions 或 KeyConditionExpression 参数。 (服务:AmazonDynamoDBv2;状态代码:400;错误代码:ValidationException;

我错过了什么吗?我认为我应该能够仅根据哈希值查询索引。

最佳答案

您误解了本地指数。

一个Query总是采用哈希键。因此,您的 QueryRequest 应该有一个 setHashKeyValue 设置。

您不能对查询进行交叉散列,不能使用散列+范围主键,也不能使用 LSI。您可以使用 GSI 来做到这一点,但我不确定这对您有何帮助。

目前尚不清楚您到底想要实现什么目标。如果您想要所有用户名,那么您需要 Scan而不是查询 - 因为您希望所有哈希键都存在。

关于java - 使用低级 java API 查询 dynamoDB 的本地二级索引,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/33557290/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com