클라우드 네이티브 애플리케이션 디자인 패턴

277

6

장

스트림 프로세싱 패턴

관련 패턴들

변환 패턴

애그리게이션 결과를 다른 데이터 포맷으로 바꿀 때 사용합니다.

신뢰성 패턴

시스템 장애 상태에도 윈도우 및 애그리게이션 상태를 저장하고 복구할 수 있습니다.

순차 수송 패턴

애그리게이션을 샤드 키 기반으로 나누고 병렬로 처리합니다. 애그리게이션 처리 연산을 확

장할 수 있을 뿐 아니라 서로 다른 유형의 이벤트를 독립적으로 애그리게이션하고 이벤트

유형별 애그리게이션 결과를 만들 수도 있습니다.

서비스 오케스트레이션 패턴

3

장에서 설명한 패턴으로 이벤트를 샤드 키 기반으로 나누어 처리할 수 있습니다.

스트림 조인 패턴

다른 샤드에서의 애그리게이션 결과들을 합칩니다.

6.3.46.3.4

스트림 조인 패턴 스트림 조인 패턴

스트림 조인 패턴

stream

join

pattern

은

SQL

테이블 조인 연산과 비슷하게 서로 다른 스키마를 가지

는 여러 스트림의 이벤트를 합칠 때 사용할 수 있습니다.

어떻게 동작할까요

이 패턴에서는 합칠 이벤트를 식별할 수 있는 조건을 정의합니다. 이 조건은 합칠 각 이벤트 스

트림의 속성 값을 사용해서 어떤 이벤트들을 합칠 지 알려줍니다. 간단한 비교 연산자를 사용

해서 같은

ID

값을 가지는 모든 이벤트를 합칠 수도 있고, 또는 더 복잡한 조건을 사용할 수도

있습니다.

또한 이 패턴에서는 다른 이벤트 스트림으로부터 관련 이벤트가 도착할 때까지 얼마나 많은 이

278

클라우드 네이티브 애플리케이션 디자인 패턴

벤트를 기다려야 할지 결정하는 버퍼를 정의합니다. 버퍼 간격은 여러 스트림에 ...