DynamoDB

• 태생적으로 분산 처리를 고려하여 만든 Database

• 데이터의 규모와 관계없이 일관되게, 수 밀리초 미만의 응답시간, 사실상 무제한의 처리량

• 관계형 데이터베이스의 장점인 보조인덱스와 트랜젝션 제공함

• 백업 복원도 쉬움

SDK

• AWS SDK for Java 2.x (High level api) : DynamoDBEnhancedClient API, Use advanced mapping features

• DynamoDbBean 어노테이션 사용하기
• [Blog ] Using Dynamodb with Kotlin + Spring Boot
• [ Git issue ] DynamoDB Enhanced Client support for Immutable objects
• [ AWS Docs ] Work with nested attributes

• AWS SDK for Java 2.x (Low level api) : DynamoDBClient

테이블 정의

• primary key 를 정해주어야 함. 고유한 값

데이터 CRUD 종류

• GetItem : partition key 와 sort key를 명시해야 함(해당 테이블에 sort key가 있다면) 아이템 한개 가져오기

• BatchGetItem : Read up to 100 items from one or more tables

• Query : 특정 partition key를 갖고 있는 아이템들을 조회

• GetItem, Query, Scan, BatchGetItem

대용량 데이터 처리

• scale up

• CPU 분산(Read replica)

• 캐쉬 계층

• 하나의 물리적 서버에서 처리하기엔 점점 힘듦을 느끼게 됨

• 샤드? 그러나 샤드를 하게되면 운영에서 많은 어려움을 마주하게됨. 백업 복원도 어려워지고

조회

• Query : PartitionKey가 필요, GSI(PK + optional sortkey)를 이용해서도 가능함

• scan : 풀 스캔

GSI를 이용한 조회

// 기본 GSI 조회
QueryConditional.keyEqualTo { key -> key.partitionValue(email) }

// GSI + SortKey 조건
QueryConditional.sortBeginsWith { 
	key -> key.partitionValue(email).sortValue(status)
}

QueryConditional.sortBetween { 
	key -> key.partitionValue(email).sortValue(startDate, endDate) }

보조 인덱스

글로벌 보조 인덱스

코틀린에서 정의하기

@DynamoDbBean
data class Currency(

    // KSUID
    @get:DynamoDbAttribute("id")
    var id: String = "",

    // Primary Key
    // pk-currencyCode-contryCode-sk-timestamp
    @get:DynamoDbPartitionKey
    @get:DynamoDbAttribute("PK")
    var pk: String = "",

    @get:DynamoDbAttribute("currency_code")
    @get:DynamoDbSecondaryPartitionKey(indexNames = ["gsi-pk-currency-code-sk-timestamp"])
    var currencyCode: String = "",

    @get:DynamoDbAttribute("contry_code")
    var contryCode: String = "",

    @get:DynamoDbAttribute("value")
    var value: BigDecimal = BigDecimal.ZERO,

    @get:DynamoDbSortKey
    @get:DynamoDbAttribute("timestamp")
    @get:DynamoDbSecondarySortKey(indexNames = ["gsi-pk-currency-code-sk-timestamp"])
    var timestamp: String = ""
)

• DynamoDB의 엔티티 클래스에는 @DynamoDbBean을 명시한다.

• 각 애트리뷰트와 필드를 맵핑하기 위한 정보로서 @DynamoDbAttribute을 명시할 수 있다. 이를 통해 물리적인 애트리뷰트의 이름과 필드명을 다르게 할 수 있다.

• Primary Key(PK)의 Partition Key(PK)에 해당하는 필드에는 @DynamoDbPartitionKey를 명시한다. 마찬가지로 Primary Key(PK)의 Sort Key(SK)에 해당하는 필드에는 @DynamoDbSortKey를 명시한다.

• GSI에는 앞서 PK와 유사하게 @DynamoDbSecondaryPartitionKey와 @DynamoDbSecondarySortKey를 명시한다.

• LSI 에는 @DynamoDbSecondarySortKey 와 인덱스 이름을 명시

로컬 보조 인덱스

• 보기 및 회신 횟수가 가장 많은 포럼 스레드

• 특정 포럼에서 메시지 수가 가장 많은 스레드

• 특정 기간 동안 특정 포럼에 게시된 스레드 수