[发明专利]一种分布式跟踪系统的实时数据分析引擎

摘要

本发明公开了一种分布式跟踪系统的实时数据分析引擎，包括数据处理模块及与数据处理模块连接的数据采集模块和数据分析模块，所述的数据采集模块和数据处理模块通过数据接收模块连接，数据接收模块和数据处理模块之间采用Kafka集群作为中间层，所述Kafka与数据接收模块中的数据接收节点之间采用异步传输方式，Kafka统计特定时间间隔内每个URL的访问的响应时间，数据处理模块采用基于时间窗口的数据预聚合，通过比较响应时间对应的字段，进行数据聚合，并将新数据添加到聚合的结果中，数据预聚合的结果存储在Redis缓存中，提取数据汇总结果并存储，同时删除Redis缓存中的数据。