(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210551366.2 (22)申请日 2022.05.18 (71)申请人 建信金融科技有限责任公司 地址 200120 上海市浦东 新区中国(上海) 自由贸易试验区银城路99号12层、 15 层 (72)发明人 邱耿峰　陈青山　崔庆文　郑晓华　 许国良　 (74)专利代理 机构 北京品源专利代理有限公司 11332 专利代理师 王风茹 (51)Int.Cl. G06F 11/07(2006.01) G06F 16/2455(2019.01) (54)发明名称 一种流数据处 理方法、 装置及设备 (57)摘要 本发明实施例涉及数据处理技术领域， 公开 了一种流数据处理方法、 装置及设备， 方法包括 抓取实时流数据； 利用滚动时间窗口从所述实时 流数据中提取目标流数据； 基于滑动时间窗口判 断所述目标流数据中的顺序事件的事件发生序 列是否存在异常。 本申请通过同时使用滚动时间 窗口和滑动时间窗口对实时流数据中的目标流 数据中是否存在事件发生序列异常进行判断， 只 使用一种 时间窗口对流数据中特定事件的响应 情况进行检测所导致的检测结果准确率较低以 及时效性较差的技术问题， 实现了提高流数据中 特定事件的响应情况的检测准确率， 以及提升检 测时效性的技 术效果。 权利要求书2页 说明书8页 附图3页 CN 114968638 A 2022.08.30 CN 114968638 A 1.一种流数据处 理方法， 其特 征在于， 所述 流数据处 理方法包括： 抓取实时流数据； 利用滚动 时间窗口从所述实时流数据中提取目标流数据， 其中， 所述滚动 时间窗口为 相邻的两个时间窗口是连续且无重叠的时间窗口， 所述目标流数据为所述实时流数据中依 照事件发生序列所抓取的至少两个间隔时间最短的顺序事 件； 基于滑动时间窗口判断所述目标流数据中的顺序事件的事件发生序列 是否存在异常， 其中， 所述滑动时间窗口为相邻的两个时间窗口之间存在重叠的时间窗口， 所述滑动时间 窗口的窗口长度大于所述滑动时间窗口 的滑动长度。 2.根据权利要求1所述的流数据处理方法， 其特征在于， 所述利用滚动时间窗口从所述 实时流数据中提取目标流数据包括： 提取每一个所述滚动时间窗口中出现时间最大的第一事 件； 提取每一个所述滚动 时间窗口中距离所述第一事件发生时间最短的第二事件， 其中， 所述第一事 件先于所述第二事 件发生， 所述第一事 件和所述第二事 件为所述目标流数据。 3.根据权利要求2所述的流数据处 理方法， 其特 征在于， 所述 流数据处 理方法还 包括： 若在一个所述滚动时间窗口之内不存在所述第 二事件， 则确定所述第 二事件的发生出 现异常， 执 行预警提示动作。 4.根据权利要求2所述的流数据处理方法， 其特征在于， 所述基于滑动时间窗口判断所 述目标流数据中的顺序事 件的事件发生序列是否存在异常包括： 基于所述滑动时间窗口确定所述目标流数据的发生时间落入所述滑动 时间窗口的位 置， 得到位置信息； 基于所述 位置信息确定所述目标流数据中的顺序事 件的事件发生序列是否存在异常。 5.根据权利要求4所述的流数据处理方法， 其特征在于， 所述基于所述位置信 息确定所 述目标流数据中的顺序事 件的事件发生序列是否存在异常包括： 若所述第一事件落入第 一滑动时间窗口内， 所述第 二事件落入第 一滑动时间窗口与第 二滑动时间窗口的重叠位置处， 则计算所述第一事件与所述第二事件的第一间隔时长， 其 中， 所述第一滑动时间窗口先于所述第二滑动时间窗口； 将所述第一间隔时长与预设间隔时长进行对比， 确定所述第 一事件与 所述第二事件的 事件发生序列是否存在异常。 6.根据权利要求4所述的流数据处理方法， 其特征在于， 所述基于所述位置信 息确定所 述目标流数据中的顺序事 件的事件发生序列是否存在异常包括： 若所述第一事件落入第 一滑动时间窗口与第 二滑动时间窗口的重叠位置处， 所述第 二 事件落入第二滑动时间窗口内， 则计算所述第一事件与所述第二事件的第一间隔时长， 其 中， 所述第一滑动时间窗口先于所述第二滑动时间窗口； 将所述第一间隔时长与预设间隔时长进行对比， 确定所述第 一事件与 所述第二事件的 事件发生序列是否存在异常。 7.根据权利要求4所述的流数据处理方法， 其特征在于， 所述基于所述位置信 息确定所 述目标流数据中的顺序事 件的事件发生序列是否存在异常包括： 若所述第一事件落入第 一滑动时间窗口与第 二滑动时间窗口的重叠位置处， 所述第 二 事件未落入第二滑动时间窗口内， 则确定所述第一事件与所述第二事件的事件发生序列存权　利　要　求　书 1/2 页 2 CN 114968638 A 2在异常， 其中， 所述第一滑动时间窗口先于所述第二滑动时间窗口。 8.根据权利要求1所述的流数据处 理方法， 其特 征在于， 所述 流数据处 理方法还 包括： 若判断出所述目标流数据中的顺序时间的事件发生序列 是否存在异常， 则执行预警提 示动作。 9.一种流数据处理系统， 其特征在于， 所述流数据处理系统基于结构化查询语言数据 库执行相应的动作， 所述 流数据处 理系统包括： 流数据抓取 单元， 用于抓取实时流数据； 流数据提取单元， 用于利用滚动时间窗口从所述实时流数据中提取目标流数据， 其中， 所述滚动时间窗口为相邻的两个时间窗口是连续且无重叠的时间窗口， 所述目标流数据为 所述实时流数据中依照事 件发生序列所抓取的至少两个间隔时间最短的顺序事 件； 流数据异常判断单元， 用于基于滑动时间窗口判断所述目标流数据中的顺序事件的事 件发生序列是否存在异常， 其中， 所述滑动时间窗口为相邻的两个时间窗口之间存在重叠 的时间窗口， 所述滑动时间窗口 的窗口长度大于所述滑动时间窗口 的滑动长度。 10.一种流数据处 理设备， 其特 征在于， 所述 流数据处 理设备包括： 一个或多个处 理器； 存储装置， 用于存 储一个或多个程序； 当所述一个或多个程序被所述一个或多个处理器执行， 使得所述一个或多个处理器实 现如权利要求1 ‑8任一所述的流数据处 理方法。 11.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 该程序被处理器 执行时实现如权利要求1 ‑8任一所述的流数据处 理方法。 12.一种计算机程序产品， 包括计算机程序， 所述计算机程序在被处理器执行时实现根 据权利要求1 ‑8中任一项所述的流数据处 理方法。权　利　要　求　书 2/2 页 3 CN 114968638 A 3