一种基于卡口数据的行车规律分析系统和方法

摘要

本发明公开了一种基于卡口数据的行车规律分析系统和方法，所述系统包括：kafka服务器、kudu数据库，NiFi数据处理与分发系统，和spark服务器技术系统，其中，kafka服务器用于获取和存储卡口数据流；NiFi数据处理与分发系统通过consumerKafka组件从kafka服务器获取卡口数据流，通过putkudu组件将卡口数据流发送到kudu数据库；spark服务器技术系统从kudu数据库获取卡口数据，基于所述卡口数据对指定车辆执行行车规律分析。本发明将kafka服务器、Nifi、kudu数据库和spark相结合，从行车数据的存储、传输、检索和分析等方面都具有明显改善。