支持事件流处理系统中的故障转移的方法与非暂时性计算机可读媒体以及系统

    公开(公告)号:CN106464746B

    公开(公告)日:2018-11-06

    申请号:CN201580023361.0

    申请日:2015-05-26

    IPC分类号: H04L29/14

    摘要: 在支持事件流处理ESP系统中的故障转移的计算装置中,接收事件块对象。将所述计算装置的第一状态确定为现用或备用。当所述第一状态为现用时,将所述计算装置的第二状态确定为新现用的或非新现用的。当所述计算装置从备用状态切换到现用状态时确定为新现用的。当所述第二状态为新现用时,确定唯一识别上一所发布事件块对象的上一所发布事件块对象识别符。从可由所述计算装置存取的非暂时性计算机可读媒体选择下一事件块对象。所述下一事件块对象具有大于所述所确定上一所发布事件块对象识别符的事件块对象识别符。将所述选定下一事件块对象发布到消息传出网络装置。

    通过事件流处理集群管理器进行路由管理

    公开(公告)号:CN112540948A

    公开(公告)日:2021-03-23

    申请号:CN202010825616.8

    申请日:2020-08-17

    IPC分类号: G06F15/173

    摘要: 本申请涉及通过事件流处理集群管理器进行路由管理。计算设备管理路由器。基于管理器引擎定义实例化管理器引擎,并基于创建的管理器ESP模型实例化管理器ESPE。基于从管理器配置文件中读取的映射信息创建路由器配置文件,该映射信息描述了事件发布源和管理器ESPE的源窗口之间的连接。基于创建的路由器配置文件实例化路由器引擎。启动连接器以接收基于路由器配置文件的事件。事件是在基于管理器ESP模型处理的管理器ESPE的源窗口中接收的。基于从远程ESP模型定义的多个窗口的每个窗口接收的使用度量,通过路由器引擎选择第三计算设备,该远程ESP模型配置为在接收到已处理事件时进一步处理该已处理的事件。

    事件流处理集群管理器
    3.
    发明授权

    公开(公告)号:CN108419447B

    公开(公告)日:2020-02-07

    申请号:CN201780004037.3

    申请日:2017-11-16

    摘要: 一种第一计算装置管理事件流处理ESP引擎ESPE的集群。基于从管理器配置文件读取的信息而创建本地ESP模型,所述管理器配置文件包含用以连接到第二计算装置的第一连接信息和用以连接到第三计算装置的第二连接信息。基于所述所创建本地ESP模型而在所述第一计算装置上实例化ESPE。在所述实例化ESPE的第一源窗口中从所述第二计算装置接收事件块对象。向远程第三计算装置部署远程ESP模型。所述管理器配置文件包含所述远程ESP模型的指示符。选择用以接收经处理事件块对象的第三计算装置。将所述经处理事件块对象发布给由向所述第三计算装置部署的所述远程ESP模型定义的第二源窗口。

    通过事件流处理集群管理器进行路由管理

    公开(公告)号:CN112540948B

    公开(公告)日:2023-12-19

    申请号:CN202010825616.8

    申请日:2020-08-17

    IPC分类号: G06F15/173

    摘要: 本申请涉及通过事件流处理集群管理器进行路由管理。计算设备管理路由器。基于管理器引擎定义实例化管理器引擎,并基于创建的管理器ESP模型实例化管理器ESPE。基于从管理器配置文件中读取的映射信息创建路由器配置文件,该映射信息描述了事件发布源和管理器ESPE的源窗口之间的连接。基于创建的路由器配置文件实例化路由器引擎。启动连接器以接收基于路由器配置文件的事件。事件是在基于管理器ESP模型处理的管理器ESPE的源窗口中接收的。基于从远程ESP模型定义的多个窗口的每个窗口接收的使用度量,通过路由器引擎选择第三计算设备,该远程ESP模型配置为在接收到已处理事件时进一步处理该已处理的事件。

    事件流处理集群管理器
    5.
    发明授权

    公开(公告)号:CN111290763B

    公开(公告)日:2021-05-04

    申请号:CN202010093173.8

    申请日:2017-11-16

    摘要: 本申请涉及事件流处理集群管理器。一种第一计算装置管理事件流处理ESP引擎ESPE的集群。基于从管理器配置文件读取的信息而创建本地ESP模型,所述管理器配置文件包含用以连接到第二计算装置的第一连接信息和用以连接到第三计算装置的第二连接信息。基于所述所创建本地ESP模型而在所述第一计算装置上实例化ESPE。在所述实例化ESPE的第一源窗口中从所述第二计算装置接收事件块对象。向远程第三计算装置部署远程ESP模型。所述管理器配置文件包含所述远程ESP模型的指示符。选择用以接收经处理事件块对象的第三计算装置。将所述经处理事件块对象发布给由向所述第三计算装置部署的所述远程ESP模型定义的第二源窗口。

    事件流处理集群管理器
    6.
    发明公开

    公开(公告)号:CN111290763A

    公开(公告)日:2020-06-16

    申请号:CN202010093173.8

    申请日:2017-11-16

    摘要: 本申请涉及事件流处理集群管理器。一种第一计算装置管理事件流处理ESP引擎ESPE的集群。基于从管理器配置文件读取的信息而创建本地ESP模型,所述管理器配置文件包含用以连接到第二计算装置的第一连接信息和用以连接到第三计算装置的第二连接信息。基于所述所创建本地ESP模型而在所述第一计算装置上实例化ESPE。在所述实例化ESPE的第一源窗口中从所述第二计算装置接收事件块对象。向远程第三计算装置部署远程ESP模型。所述管理器配置文件包含所述远程ESP模型的指示符。选择用以接收经处理事件块对象的第三计算装置。将所述经处理事件块对象发布给由向所述第三计算装置部署的所述远程ESP模型定义的第二源窗口。

    事件流处理集群管理器
    7.
    发明公开

    公开(公告)号:CN108419447A

    公开(公告)日:2018-08-17

    申请号:CN201780004037.3

    申请日:2017-11-16

    IPC分类号: G06F17/30 G06F9/54 H04L29/08

    摘要: 一种第一计算装置管理事件流处理ESP引擎ESPE的集群。基于从管理器配置文件读取的信息而创建本地ESP模型,所述管理器配置文件包含用以连接到第二计算装置的第一连接信息和用以连接到第三计算装置的第二连接信息。基于所述所创建本地ESP模型而在所述第一计算装置上实例化ESPE。在所述实例化ESPE的第一源窗口中从所述第二计算装置接收事件块对象。向远程第三计算装置部署远程ESP模型。所述管理器配置文件包含所述远程ESP模型的指示符。选择用以接收经处理事件块对象的第三计算装置。将所述经处理事件块对象发布给由向所述第三计算装置部署的所述远程ESP模型定义的第二源窗口。