Модуль передачи событий в Apache Kafka: как ритейлеру собирать и анализировать данные по кассовым событиям

Чтобы принимать своевременные управленческие решения, важно владеть полной информацией о работе торговой сети – например, как работают кассы в магазинах, какие операции совершают кассиры, какие товары покупают чаще всего, а также как скидки и акции влияют на продажи. Модуль передачи событий из Set Retail в Apache Kafka решает проблему дополнительной выгрузки данных – их можно получить с касс в виде определенных событий, при сочетаемости которых можно вычислить необходимые показатели.

Модуль решает несколько ключевых задач:

• Позволяет оценить качество работы кассиров и выявлять отклонения от стандартов, чтобы в дальнейшем оптимизировать работу персонала.

• Помогает обнаруживать возможные случаи мошенничества с помощью анализа подозрительных операций, например, отмены чеков после покупки.

• Дает возможность анализировать влияние маркетинговых акций на скорость работы кассы и продажи.

• Позволяет анализировать поведение покупателей. Например, какие товары покупают чаще, в каких магазинах и в какое время.

Как работает модуль передачи событий

При включении дополнительной лицензии на модуль, на кассе появляется возможность выгрузки всех кассовых событий в Apache Kafka. 

Что подразумевается под событием? Это действие кассира или покупателя, например: авторизация, добавление товара в чек, расчет и оплата. Модуль собирает в Set Retail больше 80 видов событий на разных устройствах – как классических кассах, так и кассах самообслуживания на программном обеспечении Set SCO.

Каждое событие превращается в пакет данных. Они записываются в таблицу очередей, фильтруются и отправляются в отдельный топик брокера сообщений Apache Kafka – специальный «контейнер» для разных типов данных. На сервере Set можно настроить отправку только выбранных событий.

Далее события можно получать из топика любой внешней системой и использовать для анализа и формирования отчетов.

Apache Kafka играет ключевую роль в обработке и передаче данных между кассами и аналитическими сервисами. Если в момент отправки событий с Apache Kafka нет соединения, то данные не теряются – они временно хранятся в базе кассы и отправляются при восстановлении связи.

Сам брокер сообщений Apache Kafka настраивается отдельно. Можно использовать уже имеющийся сервер Kafka, например, поставляемый с Set ESB или с Set Loyalty. Но при таком использовании обязательно нужно учесть увеличение нагрузки на сервер и объем данных.

Пример расчета объема данных

Чтобы понять, сколько данных будет обрабатываться системой, посмотрим на примере:

• Размер одного события 300-700 байт. Возьмем для расчета 600 байт.

• На каждую позицию приходится 1-5 события. Возьмем среднее – 3.

• На сам чек (оплаты, скидки, и так далее) приходится еще 10-15 событий.

• При средних характеристиках ритейлера: 10 позиций в чеке, 200 чеков с кассы в сутки, около 1000 касс в сети.

Получаем: (10*3*600+15*600)*200*1000 = 5 Гб в сутки + 30% на погрешность – 7 Гб.

В топике данные хранятся по умолчанию 3 суток – это уже около 20 Гб. В периоды пиковых нагрузок (например, перед праздниками) объем данных может увеличиваться в 3 раза.

Как можно использовать данные 

Собираемые данные о событиях позволяют ритейлеру:

• Отслеживать работу пользователей кассы: авторизации, начало и конец смен, повышение прав кассиров.
• Анализировать кассовые документы: внесение и изъятие денег, чеки продажи и возврата, аннулированные и отложенные мягкие чеки.
• Контролировать операции с товарами: добавление и удаление товаров, изменение цен, сканирование маркированных товаров.
• Анализировать эффективность программы лояльности: использование карт лояльности при покупках, начисление и списание бонусов.
• Следить за применением купонов: добавление, выдача и использование купонов.
• Отслеживать скидочные операции: все виды скидок, которые применяются в процессе покупки.
• Контролировать платежные операции: наличные и безналичные оплаты, а также возвраты.
• Фиксировать события кассового дня: регистрации чеков, перезагрузки кассы, снятие X и Z-отчетов.
• Оценивать поведение покупателей на кассах самообслуживания: вызовы помощника, подтверждение возраста и другие специфические события.

Лицензирование и подключение

Модуль передачи событий в Apache Kafka — отдельное лицензируемое решение, которое интегрируется в Set Retail и позволяет ритейлеру анализировать различные события в магазинах. 

Больше деталей о настройке и деталях работы модуля вы найдете в нашей базе знаний.

Если у вас есть вопросы по новым возможностям экосистемы Set — обратитесь к своему менеджеру или на e-commerce@crystals.ru