基于时间切片进行事件统计的方法及装置

摘要

本发明提供一种基于具有多个时间切片的循环时间窗进行事件统计的方法，包括：在预定时间段内，从外部获取事件并放入事件队列中；针对从事件队列中取出的每个事件，遍历循环时间窗中的头指针指向的时间切片到尾指针指向的时间切片进行清空处理；基于当前取出事件的事件发生时间和经过处理后的由尾指针指向的时间切片的时间之间的时间差，确定将该事件统计在该时间切片或下一时间切片中，其中，在遍历时，如果当前取回事件的事件发生时间与各时间切片中的任一时间切片的时间之差超过时间窗大小，则清空该时间切片。利用本方法，可以在短时间内，在网络中的海量事件中挖掘是否有存在满足发生频率的事件，并且所占用的存储空间很小，速度快，效率高。

主权项

一种基于具有多个时间切片的循环时间窗进行事件统计的方法，包括：创建具有多个时间切片的循环时间窗；其中，所述循环时间窗具有用于指向时间切片的头指针和尾指针，所述头指针指向的时间切片是指第一个统计有事件的时间切片，所述尾指针指向的时间切片是指最后一个统计有事件的时间切片；在预定时间段内，从外部获取事件并放入到事件队列中，其中，所述事件至少包含事件数量信息和事件发生时间信息；按照所述事件队列中的事件的先后顺序，从所述事件队列中逐个取出事件；针对每个从所述事件队列中取出的事件，遍历所述循环时间窗中的头指针指向的时间切片到尾指针指向的时间切片，如果当前取出的事件的事件发生时间与各时间切片中的任一时间切片的时间之差大于或等于所述循环时间窗大小，则清空该时间切片，同时，如果头指针和尾指针不指向同一个时间切片，则将头指针指向至该时间切片的下一时间切片，否则保持指针位置不变，其中，所述时间切片至少包括时间信息和数量信息，所述时间切片的时间是在该时间切片中统计的第一个事件的事件发生时间，所述时间切片的数量是在该时间切片中统计的事件的数量，所述头指针指向的时间切片是指第一个统计有事件的时间切片，所述尾指针指向的时间切片是指最后一个统计有事件的时间切片；以及计算该当前取出的事件的事件发生时间和经过遍历处理后的各时间切片中的由所述循环时间窗的尾指针指向的时间切片的时间之间的时间差；在所计算出的时间差不大于该时间切片的大小时，将该当前取出的事件统计在由所述循环时间窗的尾指针指向的时间切片中并将该当前取出的事件的数量与该时间切片的数量合并作为该时间切片的数量信息，以及在所计算出的时间差大于该时间切片的大小时，将该当前取出的事 件统计在由所述循环时间窗的尾指针指向的下一时间切片中并将该当前取出的事件的事件数量信息和事件发生时间信息作为该下一时间切片的数量信息和时间信息，同时将尾指针移动到指向该下一时间切片。