Компания PARI внедрила систему real-time-аналитики, которая обрабатывает события пользователей, включая ставки, за 10–15 секунд. Технологический стек включает Kafka для потоковой передачи данных и ClickHouse с использованием Kafka Engine и Materialized Views для их агрегации.
Система непрерывно преобразует поток событий в готовые показатели, такие как оборот или количество ставок, используя движок AggregatingMergeTree. Это решение заменило ручной мониторинг дашбордов, при котором на обнаружение проблем уходили часы или дни.
Детектор аномалий сравнивает текущие показатели с историческими данными за 90 дней, учитывая цикличность бизнес-процессов. Проверка метрик проводится с интервалом в 15 минут, что позволяет снизить количество ложных срабатываний.
Необходимость в автоматизированном мониторинге возникла после обнаружения расхождений в показателях в апреле 2026 года. На текущий момент детектор зафиксировал около 6 900 срабатываний, что ставит перед командой задачу приоритизации сигналов.
В планах компании — переход от описательной аналитики к предиктивной модели. Разработка включает внедрение прогнозирования в реальном времени для бонусных предложений и персонализации, что должно повысить вовлеченность пользователей и стабильность продукта.
