上海鷗新：基於大數據的商場實時客流分析系統

公司介紹

上海鷗新軟件有限公司專一於室內定位技術和客流統計與分析的研發，如室內定位引擎、客流統計與分析系統。在用戶導入客流系統的同時，爲商業零售實體店提供了網絡覆蓋、微信上網，定時定地點向客戶進行精準化商業信息推送等一體化解決方案。

產品簡介

實時客流分析產品主要是基於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 場景下的開發；可與用戶已使用的大數據組件無縫對接，更多增值特性助力企業實時化轉型。

  更多關於實時計算的介紹，參見實時計算產品詳情頁。