백엔드
포스코홀딩스의 Managed Apache Flink를 활용한 효율적인 다수 CCTV 이벤트 처리 사례
두줄요약
포스코홀딩스는 다수 CCTV의 AI 추론 결과를 Kinesis와 Managed Apache Flink로 실시간 분석했습니다. CloudWatch 필터링, CEP 최적화, State Backend 조정으로 이벤트 감지와 운영 효율을 높였습니다.
문제 상황
- 포항·광양제철소의 다수 CCTV와 AI 추론 결과를 결합해 실시간 복합 이벤트를 감지할 필요
- 작업 상황과 장소별로 감지 로직을 자주 수정·배포해야 하는 운영 요구
- 장기 운영 시 CEP 처리 지연과 누적 Backpressure, 이벤트 필터링 비용·복잡도 문제
해결 방법
- Amazon Kinesis로 AI 추론 데이터를 수집하고 Managed Apache Flink와 Flink CEP로 이벤트 패턴 탐지
- CloudWatch와 Subscription Filter로 특정 결과 이벤트를 선별해 후속 알림 처리
- 패턴 조건 순서 최적화, 적절한 Windows Operator 적용, MemoryStateBackend로 지연 완화