본 글은, AWS Blog 을 보고 작성되었습니다.

DynamoDB

DynamoDB에서 중복을 허용하지 않고 유일함을 보장하는 것은 오직 Primary Key (PK)뿐입니다.

RDBMS처럼 일반 컬럼에 UNIQUE 인덱스를 딸깍하고 걸 수 있는 방법은 존재하지 않습니다.

그렇다면 어떤식으로 처리해야 할까요?

해결 아이디어 : PK 의 유니크 성징과 트랜잭션의 조합

이미 우리는 PK 는 유니크 하다라는걸 알 수 있습니다.

즉, 유니크해야하는 값 자체를 PK로 가지는 가짜 데이터를 만들어서 함께 저장하는 방식을 채택하는 것 입니다.

만약 1개의 회원에 {uuid(PK), name, phone-number} 가 있고, name 속성을 유니크로 가져가야 한다면, name을 PK 로 삼는 데이터를 하나 더 생성해서 저장하는 방식입니다.

즉, 한 회원을 저장하기 위해 2개 이상의 데이터를 삽입하는 것 입니다.

마커 아이템 설계 패턴

위와 동일하게, 닉네임 필드에 중복 가입을 막고 싶다라고 가정합니다.

이 때, 백과라는닉네임으로 가입을 시도할 때, DB 에는 두가지 아이템을 동시에 저장합니다.

UUID(pk)	name	number
sdlkfjsdlkf-012390d102-cvd	백과	010-1234-1234
name#백과

추후 만약 회원가입을 시도할 때, 이미 백과라는 닉네임으로 누군가가 사용 중 이라면, 이미 존재하므로 (PK 의 Unqiue), 조건에 위배되어 트랜잭션 전체가 롤백되고 본체 데이터도 저장되지 않습니다.

이를 위해서, TransactWriteItem 을 사용하여, 하나의 트랜잭션으로 묶어서 사용하면 됩니다.

SAM CLI 구현 코드

public class CreateUserHandler implements RequestHandler<APIGatewayProxyRequestEvent, APIGatewayProxyResponseEvent> {

	private static final ObjectMapper objectMapper = new ObjectMapper();

	private static final DynamoDbClient client = createClient();

	// DynamoDbClient 생성 함수.
	// 프로파일에 따라 연결 대상이 달라짐
	private static  DynamoDbClient createClient() {
		String profile = System.getenv("PROFILE");

		if ("dev".equals(profile)) {
			return DynamoDbClient.builder()
				.endpointOverride(URI.create("http://host.docker.internal:8000"))
				.region(Region.AP_NORTHEAST_2)
				.credentialsProvider(StaticCredentialsProvider.create(
					AwsBasicCredentials.create("local", "local")))
				.build();
		}

		return DynamoDbClient.builder()
			.httpClient(UrlConnectionHttpClient.builder().build())
			.credentialsProvider(EnvironmentVariableCredentialsProvider.create())
			.region(Region.AP_NORTHEAST_2)
			.build();
	}

	private static final String TABLE_NAME = System.getenv("TABLE_NAME");

	@Override
	public APIGatewayProxyResponseEvent handleRequest(APIGatewayProxyRequestEvent input, Context context) {
		context.getLogger().log("Handler started. Input Body: " + input.getBody());

		try {
			UserRequestDto userRequest = objectMapper.readValue(input.getBody(), UserRequestDto.class);

			String generatedUserId = UUID.randomUUID().toString();
			String generatedDate = LocalDateTime.now().toString();

			Map<String, AttributeValue> mainItem = new HashMap<>();
			mainItem.put("userId", AttributeValue.builder().s(generatedUserId).build());
			mainItem.put("name", AttributeValue.builder().s(userRequest.getName()).build());
			mainItem.put("date", AttributeValue.builder().s(generatedDate).build());

			Map<String, AttributeValue> markerItem = new HashMap<>();
			markerItem.put("userId", AttributeValue.builder().s("NAME#" + userRequest.getName()).build());

			TransactWriteItem putMain = TransactWriteItem.builder()
				.put(Put.builder()
					.tableName(TABLE_NAME)
					.item(mainItem)
					.build())
				.build();

			TransactWriteItem putMarker = TransactWriteItem.builder()
				.put(Put.builder()
					.tableName(TABLE_NAME)
					.item(markerItem)
					.conditionExpression("attribute_not_exists(userId)")
					.build())
				.build();

			TransactWriteItemsRequest transactRequest = TransactWriteItemsRequest.builder()
				.transactItems(putMain, putMarker)
				.build();

			client.transactWriteItems(transactRequest);

			Map<String, String> responseBody = new HashMap<>();
			responseBody.put("message", "User saved successfully!");
			responseBody.put("userId", generatedUserId);
			responseBody.put("savedName", userRequest.getName());
			responseBody.put("createDate", generatedDate);

			return new APIGatewayProxyResponseEvent()
				.withStatusCode(200)
				.withBody(objectMapper.writeValueAsString(responseBody));

		} catch (TransactionCanceledException e) {
			context.getLogger().log("Transaction canceled (Duplicated Name): " + e.getMessage());
			return new APIGatewayProxyResponseEvent()
				.withStatusCode(409)
				.withBody("{ \"error\": \"Name already exists. Please choose another name.\" }");

		} catch (Exception e) {
			context.getLogger().log("Error: " + e.getMessage());
			return new APIGatewayProxyResponseEvent()
				.withStatusCode(500)
				.withBody("{ \"error\": \"Failed to create user: " + e.getMessage() + "\" }");
		}
	}

	public static class UserRequestDto {
		private String name;
		private String date;

		public UserRequestDto() {
		}

		public String getName() {
			return name;
		}

		public String getDate() {
			return date;
		}
	}
}

결과

신규 저장

동일한 name 으로 가입 시도

{"timestamp":"2026-02-11T02:35:58.274Z","message":"Transaction canceled (Duplicated Name): Transaction cancelled, please refer cancellation reasons for specific reasons [None, ConditionalCheckFailed] (Service: DynamoDb, Status Code: 400, Request ID: 67df89f9-381d-404b-85bd-8002de75b6a1) (SDK Attempt Count: 1)","level":"UNDEFINED","AWSRequestId":"d3612956-86f2-44a2-a8b9-592e7b3c7a51"}
END RequestId: d3612956-86f2-44a2-a8b9-592e7b3c7a51
REPORT RequestId: d3612956-86f2-44a2-a8b9-592e7b3c7a51  Duration: 90.64 ms      Billed Duration: 91 ms  Memory Size: 512 MB     Max Memory Used: 512 MB

트랜잭션 확보 및 중복 검증 완료

후기

전통적인 RDBMS 보다 확실히 간편하고 성능또한 보장되는 db 이지만, 다양한 패턴을 학습해야 할 것 같습니다.

특히, 복잡한 서비스 로직들을 2차 3차로 db 제약 조건을 통해 막는 안전 추구자 스타일이라면 이러한 문제에 있어서 조금 비관적인 시선으로 바라볼 수 있을 듯 합니다.

~~정확한건 더 써보고, 실제 서비스를 운영해봐야 알 것 같습니다.~~

트랜잭션을 사용하여 AWS DynamoDB 에서 고유 제약 조건을 거는 방법