amazon-web-services - 使用 UpdateItemEnhancedRequest DynamoDb java sdk2 更新特定属性
问题描述
我们有一个 DynamoDB 表,它有一个属性计数器,它会根据事件由多个 lambda 异步递减。我正在尝试使用 UpdateItemEnhancedRequest 更新计数器(使用 Dynamodb 增强客户端。- JAVA SDK 2)。我能够建立更新计数器的条件,但它会更新整个项目而不仅仅是计数器。有人可以指导如何使用 DynamoDb 增强客户端更新单个属性吗?
代码示例
public void update(String counter, T item) {
AttributeValue value = AttributeValue.builder().n(counter).build();
Map<String, AttributeValue> expressionValues = new HashMap<>();
expressionValues.put(":value", value);
Expression myExpression = Expression.builder()
.expression("nqctr = :value")
.expressionValues(expressionValues)
.build();
UpdateItemEnhancedRequest<T> updateItemEnhancedRequest =
UpdateItemEnhancedRequest.builder(collectionClassName)
.item(item)
.conditionExpression(myExpression)
.build();
getTable().updateItem(updateItemEnhancedRequest);
}
解决方案
更新特定列时,需要指定要更新的列。假设我们有这张表:
现在假设我们要更新存档列。您需要在代码中指定列。这里我们将key对应的item的archive列改为Closed(单列更新)。请注意,我们使用名为updatedValues的HashMap对象指定列名。
// Archives an item based on the key
public String archiveItem(String id){
DynamoDbClient ddb = getClient();
HashMap<String,AttributeValue> itemKey = new HashMap<String,AttributeValue>();
itemKey.put("id", AttributeValue.builder()
.s(id)
.build());
HashMap<String, AttributeValueUpdate> updatedValues =
new HashMap<String,AttributeValueUpdate>();
// Update the column specified by name with updatedVal
updatedValues.put("archive", AttributeValueUpdate.builder()
.value(AttributeValue.builder()
.s("Closed").build())
.action(AttributeAction.PUT)
.build());
UpdateItemRequest request = UpdateItemRequest.builder()
.tableName("Work")
.key(itemKey)
.attributeUpdates(updatedValues)
.build();
try {
ddb.updateItem(request);
return"The item was successfully archived";
注意:这不是增强型客户端。
此代码来自 AWS 教程,该教程展示了如何使用 Spring Boot 构建 Java Web 应用程序。完整教程在这里:
要使用增强型客户端更新单个列,请调用Table 方法。这将返回一个DynamoDbTable 实例。现在您可以调用updateItem方法。
这是使用增强型客户端更新存档列的逻辑。注意你得到一个Work对象,调用它的setArchive然后传递Work对象。workTable.updateItem(r->r.item(work));
Java代码:
// Update the archive column by using the Enhanced Client.
public String archiveItemEC(String id) {
DynamoDbClient ddb = getClient();
try {
DynamoDbEnhancedClient enhancedClient = DynamoDbEnhancedClient.builder()
.dynamoDbClient(getClient())
.build();
DynamoDbTable<Work> workTable = enhancedClient.table("Work", TableSchema.fromBean(Work.class));
//Get the Key object.
Key key = Key.builder()
.partitionValue(id)
.build();
// Get the item by using the key.
Work work = workTable.getItem(r->r.key(key));
work.setArchive("Closed");
workTable.updateItem(r->r.item(work));
return"The item was successfully archived";
} catch (DynamoDbException e) {
System.err.println(e.getMessage());
System.exit(1);
}
return "";
}
此答案显示了更新 DynamoDB 表中单个列的两种方法。上面的教程现在展示了这种方式。
推荐阅读
- laravel - Laravel Sail 工作迁移或与数据库联系
- python - 如何使用 pynput 和 pyautogui 停止无限循环?
- azure - 使用 Azure 数据工厂将数据从 Azure Data Lake 复制到 SnowFlake,无需阶段
- docker - 如何在不更改映像文件的情况下使用 yaml 文件中的 kubernetes 创建它时将 script.sh 文件传递给容器?
- scala - 使用 Scala 3 宏覆盖方法
- debugging - 调试小型转储期间找不到源页面
- r - 将数据从文本文件导入 R
- python - 使用 Sphinx 在函数中修改文档对象
- html - 列中的其他 div 如何占用最宽 div 的宽度?
- c++ - 使用 SDL_Rect 指针变量时引发的异常