CN201480077256.0 事件处理系统.pdf
免费下载
(19)中华人民共和国国家知识产权局
(12)发明专利
(10)授权公告号
(45)授权公告日
(21)申请号 201480077256.0
(22)申请日 2014.03 .31
(65)同一申请的已公布的文献号
申请公布号 CN 106104525 A
(43)申请公布日 2016.11 .09
(85)PCT国际申请进入国家阶段日
2016.09 .18
(86)PCT国际申请的申请数据
PCT/EP2014/056425 2014 .03 .31
(87)PCT国际申请的公布数据
WO2015/149830 EN 2015 .10 .08
(73)专利权人 华为技术有限公司
地址 518129 广东省深圳市龙岗区坂田华
为总部办公楼
(72)发明人 埃利泽·利维 阿哈龙·埃威佐
卢卡斯·布劳恩 托马斯·埃特
乔治斯·加斯帕里斯
马丁·考夫曼 唐纳德·科斯曼
丹尼尔·威徳默
(74)专利代理机构 广州三环专利商标代理有限
公司 44202
代理人 郝传鑫 熊永强
(51)Int.Cl.
G06F
16/23
(2019 .01)
G06F
16/2455
(2019 .01)
G06F
16/27
(2019 .01)
(56)对比文件
US 2012291049 A1 ,2012 .11 .15
US 2012291049 A1 ,2012 .11 .15
US 2012297237 A1,2012.11 .22
CN 102591645 A ,2012 .07 .18
CN 102930046 A ,2013 .02 .13
审查员 刘畅
(54)发明名称
事件处理系统
(57)摘要
一种事件处理系统(100)用于处理在数据库
系统上操作的流事件(101) ，所述事件处理系统
(100)包括事件负载均衡单元(103)、多个事件计
算节点(105a、105b、105c)以及与所述事件计算
节点(105a、105b、105c)分离的多个事件状态存
储(109a、109b、109c)，其中所述事件负载均衡单
元(103) 用于根据事件负载均衡标准将流事件
(101) 路由至所述多个事件计算节点 (105a 、
105b、105c) ；所述多个事件状态存储 (109a 、
109b、109c) 用于存储所述多个事件计算节点
(105a、105b、105c)的状态以保存所述事件处理
的 状态 ；以 及所述多个 事件计算节点 (105a 、
105b、105c)用于处理从所述事件负载均衡单元
(103)接收的所述流事件(101)，根据所述事件处
理改变它们的状态，以及基于它们改变后的状态
更新所述多个事件状态存储(109a、109b、109c)。
权利要求书2页 说明书10页 附图2页
CN 106104525 B
2021.04.20
CN 106104525 B
1 .一种事件处理系统(100)，用于处理在数据库系统上操作的流事件(101) ，其特征在
于，所述事件处理系统(100)包括事件负载均衡单元(103)、多个事件计算节点(105a、105b、
105c)以及与所述事件计算节点(105a、105b、105c)分离的多个事件状态存储(109a、109b、
109c)，其中：
所述事件负载均衡单元(103)用于根据事件负载均衡标准将所述流事件(101)路由至
所述多个事件计算节点(105a、105b、105c)；
所述多个事件状态存储(109a、109b、109c) 用于存储所述多个事件计算节点(105a、
105b、105c)的状态以保存所述事件处理的状态；所述多个事件状态存储(109a、109b、109c)
包括基于分布式主存储器的键值存储；以及
所述多个事件计算节点(105a、105b、105c)用于处理从所述事件负载均衡单元(103)接
收的所述流事件(101)，根据所述事件处理改变所述多个事件计算节点的状态，以及基于所
述多个事件计算节点改变后的状态更新所述多个事件状态存储(109a、109b、109c)；
所述多个事件计算节点(105a、105b、105c)用于处理规则和连续查询以在同一时间实
时地一起进行复杂事件处理和所述事件处理；
还包括查询负载均衡单元(115)和多个查询处理节点(113a、113b、113c)，其中：
所述查询负载均衡单元(115)用于根据查询负载均衡标准将多个查询(117)路由至所
述多个查询处理节点(113a、113b、113c)；
所述多个查询处理节点(113a、113b、113c)用于处理从所述查询负载均衡单元(115)接
收的所述查询(117)；
所述多个查询处理节点(113a、113b、113c)中的一个查询处理节点用于访问所述多个
事件状态存储(109a、109b、109c)中的至少一个事件状态存储以处理从所述查询负载均衡
单元(115)接收的所述查询(117)。
2.根据权利要求1所述的事件处理系统(100) ，其特征在于，所述查询负载均衡单元
(115)用于将每个查询(117)准确转发给一个查询处理节点(113a、113b、113c)。
3 .根据权利要求2所述的事件处理系统(100)，其特征在于，所述查询处理节点(113a、
113b、113c)用于访问更多数据，尤其是所述数据库系统中的用于处理所述查询(117)的客
户主数据。
4 .根据任一前述权利要求所述的事件处理系统(100)，其特征在于，所述多个查询处理
节点(113a、113b、113c)用于处理随即查询以进行实时分析。
5 .根据权利要求1所述的事件处理系统(100) ，其特征在于，所述事件负载均衡单元
(103)用于基于应用定义分区，尤其是基于客户键，以及规则复制来路由所述流事件(101)。
6 .根据权利要求5所述的事件处理系统(100) ，其特征在于，所述事件负载均衡单元
(103)用于路由所述流事件(101)，使得所述多个事件计算节点(105a、105b、105c)中的一个
事件计算节点处理所述流事件(101)的一个特定子集以及处理所述流事件(101)的所述特
定子集上的所有规则。
7 .根据权利要求1所述的事件处理系统 (100) ，其特征在于，所述事件负载均衡单元
(103) 用于基于事件复制和规则分区来路由所述流事件(101) ，使得每个事件计算节点
(105a、105b、105c)处理所有流事件(101)以及规则的子集。
8.根据权利要求1所述的事件处理系统(100) ，其特征在于，所述事件负载均衡单元103
权 利 要 求 书
1/2 页
2
CN 106104525 B
2
of 15
免费下载
【版权声明】本文为墨天轮用户原创内容，转载时必须标注文档的来源（墨天轮），文档链接，文档作者等基本信息，否则作者和墨天轮有权追究责任。如果您发现墨天轮中有涉嫌抄袭或者侵权的内容，欢迎发送邮件至：contact@modb.pro进行举报，并提供相关证据，一经查实，墨天轮将立刻删除相关内容。
下载排行榜
评论