Amazon에서 저널 데이터 스트리밍 QLDB

이벤트 기반 아키텍처 - 분리된 구성 요소를 사용하여 이벤트 기반 아키텍처 스타일로 애플리케이션을 빌드합니다. 예를 들어 은행은 AWS Lambda 함수를 사용하여 계정 잔액이 임계값 아래로 떨어질 때 고객에게 알리는 알림 시스템을 구현할 수 있습니다. 이러한 시스템에서 계정 잔액은 QLDB 원장에 유지되고 모든 잔액 변경 사항은 저널에 기록됩니다. AWS Lambda 함수는 저널에 커밋되어 Kinesis 데이터 스트림으로 전송되는 밸런스 업데이트 이벤트를 소비할 때 알림 로직을 트리거할 수 있습니다.

실시간 분석 - 이벤트 데이터에 대한 실시간 분석을 실행하는 Kinesis 소비자 애플리케이션을 빌드합니다. 이 기능을 사용하면 거의 실시간으로 통찰력을 얻고 변화하는 비즈니스 환경에 신속하게 대응할 수 있습니다. 예를 들어, 전자 상거래 웹 사이트는 제품 판매 데이터를 분석하고 판매량이 한도에 도달하는 즉시 할인된 제품에 대한 광고를 중단할 수 있습니다.

과거 분석 - 과거 이벤트 데이터를 재생QLDB하여 Amazon의 저널 지향 아키텍처를 활용합니다. 과거 어느 시점에서든 QLDB 스트림을 시작하도록 선택할 수 있습니다. 이 시간 이후의 모든 개정은 Kinesis Data Streams로 전달됩니다. 이 기능을 사용하면 기록 데이터에 대한 분석 작업을 실행하는 Kinesis 소비자 애플리케이션을 빌드할 수 있습니다. 예를 들어 전자 상거래 웹 사이트는 필요에 따라 분석을 실행하여 이전에 포착되지 않았던 과거 판매 지표를 생성할 수 있습니다.

용도별 데이터베이스 복제 - QLDB 저널 스트림을 사용하여 QLDB 원장을 기타 용도별 데이터 스토어에 연결합니다. 예를 들어 Kinesis 스트리밍 데이터 플랫폼을 사용하여 Amazon OpenSearch Service와 통합하면 QLDB 문서에 대한 전체 텍스트 검색 기능을 제공할 수 있습니다. 또한 사용자 지정 Kinesis 소비자 애플리케이션을 빌드하여 저널 데이터를 다양한 구체화된 뷰를 제공하는 다른 목적별 데이터베이스에 복제할 수 있습니다. 예를 들어 관계형 데이터의 경우 Amazon Aurora로, 그래프 기반 데이터의 경우 Amazon Neptune으로 복제합니다.

Kinesis는 Kinesis Data Streams 프로비저닝에 QLDB따라 에서 스트리밍되는 데이터를 제한할 수 있습니다. 예를 들어 단일 Kinesis 데이터 QLDB 스트림에 쓰는 스트림이 여러 개 있고 요청 속도가 Kinesis 스트림 리소스의 용량을 QLDB 초과하는 경우 이러한 상황이 발생할 수 있습니다. Kinesis의 제한은 온디맨드 프로비저닝을 사용할 때도 15분 이내에 처리량이 이전 최고치의 두 배 이상으로 증가하는 경우 발생할 수 있습니다.

Kinesis 지표 WriteProvisionedThroughputExceeded를 모니터링하여 초과 처리량을 측정할 수 있습니다. 자세한 내용과 가능한 해결 방법은 Kinesis Data Streams에서 제한 오류를 해결하려면 어떻게 해야 하나요? 섹션을 참조하세요.

QLDB 스트림을 사용하면 시작 날짜 및 시간이 과거이고 종료 날짜 및 시간이 없는 무기한 스트림을 생성할 수 있습니다. 설계상 는 지정된 시작 날짜 및 시간의 모든 이전 데이터가 성공적으로 전송된 후에만 Kinesis Data Streams로 새로 커밋된 데이터를 보내기 QLDB 시작합니다. 이 시나리오에서 추가 지연이 감지되면 이전 데이터가 전송될 때까지 기다리거나 나중의 시작 날짜 및 시간부터 스트림을 시작할 수도 있습니다.