Low-latency streaming analytics

A system comprising:

• a data store including computer-executable instructions;
• and
• a processor configured to execute the computer-executable instructions to:
• obtain a message at a multi-stage publish-subscribe messaging system;
• and
• iteratively process the message through the multi-stage publish-subscribe messaging system, wherein the multi-stage publish-subscribe messaging system implements at least a first and second stage of processing, the first and second stage of processing being implemented by the multi-stage publish-subscribe messaging system at least partly in parallel, wherein implementing the first stage of processing at the multi-stage publish-subscribe messaging system includes:
• generating a modified message by modifying content the message;
• and
• publishing the modified message from the multi-stage publish-subscribe messaging system to the multi-stage publish-subscribe messaging system for continued processing at the second stage of processing, and
• wherein implementing the second stage of processing at the multi-stage publish-subscribe messaging system with respect to the modified message includes publishing an output to an external device based at least in part on evaluating the modified message according to a set of rules maintained by the multi-stage publish-subscribe messaging system.

One or more non-transitory computer-readable media comprising computer-executable instructions that, when executed by a computing system, cause the computing system to:

• obtain a message at a multi-stage publish-subscribe messaging system;
• and
• iteratively process the message through the multi-stage publish-subscribe messaging system, wherein the multi-stage publish-subscribe messaging system implements at least a first and second stage of processing, the first and second stage of processing being implemented by the multi-stage publish-subscribe messaging system at least partly in parallel, wherein implementing the first stage of processing at the multi-stage publish-subscribe messaging system includes:
• generating a modified message by modifying content the message;
• and
• publishing the modified message from the multi-stage publish-subscribe messaging system to the multi-stage publish-subscribe messaging system for continued processing at the second stage of processing, and
• wherein implementing the second stage of processing at the multi-stage publish-subscribe messaging system with respect to the modified message includes publishing an output to an external device based at least in part on evaluating the modified message according to a set of rules maintained by the multi-stage publish-subscribe messaging system.