이 섹션에서는 Amazon DynamoDB용 Kinesis Data Streams 테이블을 Amazon DynamoDB 콘솔, AWS Command Line Interface(AWS CLI) 및 API와 함께 사용하는 방법을 설명합니다.
활성 Amazon Kinesis Data Streams 생성
다음의 모든 예에서는 DynamoDB 시작하기 자습서의 일부로 생성된 Music
DynamoDB 테이블을 사용합니다.
소비자를 빌드하고 Kinesis 데이터 스트림을 다른 AWS 서비스에 연결하는 방법에 대한 자세한 내용은 Amazon Kinesis Data Streams 개발자 안내서의 Amazon Kinesis Data Streams에서 데이터 읽기를 참조하세요.
참고
KDS 샤드를 처음 사용할 때는 사용 패턴에 따라 샤드를 스케일 업 또는 스케일 다운하도록 설정하는 것이 좋습니다. 사용 패턴에 대한 데이터를 더 많이 축적한 후에는 스트림의 샤드를 이에 맞게 조정할 수 있습니다.
-
AWS Management Console에 로그인하여 https://console.aws.amazon.com/kinesis/
에서 Kinesis 콘솔을 엽니다. -
Create data stream(데이터 스트림 생성)을 선택하고 지침에 따라
samplestream
이라는 스트림을 생성합니다. -
https://console.aws.amazon.com/dynamodb/
에서 DynamoDB 콘솔을 엽니다. -
콘솔 왼쪽의 탐색 창에서 테이블을 선택합니다.
-
Music 테이블을 선택합니다.
-
내보내기 및 스트림(Exports and streams) 탭을 선택합니다.
-
(선택 사항) Amazon Kinesis 데이터 스트림 세부 정보에서 레코드 타임스탬프 정밀도를 마이크로초(기본값)에서 밀리초로 변경할 수 있습니다.
-
드롭다운 목록에서 samplestream을 선택합니다.
-
켜기 버튼을 선택합니다.
활성 Amazon Kinesis 데이터 스트림에 변경 사항 적용
이 섹션에서는 콘솔, AWS CLI 및 API를 사용하여 DynamoDB에 대한 활성 Kinesis Data Streams 설정을 변경하는 방법을 설명합니다.
AWS Management Console
-
https://console.aws.amazon.com/dynamodb/
에서 DynamoDB 콘솔을 엽니다. -
테이블로 이동합니다.
-
내보내기 및 스트림을 선택합니다.
AWS CLI
-
describe-kinesis-streaming-destination
을 직접 호출하여 스트림이ACTIVE
임을 확인합니다. -
다음 예와 같이
UpdateKinesisStreamingDestination
을 직접 호출합니다.aws dynamodb update-kinesis-streaming-destination --table-name enable_test_table --stream-arn arn:aws:kinesis:us-east-1:12345678901:stream/enable_test_stream --update-kinesis-streaming-configuration ApproximateCreationDateTimePrecision=MICROSECOND
-
describe-kinesis-streaming-destination
을 직접 호출하여 스트림이UPDATING
임을 확인합니다. -
스트리밍 상태가 다시
ACTIVE
가 될 때까지 주기적으로describe-kinesis-streaming-destination
을 직접 호출합니다. 타임스탬프 정밀도 업데이트가 적용되려면 일반적으로 최대 5분이 걸립니다. 이 상태가 업데이트되면 업데이트가 완료되었으며 새 정밀도 값이 향후 레코드에 적용될 것임을 나타냅니다. -
putItem
을 사용하여 테이블에 기록합니다. -
Kinesis
get-records
명령을 사용하여 스트림 콘텐츠를 가져옵니다. -
쓰기의
ApproximateCreationDateTime
정밀도가 원하는 수준인지 확인합니다.
Java API
-
UpdateKinesisStreamingDestination
요청 및UpdateKinesisStreamingDestination
응답을 구성하는 코드 스니펫을 제공합니다. -
DescribeKinesisStreamingDestination
요청 및DescribeKinesisStreamingDestination response
를 구성하는 코드 스니펫을 제공합니다. -
스트리밍 상태가 다시
ACTIVE
가 될 때까지 주기적으로describe-kinesis-streaming-destination
을 직접 호출합니다. 이 상태는 업데이트가 완료되고 향후 레코드에 새 정밀도 값이 적용될 것임을 나타냅니다. -
테이블에 대한 쓰기를 수행합니다.
-
스트림에서 읽고 스트림 콘텐츠를 역직렬화합니다.
-
쓰기의
ApproximateCreationDateTime
정밀도가 원하는 수준인지 확인합니다.