Transaction error handling in DynamoDB - Mini Project: Build & Apply

Transaction Error Handling in DynamoDB

📖 Scenario: You are managing a simple inventory system where you need to update stock quantities for products. Sometimes, multiple updates happen at once, and you want to make sure either all updates succeed or none do, to keep data consistent.

🎯 Goal: Build a DynamoDB transaction that updates stock quantities for two products. Add error handling to catch transaction failures and handle them gracefully.

📋 What You'll Learn

Create a transaction with two update operations on the Products table

Use a condition expression to ensure stock quantity does not go below zero

Add error handling to catch TransactionCanceledException

Log or handle the error when the transaction fails

💡 Why This Matters

🌍 Real World

In real inventory systems, transactions ensure that stock updates happen safely without partial changes that could cause errors or inconsistencies.

💼 Career

Understanding transaction error handling in DynamoDB is important for backend developers and database administrators to maintain data integrity and build reliable applications.

1

Setup DynamoDB client and transaction parameters

Create a DynamoDB client called dynamodb using boto3.client('dynamodb'). Then create a variable called transaction_items that is a list containing two update operations. Each update should target the Products table and update the Stock attribute for products with ProductId 'A123' and 'B456' respectively. Use Update action with Key, UpdateExpression, and ExpressionAttributeValues to subtract 1 from Stock.

DynamoDB

import boto3

dynamodb = boto3.client('dynamodb')

# Create transaction_items list with two update operations
# Your code here

Need a hint?

Use boto3.client('dynamodb') to create the client. For each update, specify the table name, key with product ID, update expression to subtract 1 from stock, and a condition expression to prevent stock from going below zero.

2

Add transaction configuration

Create a variable called transaction_params that is a dictionary with a key TransactItems set to the transaction_items list.

DynamoDB

import boto3

dynamodb = boto3.client('dynamodb')

transaction_items = [
    # existing update operations
]

# Create transaction_params dictionary with TransactItems key
# Your code here

Need a hint?

Wrap the transaction_items list inside a dictionary with the key TransactItems.

3

Execute the transaction with error handling

Use a try block to call dynamodb.transact_write_items(**transaction_params). Add an except block to catch dynamodb.exceptions.TransactionCanceledException and assign the exception to a variable called e.

DynamoDB

import boto3

dynamodb = boto3.client('dynamodb')

transaction_items = [
    # existing update operations
]

transaction_params = {'TransactItems': transaction_items}

# Add try-except block to execute transaction and catch TransactionCanceledException
# Your code here

Need a hint?

Use a try block to run the transaction. Catch TransactionCanceledException with except dynamodb.exceptions.TransactionCanceledException as e:.

4

Handle the transaction error

Inside the except block, add a line to assign the string 'Transaction failed' to a variable called error_message. This simulates handling the error.

DynamoDB

import boto3

dynamodb = boto3.client('dynamodb')

transaction_items = [
    # existing update operations
]

transaction_params = {'TransactItems': transaction_items}

try:
    dynamodb.transact_write_items(**transaction_params)
except dynamodb.exceptions.TransactionCanceledException as e:
    # Assign 'Transaction failed' to error_message variable
    # Your code here

Need a hint?

Inside the except block, assign the string 'Transaction failed' to a variable named error_message.