基于云边协同的实时数据处理系统和方法

本申请提供了一种基于云边协同的实时数据处理系统和方法，系统包括：数据采集层，用于通过多协议栈配置支持多种数据源接入；基于轻量级消息传输协议实时采集数据；对采集到的数据进行标准化处理；数据处理层，用于基于预设规则引擎，对标准化处理后的数据，进行数据分层处理与转换，得到待处理数据；实时监测层，基于Kappa架构和Flink流处理引擎，结合深度学习算法和时间序列分析技术，根据所述待处理数据，确定是否存在异常情况并生成监测报告。本申请能解决现有技术容易出现网络拥塞、处理延迟高等问题。