Удаление записи

nano SeriesItemOps06.py

from decimal import Decimal
from pprint import pprint
import boto3
from botocore.exceptions import ClientError

def delete_underrated_serie(title, series_id, rating):
    ydb_docapi_client = boto3.resource('dynamodb', endpoint_url = "<Document_API_эндпоинт>")

    table = ydb_docapi_client.Table('Series')

    try:
        response = table.delete_item(
            Key = {
                'series_id': series_id,
                'title': title
            },
            ConditionExpression = "info.rating <= :val",
            ExpressionAttributeValues = {
                ":val": Decimal(rating)
            }
        )
    except ClientError as e:
        if e.response['Error']['Code'] == "ConditionalCheckFailedException":
            print(e.response['Error']['Message'])
        else:
            raise
    else:
        return response

if __name__ == '__main__':
    print("Попытка удаления записи...")
    delete_response = delete_underrated_serie("Supernatural", 3, 5)
    if delete_response:
        print("Данные о сериале удалены:")
        pprint(delete_response, sort_dicts = False)

python SeriesItemOps06.py

Попытка удаления записи...
Condition not satisfied

response = table.delete_item(
    Key = {
        'series_id': series_id,
        'title': title
    }
)

Попытка удаления записи...
Данные о сериале удалены:
{'ResponseMetadata': {'HTTPStatusCode': 200,
                      'HTTPHeaders': {'content-type': 'application/x-amz-json-1.0',
                                      'x-amz-crc32': '2745614147',
                                      'x-request-id': '786fed1d-3c71-4fee-9827-f3f28da0493e',
                                      'date': 'Wed, 13 Jan 2021 11:04:13 GMT',
                                      'content-length': '2'},
                      'RetryAttempts': 0}}

nano SeriesItemOps06.php

<?php

require 'vendor/autoload.php';

date_default_timezone_set('UTC');

use Aws\DynamoDb\Exception\DynamoDbException;
use Aws\DynamoDb\Marshaler;

$sdk = new Aws\Sdk([
    'endpoint' => '<Document_API_эндпоинт>',
    'region'   => 'ru-central1',
    'version'  => 'latest'
]);

$dynamodb = $sdk->createDynamoDb();
$marshaler = new Marshaler();

$tableName = 'Series';

$series_id = 3;
$title = 'Supernatural';

$key = $marshaler->marshalJson('
    {
        "series_id": ' . $series_id . ', 
        "title": "' . $title . '"
    }
');

$eav = $marshaler->marshalJson('
    {
        ":val": 5 
    }
');

$params = [
    'TableName' => $tableName,
    'Key' => $key, 
    'ConditionExpression' => 'info.rating <= :val',
    'ExpressionAttributeValues'=> $eav
];

try {
    $result = $dynamodb->deleteItem($params);
    echo "Запись удалена.\n";

} catch (DynamoDbException $e) {
    echo "Невозможно удалить запись:\n";
    echo $e->getMessage() . "\n";
}

?>

php SeriesItemOps06.php

Невозможно удалить запись:
...
ConditionalCheckFailedException (client): Condition not satisfied
...

$params = [
    'TableName' => $tableName,
    'Key' => $key
]; 

Запись удалена.

nano SeriesItemOps06.js

const AWS = require("@aws-sdk/client-dynamodb");
const { marshall } = require("@aws-sdk/util-dynamodb");

// Credentials should be defined via environment variables AWS_SECRET_ACCESS_KEY and AWS_ACCESS_KEY_ID
const dynamodb = new AWS.DynamoDBClient({
    region: "ru-central1",
    endpoint: "<Document_API_эндпоинт>",
});

const table = "Series";
const series_id = 3;
const title = "Supernatural";

const params = {
    TableName: table,
    Key: marshall({
        "series_id": series_id,
        "title": title
    }),
    ConditionExpression: "info.rating >= :val",
    ExpressionAttributeValues: marshall({
        ":val": 10
    })
};

console.log("Выполнение удаления с условием...");

dynamodb.send(new AWS.DeleteItemCommand(params))
    .then(data => {
        console.log("Удаление выполнено:", JSON.stringify(data, null, 2));
    })
    .catch(err => {
        console.error("Не удалось удалить запись. Ошибка JSON:", JSON.stringify(err, null, 2));
        process.exit(1);
    })

node SeriesItemOps06.js

Выполнение удаления с условием...
Не удалось удалить запись. Ошибка JSON: {
  "message": "Condition not satisfied",
  "code": "ConditionalCheckFailedException",
  "time": "2021-06-14T20:33:29.115Z",
  "statusCode": 400,
  "retryable": false,
  "retryDelay": 20.94065998018778
}

const params = {
    TableName: table,
    Key: marshall({
        "series_id": series_id,
        "title": title
    }),
};

Выполнение удаления с условием...
Удаление выполнено: {}

nano SeriesItemOps06.rb

require 'aws-sdk-dynamodb'

def table_item_deleted?(dynamodb_client, table_item)
  dynamodb_client.delete_item(table_item)
  true
rescue StandardError => e
  puts "Ошибка удаления записи: #{e.message}"
  false
end

def run_me
  region = 'ru-central1'
  table_name = 'Series'
  title = 'Supernatural'
  series_id = 3

  Aws.config.update(
    endpoint: '<Document_API_эндпоинт>',
    region: region
  )

  dynamodb_client = Aws::DynamoDB::Client.new

  table_item = {
    table_name: table_name,
    key: {
      series_id: series_id,
      title: title
    },
    condition_expression: 'info.rating > :val',
      expression_attribute_values: {
        ':val' => 9
      }
  }

  puts "Удаление сериала '#{title} (#{series_id})' из таблицы '#{table_name}', при выполнении заданного условия."

  if table_item_deleted?(dynamodb_client, table_item)
    puts 'Запись удалена.'
  else
    puts 'Не удалось удалить запись.'
  end
end

run_me if $PROGRAM_NAME == __FILE__

ruby SeriesItemOps06.rb

Удаление сериала 'Supernatural (3)' из таблицы 'Series', при выполнении заданного условия.
Ошибка удаления записи: Condition not satisfied
Не удалось удалить запись.

table_item = {
  table_name: table_name,
  key: {
    series_id: series_id,
    title: title
  }
}

Удаление сериала 'Supernatural (3)' из таблицы 'Series', при выполнении заданного условия.
Запись удалена.