Distributed processing system

A computer program product tangibly stored on one or more computer-readable hardware storage devices, the computer program product comprising instructions executable by a processor to:

• cause first local device nodes to cooperate to form a queue cluster to communicate via a RESTful API with sensor end nodes (end nodes) of a wireless mesh network, receive information from the end nodes of the wireless mesh network, store the information from the end nodes in memory;
• cause second local device nodes to cooperate to:
• form a processing cluster to retrieve the information stored in the queue cluster;
• select an end node as a leader, wherein the leader launches one or more worker routines distributed across the second local device nodes, wherein the one or more worker routines comprises one or more rules to act on the information to produce results;
• and
• wherein the leader launches one or more additional worker routines in response to determining a worker routine is over-loaded;
• cause third local device nodes to cooperate to:
• form a database cluster to provide storage for the results produced from the processing cluster;
• and
• wherein the first, the second, and the third local device nodes configured to connect to the wireless mesh network, and the wireless mesh network configurable to connect to an external network, and with each of the first, the second, and the third local device nodes configurable to be assigned functional roles as either a node of the queue cluster or a node of the processing cluster or a node of the database cluster.

A method, comprising:

• configuring local nodes as first local device nodes to form a distributed queue cluster, second local device nodes to form a processing cluster, and third local device nodes to form a database cluster, with any of the first, second and third local device nodes configurable to be assigned functional roles as either a node of the distributed queue cluster or a node of the processing cluster or a node of the database cluster;
• receiving information from sensor end nodes (end nodes) over a wireless mesh network by the distributed queue cluster, the distributed queue cluster communicating with the end nodes using a RESTful API, which stores the information from the end nodes in memory;
• performing one or more tasks on the information from the distributed queue cluster by the processing cluster that selects a node among the second local device nodes as a leader, wherein the leader retrieves information stored in the distributed queue cluster and launches one or more worker routines to process the information to produce processing results;
• storing the processing results from the processing cluster in the database cluster;
• and
• wherein the leader launches one or more additional worker routines in response to determining a worker is over-loaded;
• and
• connecting the first local device nodes, the second local device nodes, and the third local device nodes to the wireless mesh network and the wireless mesh network configurable to connect to an external network.