Adaptable internet-of-things (IoT) computing systems and methods for improved declarative control of streaming data

An adaptable internet-of-things (IoT) computing method for improved declarative control of streaming data, the adaptable IoT computing method:

• determining, by a declarative scripting engine, an input data stream based on a first declarative statement defining one or more input data stream variables of a declarative scripting language in one or more declarative scripting modules;
• binding the input data stream to the stream controller, wherein the input data stream data is ingested into one or more memories;
• generating, by the declarative scripting engine, a snapshot data stream based on a second declarative statement defining one or more snapshot stream variables of the declarative scripting language in the one or more declarative scripting modules,
• wherein the snapshot data stream is derived from the input data stream and ingested into the one or more memories, and
• defining a stream model based on the input data stream and snapshot stream data;
• determining a listener entity comprising an event based on a listener declarative statement of the declarative scripting language;
• scaling a compute cluster size corresponding to the stream controller based on at least one of:
• a number of messages included in the input data stream, the first declarative statement, the second declarative statement, or the listener declarative statement;
• suspending one or more nodes of the compute cluster based on data pipe size in the compute cluster;
• and
• triggering the event based on the input data stream or the snapshot data stream as ingested into the stream model.

A tangible, non-transitory computer-readable medium storing instructions for improved declarative control of streaming data, that when executed by one or more processors cause the one or more processors to:

• determine, by a declarative scripting engine, an input data stream based on a first declarative statement defining one or more input data stream variables of a declarative scripting language in one or more declarative scripting modules;
• bind the input data stream to the stream controller, wherein the input data stream data is ingested into one or more memories;
• generate, by the declarative scripting engine, a snapshot data stream based on a second declarative statement defining one or more snapshot stream variables of the declarative scripting language in the one or more declarative scripting modules,
• wherein the snapshot data stream is derived from the input data stream and ingested into the one or more memories, and
• define a stream model based on the input data stream and snapshot stream data;
• determine a listener entity comprising an event based on a listener declarative statement of the declarative scripting language;
• scale a compute cluster size corresponding to the stream controller based on at least one of:
• a number of messages included in the input data stream, the first declarative statement, the second declarative statement, or the listener declarative statement;
• suspend one or more nodes of the compute cluster based on data pipe size in the compute cluster;
• and
• trigger the event based on the input data stream or the snapshot data stream as ingested into the stream model.