DynamoDB 트랜잭션을 사용한 비관적 잠금

DynamoDB 트랜잭션은 그룹화된 작업에 대한 양자택일 접근 방식을 제공합니다. TransactWriteItems를 사용하면 DynamoDB가 트랜잭션의 모든 항목을 모니터링합니다. 트랜잭션 중에 다른 작업에 의해 항목이 수정되면 전체 트랜잭션이 취소되고 DynamoDB가 TransactionCanceledException을 반환합니다. 이 동작은 충돌하는 동시 수정이 사후에 감지되지 않기 때문에 비관적 동시성 제어의 한 형태를 제공합니다.

잠금에 트랜잭션을 사용해야 하는 경우

트랜잭션은 다음과 같은 경우에 적합합니다.

일반적인 예로는 계정 간 자금 이체, 인벤토리 및 주문 테이블을 모두 업데이트하는 주문, 게임 내 플레이어 간 항목 교환 등이 있습니다.

단점

구현

다음 예제에서는 TransactWriteItems를 사용하여 두 항목 간에 인벤토리를 원자적으로 전송합니다. 다른 프로세스가 트랜잭션 중에 두 항목을 수정하면 전체 작업이 롤백됩니다.

import boto3

client = boto3.client('dynamodb')

def transfer_inventory(source_id, target_id, quantity):
    try:
        client.transact_write_items(
            TransactItems=[
                {
                    'Update': {
                        'TableName': 'Inventory',
                        'Key': {'ItemID': {'S': source_id}},
                        'UpdateExpression': 'SET QuantityLeft = QuantityLeft - :qty',
                        'ConditionExpression': 'QuantityLeft >= :qty',
                        'ExpressionAttributeValues': {
                            ':qty': {'N': str(quantity)}
                        }
                    }
                },
                {
                    'Update': {
                        'TableName': 'Inventory',
                        'Key': {'ItemID': {'S': target_id}},
                        'UpdateExpression': 'SET QuantityLeft = QuantityLeft + :qty',
                        'ExpressionAttributeValues': {
                            ':qty': {'N': str(quantity)}
                        }
                    }
                }
            ]
        )
        return True
    except client.exceptions.TransactionCanceledException as e:
        print(f"Transaction canceled: {e}")
        return False

이 예제에서 조건 표현식은 인벤토리가 충분한지 확인하지만 버전 속성은 필요하지 않습니다. DynamoDB는 준비 단계와 커밋 단계 사이의 다른 작업에 의해 트랜잭션의 항목이 수정된 경우 트랜잭션을 자동으로 취소합니다. 이는 비관적 동시성 제어를 제공합니다. 트랜잭션 자체가 충돌하는 동시 수정을 방지합니다.

자세한 내용은 DynamoDB Transactions를 사용하여 복잡한 워크플로 관리 섹션을 참조하세요.