[发明专利]一种公交乘客实时分析系统及其构建方法

摘要

本发明公开了公交乘客实时分析系统的构建方法，基于Spark云计算平台，结合对公交双向刷卡乘客历史数据分析，按照数据处理规则对历史公交数据进行预处理分析；利用乘客双向上车行为历史数据得到乘客各站点下车行为，从而利用统计学习方法构建各线路公交乘客上下车站点分布；生成利用乘客上车行为而得到各区间乘客密度的数据分析计算方法；利用Spark进行实时公交数据预处理，并通过公交停车记录动态生成公交站点列表；通过Spark Streaming技术实现了后台数据处理结果向前台的实时反馈，并通过Redis实现动态公交数据高速数据库读写操作；通过历史数据分析结果进行的实时公交数据分析与乘客密度计算方法。

主权项

一种公交乘客实时分析系统的构建方法，包括如下步骤：步骤一、公交站点自动生成；步骤二、上车站点匹配；步骤三、公交乘客下车站点推算；其中步骤二具体为：基于Map Reduce的公交车辆到站时间与乘客上下车时间匹配，利用K‑Means对乘客上下车刷卡情况进行聚类，找出乘客上下车集中点并与公交各站点到达时间进行匹配并计算出每台公交车辆时间记录仪及公交非接触式读卡器时间的差异；根据时间差异性及K‑Means乘客上车聚类，依据上车站点时间划分标准对乘客上车站点进行划分。