上海鸥新：基于大数据的商场实时客流分析系统

公司介绍

上海鸥新软件有限公司专一于室内定位技术和客流统计与分析的研发，如室内定位引擎、客流统计与分析系统。在用户导入客流系统的同时，为商业零售实体店提供了网络覆盖、微信上网，定时定地点向客户进行精准化商业信息推送等一体化解决方案。

产品简介

实时客流分析产品主要是基于Wi-Fi的客流统计与分析系统。

• 实时热力图：经过实时客流分析系统，制做每一个楼层的实时热力图，不一样颜色表明客流人数的密集程度。

  图 1.上海鸥新：实时热力图

  

• 实时客流统计图：实时客流分析产品主要服务于商场运营方，提供的功能包括：

  • 实时客流分析：商场热力图、店铺热力图、客流数、新老客占比、停留时间和 客流时间分布等，为运营决策提供数据支持
  • 精准推送：将Wi-Fi 采集到的地址跟现有数据库进行碰撞，针对碰撞出的用户 创建用户画像，根据来店状况进行精准推送
  • 位置定向广告：跟商场线下广告屏幕打通，设定地理围栏与规则，命中规则后 个性化推荐广告。

图 2.上海鸥新：实时客流统计图

[![上海鸥新：实时客流统计图](https://static-aliyun-doc.oss-cn-hangzhou.aliyuncs.com/assets/img/zh-CN/3060054851/p87679.png)](https://static-aliyun-doc.oss-cn-hangzhou.aliyuncs.com/assets/img/zh-CN/3060054851/p87679.png)

系统架构

整个系统的数据源都是Wi-Fi，Wi-Fi 设备的布点是系统成功的关键。在Wi-Fi 铺设的过程当中会预先记录好设备的位置（所属楼层，平面坐标，所属店铺等），且根据 业务状况来Wi-Fi 之间是否重叠：若是要精确，须要多点定位，不然尽可能Wi-Fi 的 范围不重叠，防止数据互相污染。

数据流程：

1. 使用Wi-Fi 采集设备信息。
2. 把采集的数据通过SLB 发送到接收服务器。
3. 接受服务器把数据发送到消息队列（DataHub）。
4. 实时计算订阅DataHub 数据。
5. 把设备采集到的用户信息跟设备的地理位置信息进行关联。
6. 完成处理，而后把结果写出供下游使用。

实时计算的处理：

• 数据清洗、去重。
• 维表关联，用户 mac 地址与设备地理信息关联，实时数据与历史数据关联。
• 手机品牌识别，位置识别，新客识别。
• 计算停留时间、生成轨迹。

数据收集与清洗部分是整个系统的基础，在这些数据的基础上可再进行精 准推送和位置广告等服务。

上云价值

鸥新商场实时客流分析平台涉及多台线下设备（2000 台设备），实时计算每秒处理输入30K 条数据，每秒输出20K 条处理后的数据，总体延迟为秒级，总体收 益包括：

• 运维成本：免运维，阿里云提供高保障。
• 对接上下游：直接注册，免开发。
• 开发成本：SQL 开发，效率高，门槛低，原来单做业 Java 开发 3 天的工做量 下降到1 天内，且BUG 少，整个系统重构只需一周。

这套系统打通了线下与线上，为商场的运营方获得了不一样维度的数据支持，提升 了运营活动的效果，为在顾客打造更好的购物体验的同时也提高商场的总体营收。 商场实时客流分析系统是IoT 技术与大数据实时处理技术结合起来的典型案例。

相关产品

• 实时计算

  实时计算（Alibaba Cloud Realtime Compute，Powered by Ververica）是阿里云提供的基于 Apache Flink 构建的企业级大数据计算平台。在 PB 级别的数据集上能够支持亚秒级别的处理延时，赋能用户标准实时数据处理流程和行业解决方案；支持 Datastream API 做业开发，提供了批流统一的 Flink SQL，简化 BI 场景下的开发；可与用户已使用的大数据组件无缝对接，更多增值特性助力企业实时化转型。

  更多关于实时计算的介绍，参见实时计算产品详情页。