開發與維運

基於實時計算(Flink)的商場實時客流分析系統——上海鷗新

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

產品簡介
實時客流分析產品主要是基於Wi-Fi的客流統計與分析系統,如下圖

實時熱力圖
通過實時客流分析系統,製作每個樓層的實時熱力圖,不同顏色代表客流人數的密集程度。

image.png

實時客流統計圖

image.png

實時客流分析產品主要服務於商場運營方,提供的功能包括:

實時客流分析:商場熱力圖、店鋪熱力圖、客流數、新老客佔比、停留時間和客流時間分佈等,為運營決策提供數據支持;
精準推送:將Wi-Fi採集到的地址跟現有數據庫進行碰撞,針對碰撞出的用戶建立用戶畫像,根據來店情況進行精準推送;
位置定向廣告:跟商場線下廣告屏幕打通,設定地理圍欄與規則,命中規則後個性化推薦廣告。
系統架構
整個系統的數據源都是Wi-Fi,Wi-Fi設備的布點是系統成功的關鍵。在Wi-Fi鋪設的過程中會預先記錄好設備的位置(所屬樓層,平面座標,所屬店鋪等),且根據業務情況來Wi-Fi之間是否重疊:如果要精確,需要多點定位,否則儘量Wi-Fi的範圍不重疊,防止數據互相汙染。

image.png

數據流程
使用Wi-Fi採集設備信息。
把採集的數據經過SLB發送到接收服務器。
接受服務器把數據發送到消息隊列(DataHub)。
實時計算訂閱DataHub數據。
把設備採集到的用戶信息跟設備的地理位置信息進行關聯。
完成處理,然後把結果寫出供下游使用。
實時計算的處理

數據清洗、去重。
維表關聯,用戶mac地址與設備地理信息關聯,實時數據與歷史數據關聯。
手機品牌識別,位置識別,新客識別。
計算停留時間、生成軌跡。
說明 數據收集與清洗部分是整個系統的基礎,在這些數據的基礎上可再進行精準推送和位置廣告等服務。
總結
鷗新商場實時客流分析平臺涉及多臺線下設備(2000臺設備),實時計算每秒處理輸入30K條數據,每秒輸出20K條處理後的數據,整體延遲為秒級,整體收益包括:

運維成本:免運維,阿里雲提供高保障;
對接上下游:直接註冊,免開發;
開發成本:SQL開發,效率高,門檻低,原來單作業Java開發3天的工作量降低到1天內,且BUG少,整個系統重構只需一週。
這套系統打通了線下與線上,為商場的運營方得到了不同維度的數據支持,提高了運營活動的效果,為在顧客打造更好的購物體驗的同時也提升商場的整體營收。

商場實時客流分析系統是IoT技術與大數據實時處理技術結合起來的典型案例。

注:本文部分內容來自鷗新蔡新峰的分析,特此感謝。

如果你有類似場景需求,歡迎聯繫付空。

Leave a Reply

Your email address will not be published. Required fields are marked *