复杂事件处理

摘要： 复杂事件处理技术通常基于有限状态自动机实现,匹配过程中会在事件流上产生大量且重叠的部分匹配,有限状态自动机需维护大量的重复匹配状态,导致基于该技术的方法都会出现冗余计算的问题。为了提高复杂事件处理的匹配效率,提出了使用复杂事件实例覆盖技术来实现复杂事件处理的方法。通过设计临时匹配链式分区存储结构以及基于此结构的匹配算法来利用复杂事件实例覆盖减少冗余计算,从而实现匹配效率的提升。在模拟数据集和真实数据集上进行了实验测试与分析,与两种常用的复杂事件处理技术进行比较。实验表明,提出方法能够在保证匹配正确性的同时有效地减少匹配过程中的冗余计算,提高整体匹配效率。

摘要： 通过对铁路数据基础设施运维管理现状的阐述,结合国内铁路运营管理的实际情况,提出符合国情和行情的铁路数据中心基础设施运维管理(Data Center Intrastructure Operation Management,DCIOM)系统整体架构.多技术的融合共同构建DCIOM,并在铁路领域试点应用,探索铁路数据中心基础设施运维管理的最佳路径.最后对铁路行业DCIOM发展进行展望,DCIOM、智能化运维平台、智能运维机器人即将成为铁路行业IT基础设施运维的研究和投资热点.

摘要： 复杂事件处理是一种基于动态环境中事件流的分析技术。复杂事件处理需要定义复杂的规则,并且随着业务的变化,规则也会频繁变化。为了应对规则的变化,衍生出了众多的规则引擎框架,使得规则的变化可以动态配置,无需修改软件系统就可以满足业务需求。文章详细介绍了规则引擎的发展,并结合主流的规则引擎产品,包括Drools、Esper、SEC、NodeBrain,分析各规则引擎的核心技术与特性,最后通过性能评估方案对上述规则引擎进行性能评估。复杂事件处理应用服务于网络安全、金融、风控等众多行业,开发复杂事件处理应用的挑战之一就是为业务系统选择正确的规则引擎框架。本文从技术框架、性能等方面对主流规则引擎进行对比分析,旨在帮助开发人员快速选择合适的规则引擎框架。

摘要： 空气质量与每个人的生活都息息相关,搭建空气指标监测告警系统对于掌握实时数据指标,加强空气保护意识具有一定的作用。本文深入调研空气污染的严峻形势,针对重点监测的主要污染物 PM2.5,PM10,SO2等,使用流数据框架和复杂事件处理机制对异常指标数据进行分析监测,最终搭建基于 Spring Boot的 JavaWeb空气指标监测告警平台,支持常规数据的可视化界面展示和异常指标的告警提示。

摘要： 对传感器产生的语义数据流执行复杂推理的能力,最近已成为语义网社区中的重要研究领域,而目前大多数RDF流处理系统是以SPARQL (W3C标准RDF查询语言)为基础实现的,但这些引擎在捕获复杂的用户需求和处理复杂的推理任务方面存在局限性.针对此问题,本文结合并扩展了回答集编程(Answer Set Programing,ASP)技术用于对RDF流进行连续的处理.为了验证本方法的有效性,首先以智能家居本体为实验对象,并分析传感器设备间的共有特性及复杂事件以构建本体库;然后基于本体库产生实例对象,并通过中间件产生RDF数据流;接下来通过扩展ASP,充分利用其表达和推理能力以减少推理时间,并设计了RDF流的窗口划分策略等,然后根据用户的请求,选择性地进行静态知识库加载等;最后通过实验与Sparkwave和Laser进行对比,证明了该方法在延迟和内存上的性能优势.

摘要： 实时数据云平台是将分布式技术应用在实时数据库上,能够根据接入点的数量实现采集、存储和调用性能的“弹性”扩展,对于具有时序特征的数据具有实时的事务处理能力.新疆油田公司石西油田作业区通过引入实时数据云平台,解决了全厂参数采集的效率问题,使原有电台通讯的数据采集性能提高3-5倍,实现数据集中长期存储,为全厂生产监控、复杂事件处理(CEP)提供了高效数据调用接口,有效满足了整厂生产监控分析的需要.

摘要： 电子对抗态势情报数据以参数描述为主,数据可读性较差且电磁态势判读自动化程度较低.提出一种基于复杂事件处理(CEP)的电子对抗事件情报处理方法,该方法通过先验知识建模和事件情报处理产生电子对抗事件情报,实现电子对抗情报从数据到认知的提升和电磁态势自动高速判读.主要讨论电子对抗事件模型、事件情报处理框架、事件情报数据总线,并通过场景仿真验证该方法的有效性.

摘要： 随着数据时代的到来,各种设备所产生的数据量呈指数级增长,获取隐藏在数据中的重要信息显得愈发重要.通过复杂事件处理对数据进行过滤和组合,可以获得真正重要的信息,并使用它来支持决策,改进业务流程等.Esper是一种开源的复杂事件处理引擎,本文首先介绍Esper,然后通过实验验证Esper的性能,希望能为相关企业和相关工作者提供些许参考.

摘要： 传统的复杂事件处理都是基于时间戳上的有序性,而在实际场景中事件流往往不是有序的.对于事件流乱序问题的解决通常是在它们进入模式匹配之前就将其有序化,但是通常这种算法的效率不高且并没有对乱序时的非事件进行处理.本文采用HASH链表对中间结果进行缓存并通过0CEPM算法来调整乱序事件流以输出最终的复杂事件,然后阐述了如何判断乱序事件流下非事件是未发生还是未到达,最后通过智能交通下左转闯红灯这一案例场景证明了OCEPM算法的有效性.

摘要： 本文针对智能用电服务系统多数据源信息实时处理困难的现状,引入复杂事件处理技术,提出了基于复杂事件处理技术的智能用电服务系统多数据源信息实时处理方法.首先分析了电力系统多数据源信息的特点,提出了电力系统事件的基本格式;其次在对多种电力系统事件格式分析的基础上,提出了基于XML的电力系统事件格式的制定和生成方法;然后引入复杂事件处理技术,提出了电力系统复杂事件的处理和生成方法;最后结合面向服务的思想,提出了基于复杂事件处理技术和面向服务思想的智能用电服务系统多数据源信息实时处理的系统架构和解决方案.

摘要： 无线射频识别技术RFID有着重要的应用背景。设计并实现了一个面向无线射频识别应用的复杂事件处理系统REvent，构建了一个仿真环境并在此基础上测试Revent系统的数据预处理与事件检测等功能。对系统框架、关键技术和主要演示过程进行了说明。

摘要： 近年来,随着传感器网络和RFID技术的发展,基于数据流的应用已经无所不在.数据流上的应用大多是监控型的,并且这些监控任务一般是简单事件的组合,但简单的数据流处理系统(DSMS)一般只能处理简单事件的过滤和聚合,缺乏复杂事件概念的支持,因此需要构建数据流上的复杂事件处理系统(CEP)来满足这类需求.本文将介绍基于数据流处理系统Argus的复杂事件处理系统Eagle的设计与实现.我们提出了事件代数来描述复杂事件,并基于此事件代数提出了复杂事件查询语言.我们使用基于查询计划的方式来进行事件探测,并采用了一些优化策略来提高复杂事件探测的效率。

摘要： 随着复杂事件处理(CEP)技术的发展,复杂事件处理技术已经在多个领域中得到了应用,例如供应链管理和智能跟踪与监控.由于嵌套查询能够满足这些应用领域里更高层次的需求,因此是CEP研究的关键问题之一,得到了广泛关注.但是,已有嵌套查询的对象都是发生时间确定的事件,并未考虑现实应用中事件的发生时间是未知的或是不精确的,而这种情况下通常需要概率的方法来表示事件的时间.因此本文旨在解决发生时可不确定事件流上的嵌套查询问题.首先,针对基于可能世界的基本处理方法存在的低效问题,本文提出了一种基于迭代的处理方法;进一步,在迭代处理方法的基础上,提出基于子查询长度的剪枝优化技术和基于共享子表达式的缓存优化技术,特别的,基于缓存优化技术提出了查询结果发生概率计算的剪枝方法;最后,通过实验验证了本文提出方法可有效地进行发生时可不确定事件流上的嵌套查询,并能够通过对方法的优化有效地降低处理代价,提高查询处理效率.

摘要： 复杂事件处理是支持大数据处理的流式计算平台的核心技术之一.CEStream语言作为一种新型的事件流处理语言,支持分布式环境下的复杂事件处理.该语言以XML等层次化数据作为数据模型,为复杂事件检测提供了一种正规树模式匹配功能,支持结构连接和正规式匹配.同时,针对分布式的多个事件流,能够将各个事件源模式匹配的结果按照时间顺序再一次进行正规式模式匹配,满足多源组合型复杂事件的检测需求,具有较强的事件处理能力.为了实现CEStream语言,研制了一个基于流数据处理集群和远端查询代理的执行引擎系统.该系统通过远程查询代理实现基于正规树模式的事件检测,通过流处理集群完成多源组合型复杂事件处理.实验表明该系统实现了CEStream语言,有效地限制了各个节点之间的通信量,充分利用集群的计算能力,整体性能能够满足应用需求.

摘要： 由于存在漏读、交叉读以及语义简单的原子事件,RFID系统产生的海量原始数据无法直接融合到企业现有的管理系统中。RFID中间件作为原始数据和上层应用之间的桥梁,有着非常重要的作用。开发了一种RFID数据管理中间件原型系统RFeel。该中间件可以屏蔽异构读写器平台差异、以统一数据格式向上层提供通用接口,包含了交叉读数据仲裁、不确定性数据推导、分布式复杂事件的检测、复杂事件处理优化和聚集查询等核心技术。最后通过一个典型的零售场景演示了RFeel的工作过程。

摘要： 互联网的迅猛发展积累了海量的信息,这为执法部门发现职务犯罪线索、拓展办案途径提供了机遇.但是如何从海量的数据中快速的查找有价值的线索并实时地推荐给执法部门是案件侦查亟需解决的问题.本文分析了职务犯罪类别之间的关系,构建了面向职务犯罪的领域本体,并根据本体中结点之间的语义关系设置事件模式,提出了一种基于并行化复杂事件处理的语义驱动职务犯罪线索实时推荐方法.实验结果表明该方法采用的复杂事件处理技术保证了事件处理的实时性,并行化处理保证了海量数据的处理能力,同时事件模式查询能充分体现术语之间的语义关系,从而显著提高了犯罪线索推荐的准确性.

摘要： 为了准确而及时地检测实时定位应用中的复杂事件,本文提出一种事件驱动的处理RFID数据的框架GEEP(GodEye Event Processor),将RFID应用逻辑设计成复杂事件,基于数据流上的时间图模型,给出了对象与位置之间以及对象与对象之间约束的推导方法,描述了能够有效捕捉并处理复杂RFID事件的检测引擎的设计思想.实验证明本方法极大地简化了RFID数据处理的工作,有效降低了RFID数据处理的代价.

摘要： 为了准确而及时地检测实时定位应用中的复杂事件,本文提出一种事件驱动的处理RFID数据的框架GEEP(GodEye Event Processor),将RFID应用逻辑设计成复杂事件,基于数据流上的时间图模型,给出了对象与位置之间以及对象与对象之间约束的推导方法,描述了能够有效捕捉并处理复杂RFID事件的检测引擎的设计思想.实验证明本方法极大地简化了RFID数据处理的工作,有效降低了RFID数据处理的代价.

摘要： 本发明涉及一种复杂事件处理云平台事件分析引擎容量评估的系统及方法，系统包括事件分析引擎，用以接收来自外部的事件和加载各种事件处理规则；事件源管理模块，用以进行复杂事件处理云平台中事件元数据的管理并提供各个事件类型所对应的事件结构；分析引擎容量评估模块，用以根据所述的事件分析引擎中到达事件量和事件类型以及所述的事件源管理模块中各个事件类型所对应的事件结构进行所述的事件分析引擎的容量评估。采用该种结构的复杂事件处理云平台事件分析引擎容量评估的系统及方法，基于事件吞吐的单节点即单个JVM进程进行容量评估，大大提高了复杂事件处理平台的整体运维水平，方法工作性能稳定可靠，适用范围广泛。

摘要： 本发明公开了属于电能质量监测技术领域中的一种基于复杂事件处理的电能质量扰动事件分类监测方法。包括：提取原始信号的特征值并对提取的特征值进行筛选；根据筛选后的特征值确定原子事件；采用原子事件的组合形式描述复杂事件；确定复杂事件模式；采用复杂事件处理引擎检测复杂事件模式，得到复杂事件模式对应的复杂事件；根据复杂事件与分类输出结果的映射关系，确定复杂事件的分类输出结果。本发明可以对电能质量扰动事件的类型进行有效的分类，更快速、准确地监测出电能质量扰动信号。

摘要： 本发明公开了一种面向实时事件流的复杂事件处理方法，包括如下步骤：1)基于“事件实例覆盖”和“复杂事件实例覆盖”定义，建立查询与事件流的临时匹配之间的关联关系；2)构建临时匹配的链式分区存储结构，将所述结构作为复杂事件实例覆盖的载体，得到匹配结果复杂事件实例覆盖集，其中匹配时，采用复杂事件匹配算法CoverMatch；3)采用CombineMatch算法将所得到的匹配结果进行一个反向的匹配结果联结，最终获取全部匹配结果。本发明采用临时匹配链式分区存储结构则借助事件实例覆盖和复杂事件实例覆盖的概念来设计，规避了集中式临时匹配存储的缺点。

摘要： 本发明涉及一种复杂事件处理云平台事件分析引擎容量评估的系统及方法，系统包括事件分析引擎，用以接收来自外部的事件和加载各种事件处理规则；事件源管理模块，用以进行复杂事件处理云平台中事件元数据的管理并提供各个事件类型所对应的事件结构；分析引擎容量评估模块，用以根据所述的事件分析引擎中到达事件量和事件类型以及所述的事件源管理模块中各个事件类型所对应的事件结构进行所述的事件分析引擎的容量评估。采用该种结构的复杂事件处理云平台事件分析引擎容量评估的系统及方法，基于事件吞吐的单节点即单个JVM进程进行容量评估，大大提高了复杂事件处理平台的整体运维水平，方法工作性能稳定可靠，适用范围广泛。

摘要： 本发明公开了属于电能质量监测技术领域中的一种基于复杂事件处理的电能质量扰动事件分类监测方法。包括：提取原始信号的特征值并对提取的特征值进行筛选；根据筛选后的特征值确定原子事件；采用原子事件的组合形式描述复杂事件；确定复杂事件模式；采用复杂事件处理引擎检测复杂事件模式，得到复杂事件模式对应的复杂事件；根据复杂事件与分类输出结果的映射关系，确定复杂事件的分类输出结果。本发明可以对电能质量扰动事件的类型进行有效的分类，更快速、准确地监测出电能质量扰动信号。

摘要： 本发明涉及在复杂事件处理(CEP)环境中预测事件流的未来行为。对于每个接收的所述事件流中的事件，一个用于显示预先定义的时间范围的参考窗口被更新，在该过程中所述预测被计算，从而使得所述参考窗口以所述接收的事件结束，所述参考窗口随所述事件流移动。在该处理循环内，当一个预测更新策略指出所述预测基于所述接收的事件被更新，则：用于显示时间范围的一个预测窗口被更新，其中事件在该预测窗口中被预测；以及当所述预测窗口的时间段没有被超出，(a)下一个预测事件通过至少一个处理器被生成，以及(b)所述下一个预测事件被插入所述预测窗口；以及所述预测窗口被发布。

摘要： 本发明提供一种在分布式流数据处理引擎实现复杂事件处理的方法及系统，首先获取预先定义的需要匹配的事件序列模式以及数据处理逻辑，再将CEP算子嵌入至所述数据处理逻辑中，并对分布式流数据处理引擎下发执行指令；获取进入CEP算子中的事件，并按照取键逻辑将所述时间分配至分区中某个键对应的事件队列中；最后判断所述事件中的时间概念是实际处理时间还是事件发生时间，并根据判断结果进行对应的事件处理。本发明提供一种有效的用于在现有的分布式流数据处理引擎上实现CEP的方案，该方案在实现了一个功能完善的CEP模块的同时，还将其与现有的分布式流数据处理引擎加以融合，使其完美继承处理引擎的诸多优良特性，能够在大规模的数据量下水平拓展。

摘要： 本发明公开了一种基于树形复杂事件处理过程中算子内部处理系统，该算子内部处理系统包括有输出流定制模块、事件匹配判定模块和事件复合模块；所述输出流定制模块根据算子语义输入事件流以及该算子语义标示符字符串求和后通过哈希散列函数处理，获得定制-事件流类型SJL10输出；所述事件匹配判定模块对接收到的定制-事件流类型MD10顺次进行类型约束、时间约束和谓词约束的判定，获得匹配事件流SJL20输出；所述事件复合模块对接收到的匹配事件流SJL20分别进行当前起始时间、当前结束时间、全部谓词提取处理，获得复合事件流SJL30输出。本发明是基于树模型的复杂事件处理引擎在优化后吞吐率是基于NFA实现的开源引擎Esper的3～6倍，并且在不同事件量或事件序列复杂度下性能表现稳定。

摘要： 本发明给出了一种基于网络流量元数据的复杂事件处理方法与系统，包括采集交换机镜像端口的网络流量元数据保存为pcap包，调用解析指令解析pcap包的详细信息获得解析结果；通过具有可视化/图形化的界面的规则设计器，并基于算子模型预先设计复杂事件的处理规则，使用AI模型进行测试输出规则文本；利用rete树结构来储存规则文本得到rete规则树，再根据权限将rete规则树保存到规则数据库当中；从rete规则树的根节点开始将每个类型节点对应的模式与元数据生成的事实/业务数据进行匹配，把符合类型节点对应的模式的结果输出到外部进行存储。实现了人工预定义业务规则，集成了机器学习和人工智能模型，可从多方位多角度实现已知安全威胁检测及未知网络威胁感知。

摘要： 本实用新型公开了一种基于复杂事件处理的实时安全预警处理一体机，包括底板，所述底板的顶部固定连接有安装槽，所述安装槽的内腔活动连接有安装块，所述安装块的顶部固定连接有箱体，所述安装块和安装槽一侧的前端和后端均开设有固定孔。本实用新型通过将箱体底部的安装块放置在安装槽的内腔，然后旋转紧固螺杆，紧固螺杆会先贯穿安装槽表面的固定孔，然后与安装块表面的固定孔螺纹连接，从而对安装块以及箱体进行固定，固定箱内腔的散热风扇在工作时会将箱体内腔的热空气通过散热孔排散出去，从而实现散热的效果，解决了此类一体机在使用过程中不便于安装和散热，给一体机的使用和维护造成不便的问题。