[發明專利]一種基于游客移動信令數據的景區實時動態客流量統計方法

在審

• 申請號: 201710190179.5
• 申請日: 2017-03-27
• 公開（公告）號: CN106970976A
• 公開（公告）日: 2017-07-21
• 發明（設計）人: 陳粵龍;陳敏俊;溫亮生;張治中;趙瑞莉
• 申請（專利權）人: 重慶郵電大學;中移（杭州）信息技術有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30;H04W4/02;H04W8/02
• 代理公司: 北京同恒源知識產權代理有限公司11275
• 代理人: 趙榮之

技術領域

本發明屬于通信技術領域，特別是移動互聯網及計算機通信領域，涉及一種基于游客移動信令數據的景區實時動態客流量統計方法。

背景技術

近年來，以云計算、物聯網、移動通信等為代表的新一代信息技術取得了重大突破，開始廣泛應用于各行各業。物聯網技術突破了互聯網的“線上”局限，把虛擬世界與現實世界聯成一體；移動通信技術實現了實時數據在系統之間、遠程設備之間的無線連接，為無處不在的全程服務提供了條件；云計算解決了互聯網發展所帶來的巨量數據存儲與處理問題。這些技術的普及和應用，為旅游信息化的發展提供了有力支撐，將人類社會帶入了一個以“PB”(1024TB)為單位的新階段，大數據時代應運而生。大數據不僅更新了旅游信息化所需的技術，更從觀念和思維上革新了人類的認識，實現思維、商業、管理上的變革。

隨著中國經濟的發展，人們收入的增長以及對生活品質的追求，旅游業在國內發展得很快，得到了國家的大力支持，旅游業進入爆發性的增長階段，成為新的支柱產業。旅游已經成為人們生活方式的重要組成部分，但與此同時引發了一些景區管理的安全隱患，景區超流量接待游客已不是罕見現象。2015年跨年夜上海發生的踩踏事件，暴露出了我國在大量游客管理方面能力的匱乏。事后國家旅游局對景區安全管理更加嚴格，尤其是在景區客流量控制上。因此，無論是從國家還是旅游局層面來講，景區需要一套針對景區游客的安全監控方案。

傳統的景區動態客流量統計方法在實時性方面體現的比較差，統計景區客流量是通過從傳統的數據庫中分析提取。而傳統數據庫具有效率不夠高、可讀性不高、數據時間性不足等缺點，導致分析傳統數據庫中的海量游客信令數據會造成查詢速度特別慢、統計速度特別慢等缺點。所以傳統數據庫不適合用于存儲分析海量數據，不利于應對短時間內因游客劇增導致擁堵、踩踏等引發的安全事故。

Flume是一個分布式、可靠、和高可用的海量日志聚合的系統，支持在日志系統中定制各類數據發送方，用于收集數據；同時，Flume提供對數據進行簡單處理，并寫到各種數據接受方(可定制)的能力。

Kafka是一種高吞吐量的分布式發布訂閱消息系統，它可以處理消費者規模的網站中的所有動作流數據。Kafka可實時記錄從數據采集工具Flume中收集的數據，并作為消息緩沖組件為上游實時計算框架提供可靠數據支撐。

Spark是一個分布式的內存計算框架，其特點是能處理大規模數據，計算速度快。Spark需要集成Hadoop的分布式文件系統才能運作，它延續了Hadoop的MapReduce計算模型，相比之下Spark的計算過程保持在內存中，減少了硬盤讀寫，能夠將多個操作進行合并后計算，因此提升了計算速度。Spark必須搭在Hadoop集群上，它的數據來源是HDFS，本質上是Yarn上的一個計算框架，像MapReduce一樣。Spark核心部分分為RDD。Spark SQL、Spark Streaming、MLlib、GraphX、SparkR等核心組件解決了很多的大數據問題，其完美的框架日受歡迎。其相應的生態環境包括zepplin等可視化方面，正日益壯大。Spark讀寫過程不像Hadoop溢出寫入磁盤，都是基于內存，因此速度很快。另外DAG作業調度系統的寬窄依賴讓Spark速度提高。

本方法采用快速的海量數據處理框架和相應的分析算法實時監控景區內的客流情況，以便景區和當地人民政府能及時采取疏導、分流等措施，從而達到景區安全管理的目的。

發明內容

有鑒于此，本發明的目的在于提供一種基于游客移動信令數據的景區實時動態客流量統計方法，該方法針對傳統的景區動態客流量統計方法在實時性方面體現的比較差、海量數據不適合存儲在傳統數據庫中進行分析等問題，通過實時監控景區內的客流量，有助于應對短時間內景區游客劇增情況，便于景區和當地政府及時采取疏導、分流等措施，從而達到景區安全管理的目的，同時更大程度地提升游客對景區的體驗度。

為達到上述目的，本發明提供如下技術方案：

一種基于游客移動信令數據的景區實時動態客流量統計方法，該方法包括以下步驟：

S1：LTE-A空口監測儀實時采集景區內游客的信令數據，并將數據保存至遠程文件中，以一分鐘的時間粒度保存一個信令數據文件；

S2：通過Flume組件監測遠程文件是否有文件更新，若有更新，將文件逐條記錄收集；