[發明專利]一種通過通信數據實現人流實時監控的方法

有效

• 申請號: 201610185477.0
• 申請日: 2016-03-29
• 公開（公告）號: CN105681768B
• 公開（公告）日: 2018-08-17
• 發明（設計）人: 李壽龍
• 申請（專利權）人: 浪潮天元通信信息系統有限公司
• 主分類號: H04N7/18
• 分類號: H04N7/18;H04W4/02;H04W4/14
• 代理公司: 濟南信達專利事務所有限公司 37100
• 代理人: 孟峣

1.一種通過通信數據實現人流實時監控的方法，其特征在于, 其實現過程為：

首先采集通信數據，并將通信數據結合網絡資源信息、地理信息，通過數據模型分析出某個區域的人流數量、軌跡、來源、移動速度信息，通信數據包括每個人所攜帶手機與通信網絡之間交互所產生的信令數據、經分數據、BOSS數據；

再將這些有用信息清晰的呈現在視頻監控設備上，供安全管理人員實時監控和引導人流；

該方法基于以下硬件平臺完成人流實時監控，該硬件平臺具體包括：

設置于監控區域指揮中心的視頻監控平臺，視頻監控平臺上呈現監控區域地理信息、監控區域內部人流量以及區域內人流軌跡；

監控區域內人流量采集系統，即通過大數據處理挖掘技術挖掘運營商自有的通信數據和通信設備資源信息，將監控區域內人流數量、流動方向、流動速度、來源分布、年齡結構、行為偏好、駐留時長信息統計出來；

監控區域內人流量預警系統，通過設置預警規則，對達到預警閥值的區域內人員自動發送預警信息；

人流量采集系統順序通過Kafka、Storm、Codis數據實時處理組件對海量數據進行實時處理，完成人流量采集，其中kafka為實時通信數據隊列；storm用于實時數據處理；codis用于數據處理、內存存儲；

人流量采集系統通過人流量算法實現人流量采集，該人流量算法基于客戶行為軌跡信息表計算，當統計時段內存在部分沉默客戶時，對于這部分客戶取最近的位置記錄作為客戶當前的位置記錄；

人流量算法的內容為：

一、取客戶行為軌跡信息表當前統計時段的客戶軌跡記錄集合,即：取當前統計時段Tn和上個統計時段Tn-1的客戶行為軌跡表的客戶記錄集合；

二、對于未出現在當前統計時段的客戶位置記錄，取上個統計時段的客戶位置記錄回填，在回填過程中剔除長時間未產生位置記錄的客戶記錄，即：

取出現在Tn-1，未出現在Tn的客戶記錄，記為Recordi；

當前時間內客戶Recordi的事件觸發事件＜100分鐘，是則進入下一步，否則返回上一步；

將客戶記錄Recordi回填到當前區域客戶記錄集合Tn中；

當記錄遍歷結束時，沒有滿足條件的記錄，則取Tn的客戶記錄數作為當前時段的實時人流量。

2.根據權利要求1所述的一種通過通信數據實現人流實時監控的方法，其特征在于,對通信數據的采集通過SDTP方式實時采集，該SDTP方式用于實時通信數據接收、清洗。

3.根據權利要求1所述的一種通過通信數據實現人流實時監控的方法，其特征在于,所述視頻監控平臺的后臺將接收到的通信數據進行大數據計算，根據數據模型在GIS地圖上生成實時人流信息，然后將這些信息傳遞到視頻接入設備，完成視頻展示。

4.根據權利要求1所述的一種通過通信數據實現人流實時監控的方法，其特征在于,所述Kafka通過Hadoop的并行加載機制來統一線上和離線的消息處理，通過集群來提供實時的消費，是一種高吞吐量的分布式發布訂閱消息系統，用于處理消費者規模的網站中的所有動作流數據，這里的動作流是指包括網頁瀏覽、搜索的行動，這些數據是由于吞吐量的要求而通過處理日志和日志聚合來解決。

5.根據權利要求1所述的一種通過通信數據實現人流實時監控的方法，其特征在于,所述Storm為分布式實時計算提供了一組通用原語，該數據實時處理組件應用于以下三種情況中：

用于流處理之中，實時處理消息并更新數據庫；

用于連續計算，對數據流做連續查詢，在計算時就將結果以流的形式輸出給用戶；

用于分布式RPC，以并行的方式運行運算。