(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211218907.6 (22)申请日 2022.10.07 (71)申请人 北京中安星云软件技 术有限公司 地址 100000 北京市海淀区创业路8号5号 楼4层5-6-401 (72)发明人 唐更新　李希伟　宋辉　赵卫国　 (74)专利代理 机构 成都鱼爪智云知识产权代理 有限公司 513 08 专利代理师 刘爱平 (51)Int.Cl. G06F 16/18(2019.01) G06F 16/174(2019.01) G06K 9/62(2022.01) G06F 40/205(2020.01) G06Q 10/06(2012.01) (54)发明名称 一种基于flink流式处理的SOM数据库动态 风险感知的实现方法 (57)摘要 本发明提出了一种基于flink流式处理的 SOM数据库动态风险感知的实现方法， 涉及数据 库技术领域。 该方法包括： 获取sql请求报文数 据， 并对sql请求报文数据进行解析， 以抽取数据 库访问相关日志， 同时对数据库访问相关日志进 行压缩存放。 利用Java程序对压缩存放的数据库 访问相关日志解析后， 放入kafka。 利用flink流 式处理从kafka中抽取多个访 问数据组， 并对各 个访问数据组进行计算， 得到各种维度的访问 值。 将所有访问值发送至SOM模型中进行分类， 得 到分类结果。 根据分类结果， 调用对应的告警或 者拦截操作。 通过SOM模型接收flink计算完成的 数据， 同时映射最新分类结果， 并迅速生成处置 方案进行风险处 理。 权利要求书2页 说明书9页 附图3页 CN 115510014 A 2022.12.23 CN 115510014 A 1.一种基于flink流式处理的SOM数据库动态风 险感知的实现方法， 其特征在于， 包括 如下步骤： 获取sql请求报文数据， 并对所述sql请求报文数据进行解析， 以抽取数据库访问相 关 日志， 同时对所述数据库访问相关日志进行压缩 存放； 利用Java程序对压缩 存放的数据库访问相关日志解析后， 放入kafka； 利用flink流式处理从kafka中抽 取多个访问数据组， 并对各个访问数据组进行计算， 得到各种维度的访问值， 其中， 任一访问数据组包 含至少一个访问数据； 将所有访问值发送至SOM模型中进行分类， 得到分类结果； 根据所述分类结果， 调用对应的告警或者 拦截操作。 2.根据权利要求1所述的基于flink流式处理的SOM数据库动态风 险感知的实现方法， 其特征在于， 所述 获取sql请求报文数据， 并对 所述sql请求报文 数据进行解析， 以抽取数据 库访问相关日志， 同时对所述数据库访问相关日志进行压缩 存放的步骤 包括： 对所述sql请求报文数据进行分析， 根据sql协议确定待解析sql报文； 基于sql协议， 对所述待解析sql报文 进行解析， 得到解析后的数据库访问相关日志； 按照字节码的方式， 对所述数据库访问相关日志进行压缩 存放。 3.根据权利要求1所述的基于flink流式处理的SOM数据库动态风 险感知的实现方法， 其特征在于， 所述利用flink流式处理从kafka中抽取多个访问数据组， 并对各个访问数据 组进行计算， 得到各种维度的访问值的步骤 包括： 从kafka中抽取一个访问数据组， 利用flink框架的内置函数计算该访问数据组对应的 各种维度的访问值； 利用flink的滑动窗口， 按照预设间隔时间再次从kafka中抽取访问数据组， 以计算预 设时间段内的各种维度的访问值。 4.根据权利要求1所述的基于flink流式处理的SOM数据库动态风 险感知的实现方法， 其特征在于， 所述从kafka中抽取一个访问数据组， 利用flink框架的内置函数计算该访问 数据组对应的各种维度的访问值的步骤 包括： 基于checkpoint机制， 存放该访问数据组对应的各种维度的访问值后， 再 次从kafka中 抽取访问数据组。 5.根据权利要求3所述的基于flink流式处理的SOM数据库动态风 险感知的实现方法， 其特征在于， 所述fl ink框架的内置函数至少包括count函数和sum函数中的一种或多种。 6.根据权利要求1所述的基于flink流式处理的SOM数据库动态风 险感知的实现方法， 其特征在于， 所述利用fl ink流式处理从kafka 中抽取多个访问数据组的步骤 包括： flink通过拆分的方式从kafka 中抽取访问数据组。 7.根据权利要求1所述的基于flink流式处理的SOM数据库动态风 险感知的实现方法， 其特征在于， 对所述数据库访问相关日志进行压缩 存放的步骤 包括： 将所述数据库访问相关日志压缩放入预置文件中， 当所述预置文件的大小达到预设大 小时， 重新创建一个新的文件。 8.根据权利要求1所述的基于flink流式处理的SOM数据库动态风 险感知的实现方法， 其特征在于， 所述访问值至少包括select请求数量、 update请求数量、 alter请求数量、 insert请求数量、 delete请求数量、 每一个客户端mac地址的sql请求数量和每一个客户端权　利　要　求　书 1/2 页 2 CN 115510014 A 2ip的请求数量中的一种或多种。 9.一种电子设备， 其特 征在于， 包括： 存储器， 用于存 储一个或多个程序； 处理器； 当所述一个或多个程序被所述处理器执行时， 实现如权利要求1 ‑8中任一项所述的方 法。 10.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 该计算机程序被 处理器执行时实现如权利要求1 ‑8中任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 115510014 A 3