复杂事件处理
1. 复杂事件处理系统和方法
申请号: CN201180017466.7
申请日: 2011-03-31
公开（公告）号: CN102884510A
公开（公告）日: 2013-01-16
发明人: 大卫·罗克斯巴勒
一种复杂事件处理系统包括复杂事件处理引擎（52）和事件获取系统，其中该事件获取系统可操作为监控计算机网络（10，21，22，31，32，33）、响应于监控网络的结果产生简单事件报告且将这些报告传送到复杂事件处理引擎进行处理。该事件获取系统包括中央配置控制模块（51，53）和多个捕获节点模块（41，42），该多个捕获节点模块中的每一个可操作地连接到中央配置控制模块。每个捕获节点模块可操作为从中央配置控制模块接收配置指令以判断响应于在被监控的计算机网络上检测到的状况需要所述模块产生哪些简单事件报告。中央配置控制模块包括网络服务器形式的接口（51），该接口用于从系统的用户接收配置指令，处理这些配置指令，以及将这些配置指令发送到指定捕获节点模块以用于促使所述模块根据指定配置指令操作。
更多2. 复杂事件处理系统和方法
申请号: CN201180017466.7
申请日: 2011-03-31
公开（公告）号: CN102884510B
公开（公告）日: 2015-12-16
发明人: 大卫·罗克斯巴勒
一种复杂事件处理系统包括复杂事件处理引擎（52）和事件获取系统，其中该事件获取系统可操作为监控计算机网络（10，21，22，31，32，33）、响应于监控网络的结果产生简单事件报告且将这些报告传送到复杂事件处理引擎进行处理。该事件获取系统包括中央配置控制模块（51，53）和多个捕获节点模块（41，42），该多个捕获节点模块中的每一个可操作地连接到中央配置控制模块。每个捕获节点模块可操作为从中央配置控制模块接收配置指令以判断响应于在被监控的计算机网络上检测到的状况需要所述模块产生哪些简单事件报告。中央配置控制模块包括网络服务器形式的接口（51），该接口用于从系统的用户接收配置指令，处理这些配置指令，以及将这些配置指令发送到指定捕获节点模块以用于促使所述模块根据指定配置指令操作。
更多3. 一种分布式复杂事件处理系统
申请号: CN201410789897.0
申请日: 2014-12-17
公开（公告）号: CN104572859B
公开（公告）日: 2018-01-09
发明人: 程渤; 陈俊亮; 李敏
本发明公开一种分布式复杂事件处理系统，该系统包括：资源接入子系统，用于将异构数据以预设的命名结构发送到分布式事件分发通信子系统；复杂事件处理子系统，用于将用户的数据请求发送到分布式事件分发通信子系统中并获取具有预设的命名结构的数据之后，以预设的复杂事件过滤规则对数据进行处理，得到复杂事件处理结果并将复杂事件处理结果以预设的命名结构发送到分布式事件分发通信子系统中；分布式事件分发通信子系统，用于管理具有预设的命名结构的数据。本发明的系统以事件为中心的数据处理方式，根据实际生活的复杂应用场景，灵活多变的提供各种复杂场景的业务需求服务，支撑应用层的场景需求。
更多4. 一种物联网复杂事件处理方法
申请号: CN201510527518.5
申请日: 2015-08-25
公开（公告）号: CN105138385A
公开（公告）日: 2015-12-09
发明人: 黄海; 张雷; 王柏; 张艳梅; 朱思远; 李伟鹏; 陈峥; 薛寒寒; 许纪念
本发明公开了一种物联网复杂事件处理方法，本发明的方法将物联网系统数据看作不同类型的事件，通过分析事件间的关系如：成员关系、时间关系以及因果关系，包含关系等，建立不同的事件关系序列库，即规则库，利用过滤、关联、聚合等技术，最终由简单事件产生高级事件或商业流程。本发明实现了完整的复杂事件处理生命周期模块，涵盖复杂事件定义语言、复杂事件处理语言、处理规则引擎、事件预处理、事件检测、事件派发等，并且引入规则引擎作为事件检测和规则匹配的核心。与现有技术相比，本发明不局限于复杂事件处理的某些特定领域，具有普适性，支持在内存中对海量事件的处理，提高实时性，存储优化，提高事件识别准确率。
更多5. 一种分布式复杂事件处理系统
申请号: CN201410789897.0
申请日: 2014-12-17
公开（公告）号: CN104572859A
公开（公告）日: 2015-04-29
发明人: 程渤; 陈俊亮; 李敏
本发明公开一种分布式复杂事件处理系统，该系统包括：资源接入子系统，用于将异构数据以预设的命名结构发送到分布式事件分发通信子系统；复杂事件处理子系统，用于将用户的数据请求发送到分布式事件分发通信子系统中并获取具有预设的命名结构的数据之后，以预设的复杂事件过滤规则对数据进行处理，得到复杂事件处理结果并将复杂事件处理结果以预设的命名结构发送到分布式事件分发通信子系统中；分布式事件分发通信子系统，用于管理具有预设的命名结构的数据。本发明的系统以事件为中心的数据处理方式，根据实际生活的复杂应用场景，灵活多变的提供各种复杂场景的业务需求服务，支撑应用层的场景需求。
更多6. 一种复杂事件处理的方法及装置
申请号: CN202311234738.X
申请日: 2023-09-21
公开（公告）号: CN117235134A
公开（公告）日: 2023-12-15
发明人: 韩超; 杨应桐; 冷从林
本申请实施例提供一种复杂事件处理的方法及装置，应用在分布式计算技术领域，包括：获取上游系统上报的事件数据；针对任一事件数据，基于事件匹配规则确定事件信息数据库中是否存在事件数据的匹配事件，并基于匹配结果将事件数据记录于事件信息数据库；事件信息数据库为多个上游系统共用；针对事件信息数据库中的任一记录，将在事件窗口内未得到匹配事件的记录生成断点事件，并将断点事件对应的断点消息发送至下游系统。通过事件信息数据库实现对复杂事件进行存储和处理，实现了多机房部署的场景，避免数据量过大或者窗口期时间设定过大而造成分布式流处理应用出现宕机，进而造成数据丢失或内存溢出的问题。
更多7. 一种复杂事件处理单元部署系统
申请号: CN202310392787.X
申请日: 2023-04-11
公开（公告）号: CN116400930A
公开（公告）日: 2023-07-07
发明人: 胡昊; 匡胤鑫; 周官皓; 王禹又; 蔡逸凡
本发明公开一种复杂事件处理单元部署系统，包括集群抽象层、复杂事件处理单元模型、算法模块和部署模块，集群抽象层对Kubernetes集群的虚拟化，屏蔽了许多来自硬件节点本身或者Kubernetes的配置细节；复杂事件处理单元模型将所有由用户编写的处理单元、编排的处理单元图和事件描述类、数据生成模块、运行启动器打包成的容器镜像；算法模块，由一个抽象算法基类和若干个继承了该基类的实际算法样例组成，用户通过继承抽象算法基类的形式实现自己想要的部署算法，应用于部署；部署模块由部署实验的配置模块、集群初始化模块、负责执行部署的模块和计算响应时间的模块组成。本发明实现了对复杂事件处理模型的简易部署。
更多8. 用于微批次流传输的复杂事件处理
申请号: CN201780057260.4
申请日: 2017-09-15
公开（公告）号: CN109716322B
公开（公告）日: 2023-03-21
发明人: H·帕克; S·比施诺伊; P·图卡拉姆; S·库马; P·阿德瓦尼; K·穆拉伊; J·图里昂
公开了一种用于处理事件流中的事件的事件处理系统。该系统可以执行指令以：接收连续查询，对连续查询应用变换以生成用于连续查询的查询计划，使用变换算法来变换查询计划以生成经变换的查询计划，接收与应用相关的输入事件的微批次流，至少部分地基于经变换的查询计划来处理微批次流的输入事件以生成与应用相关的输出事件集合，以及将与应用相关的输出事件集合存储在输出队列中。
更多9. 基于复杂事件处理引擎的监控系统
申请号: CN201511000974.0
申请日: 2015-12-28
公开（公告）号: CN105653425B
公开（公告）日: 2018-10-19
发明人: 肖慧彬; 雷晓彬; 李婷; 李文亮
本发明公开了一种基于复杂事件处理引擎的监控系统，所述系统包括：代理、复杂事件处理引擎、存储器以及主控单元；所述代理为一个或多个，部署在应用服务器上，一个应用服务器上部署一个代理；所述代理，用于监控应用服务器，收集应用的事件信息并发送给所述复杂事件处理引擎；复杂事件处理引擎，用于基于预先配置的规则对所述事件信息进行过滤和分析，得到最终的报警数据，并交由所述存储器保存；存储器，用于保存所述复杂事件处理引擎得到的报警数据，以及保存所述复杂事件处理引擎所需的规则；主控单元，用于控制所述复杂事件处理引擎所需规则的配置、基于所述报警数据控制前端界面的展示、以及控制所述代理；前端界面，用于用户配置规则、以及向用户展示报警数据。
更多10. 基于复杂事件处理引擎的监控系统
申请号: CN201511000974.0
申请日: 2015-12-28
公开（公告）号: CN105653425A
公开（公告）日: 2016-06-08
发明人: 肖慧彬; 雷晓彬; 李婷; 李文亮
本发明公开了一种基于复杂事件处理引擎的监控系统，所述系统包括：代理、复杂事件处理引擎、存储器以及主控单元；所述代理为一个或多个，部署在应用服务器上，一个应用服务器上部署一个代理；所述代理，用于监控应用服务器，收集应用的事件信息并发送给所述复杂事件处理引擎；复杂事件处理引擎，用于基于预先配置的规则对所述事件信息进行过滤和分析，得到最终的报警数据，并交由所述存储器保存；存储器，用于保存所述复杂事件处理引擎得到的报警数据，以及保存所述复杂事件处理引擎所需的规则；主控单元，用于控制所述复杂事件处理引擎所需规则的配置、基于所述报警数据控制前端界面的展示、以及控制所述代理；前端界面，用于用户配置规则、以及向用户展示报警数据。
更多11. 用于微批次流传输的复杂事件处理
申请号: CN201780057260.4
申请日: 2017-09-15
公开（公告）号: CN109716322A
公开（公告）日: 2019-05-03
发明人: H·帕克; S·比施诺伊; P·图卡拉姆; S·库马; P·阿德瓦尼; K·穆拉伊; J·图里昂
公开了一种用于处理事件流中的事件的事件处理系统。该系统可以执行指令以：接收连续查询，对连续查询应用变换以生成用于连续查询的查询计划，使用变换算法来变换查询计划以生成经变换的查询计划，接收与应用相关的输入事件的微批次流，至少部分地基于经变换的查询计划来处理微批次流的输入事件以生成与应用相关的输出事件集合，以及将与应用相关的输出事件集合存储在输出队列中。
更多12. 复杂事件处理方法、装置及存储介质
申请号: CN202210672152.0
申请日: 2022-06-14
公开（公告）号: CN115145744A
公开（公告）日: 2022-10-04
发明人: 赖春江; 欧阳贤
本公开的实施例提供一种复杂事件处理方法、装置及存储介质，属于计算机技术领域。所述方法包括：订阅与预设运营计划中的事件定义对应的用户事件；根据用户标识以及所述预设运营计划中的事件条件，预处理所述用户事件；将预处理后的所述用户事件与所述预设运营计划中的匹配规则进行匹配，并输出匹配成功的所述用户事件对应的用户标识以及所述预设运营计划。本公开实施例适用于运营计划的实现过程。
更多13. 复杂事件处理方法、装置及终端设备
申请号: CN202010912588.3
申请日: 2020-09-02
公开（公告）号: CN112181477B
公开（公告）日: 2024-05-10
发明人: 宣钢炜; 罗明星; 刘达明
本申请公开了一种复杂事件处理方法、装置及终端设备，所述方法包括：获取由用户终端根据选定的数据源从服务器选取的多个事件数据；其中，数据源根据用户终端接收到的配置指令进行选取；根据多个事件数据生成多个复杂事件，以根据多个复杂事件创建多个CEP算子；在接收到决策请求时，获取由用户终端配置的规则数据包，将规则数据包中的多个规则数据与多个CEP算子进行一一匹配，以基于匹配关系形成多个决策任务后，根据决策请求执行多个决策任务，生成决策结果。
更多14. 一种复杂事件处理方法、装置及系统
申请号: CN201410775571.2
申请日: 2014-12-15
公开（公告）号: CN105786451A
公开（公告）日: 2016-07-20
发明人: 刘诗凯
本发明实施例提供一种复杂事件处理方法、装置及系统，涉及通信技术领域，实现了需要同步响应的系统进行复杂事件处理时既对外提供同步响应，又避免信息泛滥。本发明提供的方案包括：接收事件源发送的输入事件，其中，输入事件包括对象的标识和事件类型；获取预设数据库中，与事件类型对应的M个模式规则；将输入事件与M个模式规则分别进行模式规则匹配，获取N个输出事件；若N大于或等于1，向实时决策装置发送至少一个事件信息，每个事件信息包括Q个输出事件和指示信息。本发明用于复杂事件处理。
更多15. 复杂事件处理方法、装置及终端设备
申请号: CN202010912588.3
申请日: 2020-09-02
公开（公告）号: CN112181477A
公开（公告）日: 2021-01-05
发明人: 宣钢炜; 罗明星; 刘达明
本申请公开了一种复杂事件处理方法、装置及终端设备，所述方法包括：获取由用户终端根据选定的数据源从服务器选取的多个事件数据；其中，数据源根据用户终端接收到的配置指令进行选取；根据多个事件数据生成多个复杂事件，以根据多个复杂事件创建多个CEP算子；在接收到决策请求时，获取由用户终端配置的规则数据包，将规则数据包中的多个规则数据与多个CEP算子进行一一匹配，以基于匹配关系形成多个决策任务后，根据决策请求执行多个决策任务，生成决策结果。
更多16. 面向CPS应用的复杂事件处理系统及方法
申请号: CN201410478582.4
申请日: 2014-09-18
公开（公告）号: CN104268008B
公开（公告）日: 2017-07-28
发明人: 谭杰; 毛娜
本发明公开了一种面向CPS应用的复杂事件处理系统及方法，所述系统包括外部实体环境、传感器、事件产生器、复杂事件处理引擎和制动事件管理模块，其中外部实体环境为整个系统提供物理环境下的各种信息，并接受信息系统的控制；传感器是连接外部实体环境和事件产生器的纽带；事件产生器将从外部实体环境中获得的信息抽象成具有统一格式的基本事件流；复杂事件处理引擎根据系统中已定义的规则对基本事件进行处理，并生成制动事件；制动事件管理模块根据事件中的指示，将制动事件分发给合适的待感控的物体进行处理。本发明实现面向CPS应用的事件‑响应操作，达到控制物理系统的目的，能够提高事件处理的有效性和高效性。
更多17. 复杂事件处理方法、装置、介质及设备
申请号: CN202410417289.0
申请日: 2024-04-09
公开（公告）号: CN118012720A
公开（公告）日: 2024-05-10
发明人: 张月江; 严斌锋; 岳可诚; 林剑浪; 孙晓; 黄舟瑜
本申请提供了一种复杂事件处理方法、装置、介质及设备，其中方法包括：启动客户端，向服务端发送复杂事件配置请求，获取复杂事件配置信息并进行初始化；基于前端代码中的统一事件流处理工具，捕捉埋点数据，根据埋点数据确定是否触发了目标复杂事件；响应于目标复杂事件的触发，运行复杂事件时机决策引擎，以依据时机配置信息针对所述埋点数据进行时机匹配，确定是否满足所述目标复杂事件的时机；在时机匹配成功后，触发回调函数，以执行目标复杂事件对应的处置方案。本申请可提高复杂事件处理效率。
更多18. 一种复杂事件处理方法、系统及其装置
申请号: CN201710165680.6
申请日: 2017-03-20
公开（公告）号: CN108628884B
公开（公告）日: 2022-03-25
发明人: 丁福海
本申请实施例公开了一种复杂事件处理方法、系统及其装置，用于在复杂事件处理系统中识别静默事件。本申请实施例方法包括：任务管理装置获取事件类型集合；所述任务管理装置向事件分发装置发送所述事件类型集合；所述事件分发装置向静默事件匹配装置发送初始化指令消息，所述初始化指令消息包括所述事件类型集合；所述静默事件匹配装置启动定时器；若在所述定时器启动后的预置时间内，所述静默事件匹配装置未接收到属于所述事件类型集合中的任一事件类型的事件，则生成静默事件；所述静默事件匹配装置向终端发送所述静默事件。
更多