Data monitoring system
    1.
    发明授权

    公开(公告)号:US11036981B1

    公开(公告)日:2021-06-15

    申请号:US17167633

    申请日:2021-02-04

    Abstract: A computing system determines if an event has occurred. A first window is defined that includes a subset of a plurality of observation vectors modeled as an output of an autoregressive causal system. A magnitude adjustment vector is computed from a mean computed for a matrix of magnitude values that includes a column for each window of a plurality of windows. The first window is stored in a next column of the matrix of magnitude values. Each cell of the matrix of magnitude values includes an estimated power spectrum value for a respective window and a respective frequency. A second matrix of magnitude values is updated using the magnitude adjustment vector. Each cell of the second matrix of magnitude values includes an adjusted power spectrum value for the respective window and the respective frequency. A peak is detected from the next column of the second matrix of magnitude values.

    Event stream processing cluster manager

    公开(公告)号:US10152361B2

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

    申请号:US15815293

    申请日:2017-11-16

    Abstract: A first computing device manages a cluster of event stream processing (ESP) engines (ESPEs). A local ESP model is created based on information read from a manager configuration file that includes first connection information to connect to the second computing device and second connection information to connect the third computing device. An ESPE is instantiated on the first computing device based on the created local ESP model. The event block object is received from the second computing device in a first source window of the instantiated ESPE. A remote ESP model is deployed to a remote third computing device. The manager configuration file includes an indicator of the remote ESP model. The third computing device to receive the processed event block object is selected. The processed event block object is published to a second source window defined by the remote ESP model deployed to the third computing device.

    COMPUTER SYSTEM TO SUPPORT FAILOVER IN AN EVENT STREAM PROCESSING SYSTEM
    3.
    发明申请
    COMPUTER SYSTEM TO SUPPORT FAILOVER IN AN EVENT STREAM PROCESSING SYSTEM 有权
    在事件流处理系统中支持故障的计算机系统

    公开(公告)号:US20150358196A1

    公开(公告)日:2015-12-10

    申请号:US14806750

    申请日:2015-07-23

    Abstract: In a system, a first status of a first ESP engine (ESPE) executing at a first computing device is determined as newly active; a last published event block object identifier is determined as an identifier uniquely identifying a last event block object published to an out-messaging network device; a next event block object having an event block object identifier greater than the determined last published event block object identifier is selected from a first computer-readable medium; and the selected next event block object is published to the out-messaging network device. A first event block object is received from a second ESPE executing at a second computing device. A first status of the second ESPE is determined as standby by the second computing device. The received first event block object is stored by the second computing device in a second non-transitory computer-readable medium.

    Abstract translation: 在系统中,在第一计算设备处执行的第一ESP引擎(ESPE)的第一状态被确定为新活动的; 确定最后发布的事件块对象标识符作为唯一地标识发布到外发消息传递网络设备的最后事件块对象的标识符; 从第一计算机可读介质中选择具有大于所确定的最后发布的事件块对象标识符的事件块对象标识符的下一个事件块对象; 并且所选择的下一个事件块对象被发布到外发消息网络设备。 从在第二计算设备处执行的第二ESPE接收第一事件块对象。 第二ESPE的第一状态被第二计算设备确定为待机。 所接收的第一事件块对象由第二计算设备存储在第二非暂时计算机可读介质中。

    Router management by an event stream processing cluster manager

    公开(公告)号:US10747592B2

    公开(公告)日:2020-08-18

    申请号:US16578480

    申请日:2019-09-23

    Abstract: A computing device manages a router. A manager engine is instantiated based on a manager engine definition and instantiates a manager ESPE based on a created manager ESP model. A router configuration file is created based on mapping information read from the manager configuration file that describes connectivity between an event publishing source and a source window of the manager ESPE. A router engine is instantiated based on the created router configuration file. A connector is started to receive an event based on the router configuration file. The event is received in the source window of the manager ESPE processed based on the manager ESP model. A third computing device is selected by the router engine based on a usage metric received from each window of a plurality of windows defined by a remote ESP model configured to further process the processed event when it is received.

    Router management by an event stream processing cluster manager

    公开(公告)号:US10423469B2

    公开(公告)日:2019-09-24

    申请号:US16163748

    申请日:2018-10-18

    Abstract: A computing device manages a router to route events between a plurality of computing device based on a manager configuration file. A manager engine is instantiated based on a manager engine definition and instantiates a manager ESPE based on a created manager ESP model. A router configuration file is created based on mapping information read from the manager configuration file that describes connectivity between an event publishing source and a source window of the manager ESPE. A router engine is instantiated based on the created router configuration file. A connector is started to receive an event based on the router configuration file. The event is received in the source window of the manager ESPE defined by the manager ESP model and processed based on the manager ESP model. A third computing device is selected by the router engine. The processed event is published to the third computing device.

    ROUTER MANAGEMENT BY AN EVENT STREAM PROCESSING CLUSTER MANAGER

    公开(公告)号:US20190050277A1

    公开(公告)日:2019-02-14

    申请号:US16163748

    申请日:2018-10-18

    CPC classification number: G06F9/542 G06F8/60 G06F8/70 G06F9/44505 G06F2209/544

    Abstract: A computing device manages a router to route events between a plurality of computing device based on a manager configuration file. A manager engine is instantiated based on a manager engine definition and instantiates a manager ESPE based on a created manager ESP model. A router configuration file is created based on mapping information read from the manager configuration file that describes connectivity between an event publishing source and a source window of the manager ESPE. A router engine is instantiated based on the created router configuration file. A connector is started to receive an event based on the router configuration file. The event is received in the source window of the manager ESPE defined by the manager ESP model and processed based on the manager ESP model. A third computing device is selected by the router engine. The processed event is published to the third computing device.

    Delivery acknowledgment in event stream processing

    公开(公告)号:US10102028B2

    公开(公告)日:2018-10-16

    申请号:US13958096

    申请日:2013-08-02

    Abstract: A method of acknowledging receipt of an event block object is provided. First connection information for connecting to an event stream processing (ESP) engine executing at a first computing device is received. A first connection to the ESP engine is established using the received first connection information. Second connection information for connecting to a publishing client executing at a second computing device is received. A second connection to the publishing client is established using the received second connection information, wherein the first connection differs from the second connection. An event block object is received from the ESP engine using the established first connection, wherein the event block object includes a unique identifier for the event block object. Successful processing of the event block object is determined. Responsive to the successful processing determination, an acknowledgment message including the unique identifier is sent to the publishing client using the established second connection.

    DELIVERY ACKNOWLEDGMENT IN EVENT STREAM PROCESSING
    8.
    发明申请
    DELIVERY ACKNOWLEDGMENT IN EVENT STREAM PROCESSING 审中-公开
    在事件流处理中的交付确认

    公开(公告)号:US20140280986A1

    公开(公告)日:2014-09-18

    申请号:US13958096

    申请日:2013-08-02

    CPC classification number: G06F9/46 H04L61/35 H04L67/10 G06F15/16

    Abstract: A method of acknowledging receipt of an event block object is provided. First connection information for connecting to an event stream processing (ESP) engine executing at a first computing device is received. A first connection to the ESP engine is established using the received first connection information. Second connection information for connecting to a publishing client executing at a second computing device is received. A second connection to the publishing client is established using the received second connection information, wherein the first connection differs from the second connection. An event block object is received from the ESP engine using the established first connection, wherein the event block object includes a unique identifier for the event block object. Successful processing of the event block object is determined. Responsive to the successful processing determination, an acknowledgment message including the unique identifier is sent to the publishing client using the established second connection.

    Abstract translation: 提供了确认事件块对象的接收的方法。 接收用于连接到在第一计算装置执行的事件流处理(ESP)引擎的第一连接信息。 使用接收到的第一连接信息建立到ESP引擎的第一连接。 接收用于连接到在第二计算设备执行的发布客户端的第二连接信息。 使用所接收的第二连接信息建立与发布客户端的第二连接,其中第一连接与第二连接不同。 使用建立的第一连接从ESP引擎接收事件块对象,其中事件块对象包括事件块对象的唯一标识符。 确定事件块对象的成功处理。 响应于成功的处理确定,使用建立的第二连接将包括唯一标识符的确认消息发送到发布客户端。

    ROUTER MANAGEMENT BY AN EVENT STREAM PROCESSING CLUSTER MANAGER

    公开(公告)号:US20200034216A1

    公开(公告)日:2020-01-30

    申请号:US16578480

    申请日:2019-09-23

    Abstract: A computing device manages a router. A manager engine is instantiated based on a manager engine definition and instantiates a manager ESPE based on a created manager ESP model. A router configuration file is created based on mapping information read from the manager configuration file that describes connectivity between an event publishing source and a source window of the manager ESPE. A router engine is instantiated based on the created router configuration file. A connector is started to receive an event based on the router configuration file. The event is received in the source window of the manager ESPE processed based on the manager ESP model. A third computing device is selected by the router engine based on a usage metric received from each window of a plurality of windows defined by a remote ESP model configured to further process the processed event when it is received.

    EVENT STREAM PROCESSING CLUSTER MANAGER
    10.
    发明申请

    公开(公告)号:US20180165139A1

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

    申请号:US15815293

    申请日:2017-11-16

    CPC classification number: G06F9/542 G06F8/60 G06F8/70 G06F9/44505 G06F2209/544

    Abstract: A first computing device manages a cluster of event stream processing (ESP) engines (ESPEs). A local ESP model is created based on information read from a manager configuration file that includes first connection information to connect to the second computing device and second connection information to connect the third computing device. An ESPE is instantiated on the first computing device based on the created local ESP model. The event block object is received from the second computing device in a first source window of the instantiated ESPE. A remote ESP model is deployed to a remote third computing device. The manager configuration file includes an indicator of the remote ESP model. The third computing device to receive the processed event block object is selected. The processed event block object is published to a second source window defined by the remote ESP model deployed to the third computing device.

Patent Agency Ranking