Блог

Я пытаюсь написать лямбда-функцию для добавления новых данных в таблицу DynamoDB. Из чтения документов на:

http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/DynamoDB/DocumentClient.html#put-property Метод PUT: «Создает новый элемент или заменяет старый элемент новым элементом, делегируя его AWS.DynamoDB.PutItem() .»

Помимо выполнения проверки объекта перед «вводом», существует ли параметр или флаг для сбоя, если объект существует при попытке ввода?

Я вижу в

 params -> Expected -> Exists (Bool)
 

но не вижу никакой документации о том, что это делает.

Какая архитектура была бы наилучшей (или быстрой) для предотвращения перезаписи элемента?

 Query the table first and if no item exists then add the item
 

или

 Attempt to insert the item and on failure because of duplicate entry report this back? (Is there a way to prevent item overwrite?)
 

ConditionExpression Может использоваться для проверки того, существуют ли значения ключевого атрибута в таблице, и выполнения операции PUT только в том случае, если значения ключа отсутствуют в таблице.

При первом запуске приведенного ниже кода операция put должна быть успешной. При втором запуске операция put должна завершиться ошибкой с исключением «Ошибка условного запроса«.

В моей таблице movies есть ключи разделения и сортировки. Итак, я использовал оба атрибута в условном выражении.

Пример кода с условным помещением:-

     var table = "Movies";
    
    var year = 1502;
    var title = "The Big New Movie";
    
    var params = {
        TableName:table,
        Item:{
            "yearkey": year,
            "title": title,
            "info":{
                "plot": "Nothing happens at all.",
                "rating": 0
            }
        },
        ConditionExpression: "yearkey <> :yearKeyVal AND #title <>  :title",
        ExpressionAttributeNames: { 
            "#title" : "title" 
         },
        ExpressionAttributeValues: {
            ":yearKeyVal" : year,
            ":title": {"S": title}
        }
    };
    
    console.log("Adding a new item...");
    docClient.put(params, function(err, data) {
        if (err) {
            console.error("Unable to add item. Error JSON:", JSON.stringify(err, null, 2));
        } else {        
            console.log("Added item:", JSON.stringify(data, null, 2));
        }
    });
 

Исключение при выполнении операции put во второй раз:-

 Unable to add item. Error JSON: {
  "message": "The conditional request failed",
  "code": "ConditionalCheckFailedException",
  "time": "2017-10-02T18:26:26.093Z",
  "requestId": "7ae3b0c4-3872-478d-908c-94bc9492a43a",
  "statusCode": 400,
  "retryable": false,
  "retryDelay": 0
}
 

Я вижу, что этот вопрос относится к языку JavaScript, в любом случае я напишу также для Java (возможно, это будет кому-то полезно):

 DynamoDBSaveExpression saveExpression = new DynamoDBSaveExpression();
Map<String, ExpectedAttributeValue> expectedAttributes =
        ImmutableMapParameter.<String, ExpectedAttributeValue>builder()
                .put("hashKeyAttrName", new ExpectedAttributeValue(false))
                .put("rangeKeyAttrName", new ExpectedAttributeValue(false))
                .build();
saveExpression.setExpected(expectedAttributes);
saveExpression.setConditionalOperator(ConditionalOperator.AND);

try {
    dynamoDBMapper.save(item, saveExpression);
} catch (ConditionalCheckFailedException e) {
    e.printStackTrace();
}
 

ConditionalCheckFailedException будет выдан в случае, если мы попытаемся сохранить элемент с уже существующей парой HashKey и rangeKey в DynamoDB.

В дополнение к правильному ответу на notionquest рекомендуемый способ выражения условия, которое приводит putItem к сбою, если элемент уже существует, — это утверждение, что ключ раздела отсутствует ни в одном потенциально существующем элементе:

 "ConditionExpression": "attribute_not_exists(pk)",
 

Это гласит: «если этот элемент уже существует до putItem , убедитесь, что у него еще нет ключа раздела» ( pk являющегося ключом раздела в этом примере). Поскольку невозможно, чтобы элемент существовал без ключа раздела, это фактически означает «убедитесь, что этот элемент еще не существует».

Смотрите также блок «Примечание» в начале этой страницы: https://awscli.amazonaws.com/v2/documentation/api/latest/reference/dynamodb/put-item.html

Здесь приведен пример, используемый для гарантии уникальности неключевых столбцов:

https://aws.amazon.com/blogs/database/simulating-amazon-dynamodb-unique-constraints-using-transactions/

Как и дополнение к решению @Svend полный пример Java (для AWS SDK v2, dynamodb-enchanced)

 public <T> void insert(DynamoDbClient client, String tableName, T object, Class<T> clazz) {

  DynamoDbEnhancedClient enhancedClient = DynamoDbEnhancedClient.builder().dynamoDbClient(client).build();

  DynamoDbTable<T> table = enhancedClient.table(tableName, TableSchema.fromBean(clazz));

  table.putItem(PutItemEnhancedRequest.builder(clazz)
      .item(object)
      .conditionExpression(Expression.builder()
          .expression("attribute_not_exists(primaryKey)")
          .build())
      .build());
}
 

где

• primaryKey
  • имя столбца, для которого проверяется уникальность
• software.amazon.awssdk.services.dynamodb.model.ConditionalCheckFailedException
  • исключение, вызванное дублированием put