Automated streaming data model generation

A computing device comprising:

• a processor;
• and
• a computer-readable medium operably coupled to the processor, the computer-readable medium having computer-readable instructions stored thereon that, when executed by the processor, cause the computing device to
• create a mapping dataset from predefined configuration information and predefined device information, wherein the predefined configuration information includes a measurement processing description for a measurement, wherein the measurement processing description describes a computational process to be performed by an event stream processing (ESP) window on one or more fields of an event block object when the event block object is received by a second computing device from a third computing device, wherein the predefined device information includes a measurement identifier that uniquely identifies a sensor and a device to which the sensor is associated for a plurality of measurements, wherein the measurement is one of the plurality of measurements;
• execute an update macro with an update template to create update code, wherein the update template defines a first template for the created update code and the update macro replaces an update code placeholder included in the update template with first code specific to the created mapping dataset, wherein the created update code is configured to parse the measurement identifier and a measurement value from the event block object when the event block object is received by the second computing device;
• execute a transpose macro with a transpose template to create transpose code, wherein the transpose template defines a second template for the created transpose code and the transpose macro replaces a transpose code placeholder included in the transpose template with second code specific to the created mapping dataset, wherein the created transpose code is configured to perform the described computational process on the parsed measurement value to define a transposed event record;
• and
• create an ESP model that includes the created update code, a source window defined to execute the created update code, the created transpose code, a transpose window defined to execute the created transpose code, connection information to connect the second computing device and the third computing device, and a connectivity definition, wherein the connectivity definition defines a connectivity between the source window and the transpose window for processing the event block object when the event block object is received by the second computing device from the third computing device.

A method of automatically generating an event streaming model configured to receive and process events from a plurality of computing devices, the method comprising:

• creating, by a computing device, a mapping dataset from predefined configuration information and predefined device information, wherein the predefined configuration information includes a measurement processing description for a measurement, wherein the measurement processing description describes a computational process to be performed by an event stream processing (ESP) window on one or more fields of an event block object when the event block object is received by a second computing device from a third computing device, wherein the predefined device information includes a measurement identifier that uniquely identifies a sensor and a device to which the sensor is associated for a plurality of measurements, wherein the measurement is one of the plurality of measurements;
• executing, by the computing device, an update macro with an update template to create update code, wherein the update template defines a first template for the created update code and the update macro replaces an update code placeholder included in the update template with first code specific to the created mapping dataset, wherein the created update code is configured to parse the measurement identifier and a measurement value from the event block object when the event block object is received by the second computing device;
• executing, by the computing device, a transpose macro with a transpose template to create transpose code, wherein the transpose template defines a second template for the created transpose code and the transpose macro replaces a transpose code placeholder included in the transpose template with second code specific to the created mapping dataset, wherein the created transpose code is configured to perform the described computational process on the parsed measurement value to define a transposed event record;
• and
• creating, by the computing device, an ESP model that includes the created update code, a source window defined to execute the created update code, the created transpose code, a transpose window defined to execute the created transpose code, connection information to connect the second computing device and the third computing device, and a connectivity definition, wherein the connectivity definition defines a connectivity between the source window and the transpose window for processing the event block object when the event block object is received by the second computing device from the third computing device.