Grab의 실시간 개인화 혁신: CDP '시나리오'를 통한 사용자 경험 고도화

핵심 요약

Grab은 기존 배치 처리 방식의 한계를 극복하기 위해 실시간 개인화 기능인 '시나리오(Scenarios)'를 고객 데이터 플랫폼(CDP)에 도입했다. 이 시스템은 사용자의 실시간 이벤트, 지오펜싱 정보, 과거 프로필 데이터 및 AI 예측 모델을 결합하여 15초 이내의 낮은 지연 시간으로 개인화된 제안을 제공한다. Grab Unlimited 구독 포기 사용자에게 실시간 넛지를 제공하여 전환율을 3% 이상 높이는 등 실질적인 비즈니스 성과를 거두었으며, 마케터가 엔지니어의 도움 없이 직접 시나리오를 설계할 수 있는 셀프 서비스 환경을 구축했다. 향후에는 신호 분산 최적화 및 예약된 트리거 기능을 통해 더욱 복잡한 개인화 사례를 지원할 예정이다.

배경

데이터 스트리밍 파이프라인(Kafka, Flink)에 대한 기본 지식, CDP(Customer Data Platform)의 개념 및 역할 이해, 실시간 머신러닝 모델 서빙 아키텍처에 대한 이해

대상 독자

실시간 개인화 시스템을 설계하는 데이터 엔지니어 및 초개인화 마케팅 자동화를 고민하는 프로덕트 매니저

의미 / 영향

실시간 데이터 처리와 AI 예측의 결합이 비즈니스 전환율에 직접적인 영향을 미칠 수 있음을 보여준다. 특히 마케팅 도구의 셀프 서비스화가 조직의 민첩성을 어떻게 개선하는지에 대한 기술적, 운영적 벤치마크를 제시한다.

섹션별 상세

기존 배치 기반 CDP는 사용자 속성을 하루 한 번 업데이트하기 때문에 공항 도착이나 쇼핑몰 방문과 같은 즉각적인 대응이 필요한 상황에서 기회를 놓치는 문제가 있었다. 이를 해결하기 위해 실시간 이벤트와 과거 데이터를 동적으로 결합하고 엔지니어링 리소스 소모를 줄여 마케팅 팀의 민첩성을 높이는 새로운 프레임워크가 요구되었다. 실시간 개인화는 사용자 경험을 개선할 뿐만 아니라 비즈니스 전환율을 직접적으로 높이는 핵심 전략으로 자리 잡았다.

CDP '시나리오' 기능은 Scribe를 통한 실시간 이벤트 트리거, 특정 위치 기반의 지오펜싱, CDP의 과거 배치 속성, 그리고 Catwalk 플랫폼의 사전 학습된 AI 모델을 통합한다. 마케터는 GUI를 통해 복잡한 이벤트 시퀀스를 정의하고 가상 데이터를 사용해 Flink 파이프라인에서 시나리오를 검증한 후 1시간 이내에 실시간 서비스에 배포할 수 있다. 이러한 셀프 서비스 구조는 엔지니어링 병목 현상을 제거하고 실험 주기를 획기적으로 단축했다.

전체 시스템 아키텍처는 15초 미만의 지연 시간을 목표로 설계되었으며 Apache Flink를 사용하여 실시간 스트리밍 데이터를 처리한다. 실시간 이벤트가 발생하면 StarRocks에서 과거 데이터를 조회하고 AI 모델로 사용자 의도를 예측한 뒤 그 결과를 Kafka나 내부 기능 저장소인 Amphawa에 동기화한다. 동기화된 데이터는 다운스트림 서비스에서 Profile SDK나 Kafka 스트림을 통해 즉시 소비되어 사용자에게 개인화된 경험을 제공한다.

Grab Unlimited 구독 프로세스를 시작했다가 중단한 사용자에게 15분 이내에 실시간 알림을 보내는 시나리오를 적용한 결과 비실시간 캠페인 대비 구독 전환율이 3% 이상 상승했다. 이 외에도 쇼핑몰 도착 시 맞춤형 할인 혜택 제공, 공항에서의 이동 수단 추천 등 12개 이상의 실무 사례에서 사용자 참여도와 전환율을 유의미하게 개선했다. 이는 실시간 데이터와 AI 예측의 결합이 실제 비즈니스 가치 창출에 기여함을 입증한 사례이다.