构建实时数据可视化监控的全栈实现(Kafka+Spark+TimescaleDB+Flask+Node.js)

由于项目需求，须要构建一个实时的数据监控系统，把平台上报的业务数据以1分钟的粒度进行呈现。为此我构建了如下的一个架构来实现。javascript 平台上报的业务数据会实时的发送消息给Kafka，例如平台每次为车辆进行OTA升级时，会发送一个OTA业务请求的事件，一个OTA业务完成或失败的事件。这些事件会发送到Kafka，而后Spark Streaming会进行实时的数据处理并保存到时序数据库。前端

>>阅读原文<<