새 프로젝트의 경우 애플리케이션용 Kinesis Data Analytics보다 Apache Flink Studio용 새로운 관리형 서비스를 사용하는 것이 좋습니다. SQL Managed Service for Apache Flink Studio는 사용 편의성과 고급 분석 기능을 결합하여 정교한 스트림 처리 애플리케이션을 몇 분 만에 구축할 수 있도록 합니다.
기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.
3단계: 애플리케이션 출력 구성
이 시점에 핫스팟 예에서 Amazon Kinesis Data Analytics 애플리케이션 코드를 보유하여 스트리밍 소스로부터 중요 핫스팟을 발견하고 히트 점수를 각각에게 할당합니다.
이제 애플리케이션 내 스트림에서 외부 목적지인 또 다른 Kinesis 데이터 스트림 (ExampleOutputStream)으로 에플리케이션 결과를 보낼 수 있습니다. 그런 다음 핫스팟 점수를 분석하고 핫스팟 히트에 대한 적절한 임계점을 판단할 수 있습니다. 이 애플리케이션을 더욱 확장하여 알림을 만들 수 있습니다.
애플리케이션 출력을 구성하려면
-
https://console.aws.amazon.com/kinesisanalytics
에서 Kinesis Data Analytics 콘솔을 엽니다. -
SQL 편집기에서 [Destination]을 선택하거나 애플리케이션 대시보드에서 [Add a destination]을 선택합니다.
-
Add a destination(대상 주소 추가) 페이지에서 Select from your streams(나의 스트림에서 선택)을 선택합니다. 그런 다음 이전 섹션에서 생성한
ExampleOutputStream스트림을 선택합니다.이제 애플리케이션 내 스트림
DESTINATION_SQL_STREAM에 애플리케이션이 작성하는 모든 레코드를 Amazon Kinesis Data Analytics가 유지하는 외부 대상이 생성되었습니다. -
ExampleOutputStream스트림을 모니터링하고 알림을 전송하도록 AWS Lambda을(를) 선택적으로 구성할 수 있습니다. 자세한 설명은 Lambda 함수를 출력으로 사용 섹션을 참조하세요. 4단계: 애플리케이션 출력 확인에서 설명한 대로 Kinesis Data Analytics가 외부 목적지인 Kinesis 스트림ExampleOutputStream에 기록하는 레코드를 검토할 수 있습니다.
다음 단계
