Rules execution system for IoT devices

A device, comprising:

• a processor configured to execute instructions to:
• receive datasets of readings from a plurality of Internet of Things (IoT) devices;
• identify rules for processing the readings from the plurality of IoT devices, wherein each rule is associated with a priority;
• divide the datasets of readings into a plurality of subsets of readings based on the rules for processing the readings;
• determine policies to be applied to routing of the readings;
• route, based on the policies, the plurality of subsets of the readings to processing units to be processed in parallel by the processing units;
• process the subsets of the readings to generate a list of actions, wherein each action in the list of actions identifies an action to be performed by an IoT device and is generated based on a rule of the rules for processing the readings from the plurality of IoT devices;
• resolve conflicts in the list of actions based on priorities associated with the rules, wherein, when resolving the conflicts in the list of actions, the processor is further configured to determine to execute an action generated based on a lower priority rule when an action generated from a conflicting higher priority rule is not in effect;
• and
• execute the actions.

A non-transitory computer-readable medium including instructions to be executed by a processor, the instructions including one or more instructions, when executed by the processor, for causing the processor to:

• receive datasets of readings from a plurality of Internet of Things (IoT) devices;
• identify rules for processing the readings from the plurality of IoT devices, wherein each rule is associated with a priority;
• divide the datasets into a plurality of subsets of the readings based on the rules for processing the readings;
• determine policies to be applied to routing of the readings;
• route, based on the policies, the plurality of subsets of the readings to processing units to be processed in parallel by the processing units;
• process the subsets of the readings to generate a list of actions, wherein each action in the list of actions identifies an action to be performed by an IoT device and is generated based on a rule of the one or more rules;
• resolve conflicts in the list of actions based on priorities associated with the rules, wherein resolving the conflicts in the list of actions includes determining to execute an action generated based on a lower priority rule when an action generated from a conflicting higher priority rule is not in effect;
• and
• execute the actions.