架构图

kafka

业务系统

DATA PRETREATMENT数据预处理：修正，抛弃，或者直接生成结果

三急处理器ThreeEmergentHandler

redis

三急事件

疲劳事件

吐出事件

MySql

...处理器xxxHandler

计算结果实例化

TerminalContext1、行程信息2、三急信息3、疲劳信息4、...

sparkstream

spark流式平台

业务查询

XX事件

行程计算处理器TripHandler

mongo

点火、行程、里程报告..

数据存储层

事件订阅

数据源

疲劳处理器TiredHandler

驾驶事件