3.3단계: 실시간 분석 추가(애플리케이션 코드 추가)

인애플리케이션 스트림에 대해 직접 SQL 쿼리를 작성할 수 있지만 다음 단계에서는 샘플 코드를 제공하는 템플릿 중 하나를 사용합니다.

1. 애플리케이션 허브 페이지에서 SQL편집기로 이동을 선택합니다.

   

2. ExampleApp““실행을 시작하시겠습니까?” 에서 대화 상자에서 예, 응용 프로그램 시작을 선택합니다.

   콘솔에서 애플리케이션 시작 요청을 보내면 (참조StartApplication) SQL 편집기 페이지가 나타납니다.

3. 콘솔에서 SQL 편집기 페이지가 열립니다. 버튼 (SQL템플릿에서 추가, 저장 및 실행 SQL) 과 다양한 탭을 포함한 페이지를 검토하십시오.

4. SQL편집기에서 SQL템플릿에서 추가를 선택합니다.

5. 가용한 템플릿 목록에서 [Continuous filter]를 선택합니다. 샘플 코드는 하나의 애플리케이션 내 스트림으로부터 오는 데이터를 읽고(WHERE 절이 행을 필터링) 다음과 같이 그것을 다른 애플리케이션 내 스트림에 삽입합니다.

   • 애플리케이션 내 스트림 DESTINATION_SQL_STREAM을 생성합니다.

   • 펌프 STREAM_PUMP를 생성하고, 생성한 펌프를 사용하여 SOURCE_SQL_STREAM_001에서 행을 선택한 다음 DESTINATION_SQL_STREAM에 삽입합니다.

6. SQL편집기에 추가를 선택합니다.

7. 다음과 같이 애플리케이션 코드를 시험합니다.

   이미 애플리케이션을 시작했다는 점을 기억하세요 (상태는RUNNING). 그러므로 Amazon Kinesis Data Analytics는 이미 스트리밍 소스로부터 지속적으로 읽고 행을 애플리케이션 내 스트림 SOURCE_SQL_STREAM_001에 추가하고 있습니다.

   1. SQL편집기에서 [저장 후 실행] 을 선택합니다SQL. 우선 콘솔이 업데이트 요청을 전송하여 애플리케이션 코드를 저장합니다. 그런 다음, 코드가 연속적으로 실행됩니다.

   2. [Real-time analytics] 탭에서 결과를 확인할 수 있습니다.

      

      SQL에디터에는 다음과 같은 탭이 있습니다.

      • [Source data] 탭에서는 스트리밍 소스로 매핑되는 애플리케이션 내 입력 스트림을 확인할 수 있습니다. 애플리케이션 내 스트림을 선택하면 수신되는 데이터를 확인할 수 있습니다. 입력 구성에서 지정되지 않은 애플리케이션 내 입력 스트림에서의 추가 열에 주목합니다. 여기에는 다음과 같은 타임스탬프 열이 포함됩니다:

         

        • ROWTIME— 애플리케이션 내 스트림의 각 행에는 라는 ROWTIME 특수 열이 있습니다. 이 열은 Amazon Kinesis Data Analytics가 첫 번째 애플리케이션 내 스트림 (스트리밍 소스에 매핑되는 애플리케이션 내 입력 스트림)에 행을 삽입할 때의 타임스탬프입니다.

           

        • Approximate_Arrival_Time – 각 Kinesis Data Analytics 레코드에는 Approximate_Arrival_Time라는 값이 포함됩니다. 이 값은 스트리밍 소스가 레코드를 성공적으로 수신하여 저장하는 시점에 정해지는 대략적인 도착 타임스탬프입니다. Kinesis Data Analytics가 스트리밍 소스로부터 레코드를 읽을 때 이 열을 애플리케이션 내 입력 스트림으로 가져옵니다.

        이들 타임스탬프 값은 시간 기반 윈도우 모드 쿼리에 유용합니다. 자세한 설명은 윈도우 모드 쿼리 섹션을 참조하십시오.

         

      • [Real-time analytics] 탭에서는 애플리케이션 코드에서 생성한 다른 모든 애플리케이션 내 스트림을 확인할 수 있습니다. 여기에는 오류 스트림도 포함됩니다. Kinesis Data Analytics는 처리할 수 없는 모든 행을 오류 스트림으로 보냅니다. 자세한 설명은 오류 처리 섹션을 참조하십시오.

         

        DESTINATION_SQL_STREAM을 선택하여 애플리케이션 코드가 삽입한 행을 확인합니다. 애플리케이션이 생성하지 않은 추가 열에 주목합니다. 이러한 열에는 ROWTIME 타임스탬프 열이 포함됩니다. Kinesis Data Analytics는 단순히 소스 (SOURCE_SQL_STREAM_001)에서 이러한 값을 복사합니다.

         

      • 목적지 탭에는 Kinesis Data Analytics가 쿼리 결과를 작성하는 외부 목적지가 나타납니다. 아직 애플리케이션 출력의 외부 대상을 구성하지 않았습니다.

다음 단계

3.4단계: 애플리케이션 코드 업데이트(선택 사항)