저지연 파이프라인
저지연 파이프라인은 데이터가 생성(수집)되는 시점부터 소비 또는 조치를 위해 사용 가능해지는 시점까지의 시간 지연을 최소화하도록 설계된 데이터 처리 아키텍처입니다. 본질적으로 이는 배치 효율성보다 속도를 우선시하여 거의 실시간 응답성을 보장합니다.
현대의 데이터 집약적인 애플리케이션에서 지연은 직접적으로 수익 손실, 사용자 경험 저하 또는 심각한 운영 실패로 이어질 수 있습니다. 예를 들어, 사기 탐지에서 몇 초의 지연만으로도 사기 거래가 완료될 수 있습니다. 저지연성은 즉각적인 피드백 루프가 필요한 시스템에 매우 중요합니다.
이러한 파이프라인은 일반적으로 전통적인 배치 처리 대신 스트림 처리 기술에 의존합니다. 데이터는 소스(IoT 센서 또는 사용자 클릭과 같은)에서 지속적으로 수집되어 도착하는 즉시 점진적으로 처리됩니다. 주요 구성 요소에는 이벤트 순서 지정 및 변환을 최소한의 오버헤드로 처리하는 메시지 브로커(Kafka와 같은)와 스트림 처리 엔진(Flink 또는 Spark Streaming과 같은)이 포함되는 경우가 많습니다.
저지연 시스템을 구현하는 것은 복잡성을 초래합니다. 과제에는 분산 스트림 전반의 상태 관리, 정확히 한 번 처리(exactly-once processing semantics) 보장, 그리고 데이터 수집 속도가 처리 용량을 초과할 때의 백프레셔(backpressure) 처리가 포함됩니다.
이 개념은 볼륨에 중점을 두는 고처리량 시스템(High Throughput Systems) 및 데이터 소스 근접성에 중점을 두는 엣지 컴퓨팅(Edge Computing)과 밀접하게 관련되어 있습니다.