Applying a plurality of rules to a multiplicity of streaming messages to perform intelligent data analytics

摘要

A plurality of messages comprising a stream of sensed data is received from an Internet of Things (IoT) device. A plurality of rules is identified. Responsive to a received message of the plurality of messages, the plurality of rules are distributed into a rule index tree based upon a cost model which minimizes a cost for analyzing the plurality of rules to determine whether or not each of the plurality of rules can be applied to the received message. The rule index tree is used to identify a set of rules of the plurality of rules that can be applied to the received message. The set of rules is applied to the received message to generate an outgoing message.