一种基于Flink的审计日志规则匹配方法及系统

发明专利有效专利

申请号：
CN202211140178.7
IPC分类号：G06F11/30;G06F16/2458
申请日期：
2022-09-20
申请人：
北京中安星云软件技术有限公司

基础信息

权利要求

说明书

PDF全文

法律信息

引证文献

著录项信息

专利名称	一种基于Flink的审计日志规则匹配方法及系统
申请号	CN202211140178.7	申请日期	2022-09-20
法律状态	实质审查	申报国家	中国
公开/公告日	2022-10-21	公开/公告号	CN115221010A
优先权	暂无	优先权号	暂无
主分类号	G06F11/30 ? IPC结构图谱： G 物理 G0 仪器 G06 计算；推算；计数 G06F 电数字数据处理（基于特定计算模型的计算机系统入G06N） G06F11/00 错误检测；错误校正；监控（在基于记录载体和传感器之间的相对运动而实现的信息存储中的错误检测、校正或监控所用的方法或装置入 G11B 20/18；监控，即，监控记录或重现的进程入G11B 27/36；静态存储中所用的方法或装置入G11C29/00）〔1，4，2006.01〕 G06F11/30 监控〔3〕	IPC分类号	G;0;6;F;1;1;/;3;0;;;G;0;6;F;1;6;/;2;4;5;8查看分类表>
申请人	北京中安星云软件技术有限公司	申请人地址	北京市海淀区创业路8号5号楼4层5-6-401 变更专利地址、主体等相关变化，请及时变更，防止失效
权利人	北京中安星云软件技术有限公司	当前权利人	北京中安星云软件技术有限公司
发明人	唐更新;张家荧;宋辉;赵卫国
代理机构	成都鱼爪智云知识产权代理有限公司	代理人	杨洪婷

摘要

本发明提出了一种基于Flink的审计日志规则匹配方法及系统，涉及计算通信技术领域。通过Flink处理引擎获取规则数据并将其加载到预置的DAG模型工厂中以生成该规则对应的DAG模型，然后进行拓扑排序生成拓扑结果，并将所有规则对应的拓扑结果发送给DAG模型调度器，并将Graph对象交付给Flink处理引擎进行广播，最后，执行窗口依次按照Graph对象中绑定的规则对审计日志数据进行匹配得到规则匹配结果发送给DAG模型调度器，并将规则匹配结果发送到下游组件中。本方法可实现用户自定义规则的动态加载，提高数据处理并行度，集群整体数据处理吞吐量高，并且接口封装简单，二次开发和功能迭代更为方便。

序号	公开(公告)号	公开(公告)日	申请日	专利名称	申请人
该专利没有引用任何外部专利数据！

序号	公开(公告)号	公开(公告)日	申请日	专利名称	申请人
该专利没有被任何外部专利所引用！

我浏览过的专利

专利服务由北京酷爱智慧知识产权代理公司提供