Publish-subscribe messaging with distributed processing

    公开(公告)号:US10666712B1

    公开(公告)日:2020-05-26

    申请号:US15179886

    申请日:2016-06-10

    Abstract: Technology for a publish-subscribe messaging method may include determining a schema for structuring raw data published in a publication by a publisher in a publish-subscribe system at a channel node in a network and distributing the schema from the channel node to other channel nodes in the network. The method may include identifying the publication from the publisher at one of the channel nodes and applying the schema to the raw data of the publication at the channel node, transforming the raw data to transformed data. The transformed data may be provided at a subscriber in the publish-subscribe system.

    Multi-tiered data processing service

    公开(公告)号:US10382358B1

    公开(公告)日:2019-08-13

    申请号:US15181332

    申请日:2016-06-13

    Abstract: A technology is described for operating a multi-tiered data processing service. An example method may include receiving a data rule set used to process data generated by a network addressable device included in a multi-tiered data processing service having computing nodes that are connected using one or more networks, where the computing nodes may have computing capacities to execute a portion of the data rule set using a rules engine. A computing node included in the multi-tiered processing service may be selected to host a portion of the data rule set on the computing node and a portion of the data rule set may be deployed to the computing node, where the data rule set may be registered with the rules engine that executes on the computing node and data generated by the network addressable device may be processed using the rules engine and the data rule set.

    Multi-tiered data processing service

    公开(公告)号:US11297003B1

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

    申请号:US16532313

    申请日:2019-08-05

    Abstract: A technology is described for operating a multi-tiered data processing service. An example method may include receiving a data rule set used to process data generated by a network addressable device included in a multi-tiered data processing service having computing nodes that are connected using one or more networks, where the computing nodes may have computing capacities to execute a portion of the data rule set using a rules engine. A computing node included in the multi-tiered processing service may be selected to host a portion of the data rule set on the computing node and a portion of the data rule set may be deployed to the computing node, where the data rule set may be registered with the rules engine that executes on the computing node and data generated by the network addressable device may be processed using the rules engine and the data rule set.

Patent Agency Ranking