포스코홀딩스의 Managed Apache Flink를 활용한 효율적인 다수 CCTV 이벤트 처리 사례

간단 소개

포스코홀딩스는 Managed Apache Flink를 활용하여 다수 CCTV 이벤트 처리 시스템을 구축하고, CloudWatch, Flink CEP, MemoryStateBackend 등을 통해 효율성과 안정성을 향상시켰다.

AI Summary

포스코홀딩스의 과제 및 해결
- 포스코홀딩스는 다수 CCTV 이벤트 처리를 위해 Amazon Kinesis와 Managed Apache Flink를 도입하여 실시간 상황 감지 시스템을 구축함.
- 이벤트 필터링을 위해 CloudWatch와 구독 필터를 활용하여 비용 효율적인 파이프라인을 구축하고, Flink CEP 로직의 복잡성을 해결함.
- MemoryStateBackend로 State Backend 설정을 변경하여 Managed Apache Flink의 장기 운영 시 누적되는 처리 지연 문제를 해결함.
Flink CEP 활용 및 효과
- KeyedProcessFunction 및 Windows Operator를 활용하여 다양한 이벤트 감지 시나리오에 효과적으로 대응하고, 불필요한 중복 이벤트 발생을 방지함.
- AI 모델 추론 결과를 Kinesis Data Stream으로 수집하고, Managed Apache Flink와 Flink CEP를 통해 다양한 상황에 따른 이벤트 패턴을 실시간으로 탐지함.
- AWS 팀과의 협력을 통해 작업 상황과 장소별로 감지 로직을 유연하게 수정하고 업데이트할 수 있는 파이프라인을 구현함.