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

애플리케이션 허브 페이지에서 [Go to SQL editor]를 선택합니다.

Would you like to start running "ExampleApp"?("ExampleApp"을 실행하시겠습니까?) 대화 상자에서 Yes, start application(예, 애플리케이션 시작)을 선택합니다.

콘솔이 애플리케이션 시작 요청을 전송하고(StartApplication 참조), SQL 편집기 페이지가 나타납니다.

콘솔이 SQL 편집기 페이지를 엽니다. 버튼([Add SQL from templates], [Save and run SQL]) 및 다양한 탭을 포함하여 페이지를 검토합니다.

SQL 편집기에서 [Add SQL from templates]를 선택합니다.

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

[Add this SQL to editor]를 선택합니다.

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

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

1. SQL 편집기에서 [Save and run 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가 쿼리 결과를 작성하는 외부 목적지가 나타납니다. 아직 애플리케이션 출력의 외부 대상을 구성하지 않았습니다.