자습서: KPL 및 KCL 2.x를 사용하여 실시간 주식 데이터 처리 - Amazon Kinesis Data Streams

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

자습서: KPL 및 KCL 2.x를 사용하여 실시간 주식 데이터 처리

이 자습서의 시나리오에서는 스트림에 주식 거래를 가져와 데이터 스트림에 대한 계산을 수행하는 간단한 Amazon Kinesis Data Streams 애플리케이션을 작성합니다. Kinesis Data Streams에 레코드 스트림을 전송하고, 거의 실시간으로 레코드를 사용하고 처리하는 애플리케이션을 구현하는 방법을 알아봅니다.

중요

는 Kinesis Data Stream에서 제공되지 않으므로 스트림을 생성한 후에는 Kinesis Kinesis Data Streams 사용에 대한 일반 요금이 계정에 부과됩니다.AWS프리 티어. 소비자 애플리케이션이 시작된 후에는 Amazon DynamoDB 사용에 대한 일반 요금도 발생합니다. 소비자 애플리케이션은 DynamoDB를 사용하여 처리 상태를 추적합니다. 이 응용 프로그램을 완료하면 를 삭제하십시오.AWS요금 발생을 중지하기 위한 리소스 자세한 정보는 단계 7: 마무리 마무리 업을 참조하십시오.

이 코드는 실제 주식 시장 데이터에는 액세스하지 않지만, 대신 주식 거래의 스트림을 시뮬레이션합니다. 2015년 2월 현재 시가 총액 상위 25개 주식에 대한 실제 시장 데이터의 시작점이 있는 임의의 주식 거래 생성기를 사용하여 이를 수행합니다. 주식 거래의 실시간 스트림에 액세스할 수 있는 경우 스트림에서 유용하고 시기 적절한 통계를 추출하고 싶을 때도 있습니다. 예를 들어, 마지막 5분 이내에 구매한 가장 인기 있는 주식을 결정하는 슬라이딩 윈도우 분석을 수행하려고 할 수 있습니다. 또는 너무 많은 판매 주문(즉, 너무 많은 공유)이 있을 때마다 알림을 원할 수도 있습니다. 이 시리즈의 코드를 확장하여 이러한 기능을 제공할 수 있습니다.

데스크톱 또는 랩톱 컴퓨터에서 이 자습서의 단계를 완료하고, 동일한 머신에서 또는 정의된 요구 사항을 지원하는 플랫폼에서 생산자 코드와 소비자 코드를 모두 실행할 수 있습니다.

표시된 예제는 미국 서부 (오레곤) 리전을 사용하지만 모든 리전에 적용됩니다.AWS지역Kinesis Data Streams 지원하는 기능입니다.