DESC:TECHNICAL FIELD
[001] The present invention relates to a system and a method for dynamic distributed assembly level parsing for IOT, and more particularly, the present invention relates to a dynamic distributed level parsing mechanism and a method thereof.

BACKGROUND
[002] In the realm of industrial automation, the Internet of Things (IoT) based systems play a vital role by seamlessly exchanging data over the Internet. The IoT-based systems widely deploy protocols such as Modbus, or Controller Area Network (CAN) that aid in communication of the data from the sensors to the edge device and conversion of it into a suitable format before further sending it to the server. However, the current configurable IoT system consumes more CPU memory. Additionally, the current systems are not suitable to process more than 100 parameters for thousands of connected devices.
[003] Existing solutions in the field of IoT systems primarily focus on data communication and conversion using established protocols. These systems are designed to handle data from sensors and convert it into a format suitable for server communication. Technologies such as Modbus and CAN are commonly used to facilitate this process. These protocols have been instrumental in enabling data exchange in industrial automation environments, ensuring that sensor data is accurately transmitted to edge devices and subsequently to servers for further processing.
[004] Despite the advancements in IoT systems, several limitations persist. The current systems are heavily reliant on CPU memory, leading to inefficiencies in resource utilization. This high memory consumption restricts the scalability of the systems, making them unsuitable for handling a large number of parameters across thousands of connected devices. Additionally, the existing solutions lack the capability to dynamically adapt to varying configurations, further limiting their effectiveness in diverse industrial settings.
[005] There is a pressing need for an IoT system that addresses these deficiencies by offering a fast and efficient solution with reduced CPU and memory requirements. In the context of the present disclosure, it should be understood that the described embodiments in this section are put forth for illustrative purposes only. Those skilled in the art will appreciate that various modifications, adaptations, and alternative designs may be employed without departing from the scope and spirit of the invention. Accordingly, the present invention should not be limited to the specific embodiments illustrated herein, but rather should be construed according to the claims and description that follow.

OBJECTS OF THE INVENTION
[006] An object of the present invention is to provide a dynamic distributed assembly level parsing for an IoT-based system.
[007] Another object of the present invention is to maintain the dynamics of the configurable system.
[008] Yet another object of the present invention is to provide a method for dynamic distributed assembly level parsing.
[009] Yet another object of the present invention is to provide a dynamic distributed assembly level parsing system configured to receive parameter-specific data from a plurality of devices on various types of Modbus/CAN bus controllers in real time and collect it in an IoT-based system.
[0010] Still another object of the present invention is to provide a system comprising a controller module, an IoT module, and a server, wherein the IoT module includes an IoT device, a communication module, and a Modbus/CAN bus interface that can be selected among GSM, LTE, Ethernet, or Wi-Fi options.
[0011] Yet another object of the present invention is to provide a method for receiving data, processing and finding an assembly relating to the received data, fetching dynamic configuration of the assembly, compiling assembly data in runtime, processing compiled data in assembly, and storing processed data in cache.
[0012] Another object of the present invention is to provide a system configured for providing data from a plurality of devices to the IoT module via Modbus/CAN bus interface, where the plurality of devices can include industrial equipment, battery management systems, heavy equipment, vehicles, lifts, cranes, or household equipment.
[0013] Yet another object of the present invention is to provide a system configured for processing received data from connected devices, where Modbus/CAN bus or both having all or selected Modbus addresses/CAN IDs are communicated over the connected interfaces.
[0014] Another object of the present invention is to provide a system configured for identifying the type of device during data processing and fetching the dynamic configuration of the device, where the dynamic configuration is compiled during runtime, and an assembly is either found or generated for each device.
[0015] Yet another object of the present invention is to provide a system where the compiled configuration of the assembly relating to the device is stored in the cache of the CPU, and the data processing is done within the loaded assembly with dynamic configuration, using the same assembly for the same type of device to ensure minimum CPU consumption.
[0016] Another object of the present invention is to provide a system capable of dynamically loading another code and expanding itself to perform different operations at runtime, ensuring efficient stream processing of different types of machine data from various devices.
[0017] Yet another object of the present invention is to provide a mechanism for generating a plurality of data strings that are dynamic in nature, allowing different data objects to be dynamically embedded without significantly increasing payload size.
[0018] Another object of the present invention is to provide a method for dynamic distributed assembly level parsing, including steps such as receiving data, checking device authorization, finding the type of device, locating an assembly in cache, processing data, verifying, and storing updated data in cache, and if the assembly is not found, fetching dynamic configuration, compiling the assembly in runtime, and processing the assembly data before verification and storage.

SUMMARY
[0019] This summary is not intended to identify essential features of the claimed subject matter nor is it intended for use in limiting the scope of the claimed subject matter. The present invention provides an embodiment configured provide a dynamic distributed assembly level parsing system (hereinafter referred to as "system") and a method thereof.
[0020] The embodiments herein are configured to receive parameter-specific data from a plurality of devices on various types of Modbus/CAN bus controllers in real time and collect it in an IoT-based system. The system comprises a controller module, an IoT module, and a server.
[0021] In accordance with an embodiment of the present invention, the system is configured for receiving data, processing and finding an assembly relating to received data, fetching dynamic configuration of the assembly, compiling assembly data in runtime, processing compiled data in assembly, and storing processed data in cache. This embodiment ensures that the system can dynamically adapt to the data received from various devices, compile the necessary assembly code in real-time, and store the processed data efficiently, thereby optimizing the overall data processing workflow.
[0022] According to another embodiment, the IoT module comprises an IoT device, a communication module, and a Modbus/CAN bus interface that can be selected among GSM, LTE, Ethernet, or Wi-Fi options. This configuration allows the IoT module to be versatile in terms of connectivity, ensuring that it can interface with a wide range of devices and communication protocols, thereby enhancing the system's adaptability and scalability.
[0023] In another embodiment, the server is a cloud server or a physical or virtual server connected through a network. This embodiment provides flexibility in terms of data storage and processing capabilities, allowing the system to leverage cloud computing resources or local servers based on the specific requirements of the application, thereby ensuring efficient data management and processing.
[0024] In accordance with an embodiment of the present invention, the system is configured for providing data from a plurality of devices to the IoT module via Modbus/CAN bus interface. The plurality of devices can include industrial equipment, battery management systems, heavy equipment, vehicles, lifts, cranes, or household equipment. The IoT module further pushes the received data to a processing service of the IoT device. The processing service contains a plurality of strings containing different types of equipment data with more than 100 parameters that need to be processed for thousands of connected devices simultaneously. This embodiment highlights the system's capability to handle large volumes of data from diverse sources, ensuring comprehensive data collection and processing.
[0025] In an exemplary embodiment, the plurality of parameters may comprise but not be limited to temperature, pressure, level, pH, and alike. This embodiment ensures that the system can handle a wide range of data types, making it suitable for various industrial and commercial applications where different parameters need to be monitored and processed.
[0026] According to another embodiment, the system is configured for processing received data from connected devices. Modbus/CAN bus or both having all or selected Modbus address/CAN IDs are communicated over the connected interfaces. This embodiment ensures that the system can efficiently communicate with and process data from devices using different communication protocols, thereby enhancing its versatility and applicability.
[0027] In one of the exemplary embodiments of the present invention, the system is configured for processing the data, and while processing, the type of the device is identified. The system is further configured to fetch the dynamic configuration of the device. The dynamic configuration is compiled during runtime, where an assembly is either found or generated for each device. An assembly code is kept in external memory and gets into cache runtime depending on the operating system. The system is configured to dynamically load another code and expand itself to perform different operations at runtime. This embodiment ensures that the system can dynamically adapt to different devices and configurations, thereby optimizing the data processing workflow and enhancing system performance.
[0028] The compiled configuration of the assembly relating to the device is further stored in the cache of the CPU. This embodiment ensures that the system can quickly access and process the necessary assembly code, thereby reducing latency and improving overall system efficiency.
[0029] In an exemplary embodiment, the data processing is done within the loaded assembly with dynamic configuration. For the same type of device, the same assembly is used for processing. As the assembly is a low-level code, it is executed with minimum CPU consumption. Processing data can process different types of machine data from different devices. This stream processing is dynamic and executed on the server side with server-side cache. This embodiment highlights the system's efficiency in terms of CPU usage and its capability to handle diverse data types dynamically.
[0030] In another exemplary embodiment, if the dynamic configuration is updated or modified, the corresponding runtime assemblies are updated. This embodiment ensures that the system can adapt to changes in device configurations in real-time, thereby maintaining optimal performance and accuracy in data processing.
[0031] In one of the exemplary embodiments of the present invention, the mechanism generates a plurality of data strings that are dynamic in nature, and different data objects can be dynamically embedded therein without increasing payload size drastically. This embodiment ensures efficient data transmission and storage, thereby optimizing the overall system performance.
[0032] In an implementation of one of the exemplary embodiments of the present invention, a controller module comprises a Modbus/CAN controller. The controller module is communicatively coupled to an IoT module via a wired connection. The IoT module is configured to read data from connected interfaces frequently and decode the protocol to form a collection of required and desired parameters to be transferred to the server of choice. The IoT module can be chosen among GSM, LTE, Ethernet, or Wi-Fi. The IoT module is configured for converting the received data into a compiled assembly during runtime, processing and storing the compiled assembly in cache. The IoT module is further configured for transmitting the processed data to a server in a wired or wireless manner. This embodiment provides a detailed explanation of the system's operation, highlighting the interaction between different components and the data processing workflow.
[0033] In an implementation of one of the exemplary embodiments of the present invention, the method for dynamic distributed assembly level parsing is disclosed. The method comprises steps such as receiving data, checking if the device sending data is authorized by finding the type of device, finding an assembly relating to the device in cache, processing the data, verifying and storing the updated data in cache. If the assembly is not found in cache, then the method further comprises steps such as fetching dynamic configuration of the corresponding device, compiling the assembly in runtime, and processing the assembly data before verifying and saving it in the cache. This embodiment provides a comprehensive explanation of the method for dynamic distributed assembly level parsing, highlighting the steps involved in data processing and the interaction between different components of the system.
[0034] In another implementation a method (200) for dynamic distributed assembly level parsing, is disclosed. The method comprises receiving (201) data from a plurality of devices. Further identifying a type of device from which data is received. Fetching (208) a dynamic configuration of the identified device. The method further comprises compiling (209) an assembly based on the dynamic configuration during runtime. Further processing (205) the compiled assembly data.

BRIEF DESCRIPTION OF DRAWINGS
[0035] The detailed description is described with reference to the accompanying figures. In the figures, the left-most digit(s) of a reference number identifies the figure in which the reference number first appears. The same numbers are used throughout the drawings to refer like features and components.
[0036] Figure 1a & 1b illustrates a schematic diagram of the system (100) for dynamic distributed assembly level parsing in accordance with an embodiment of the present invention;
[0037] Figure 2, represents a flow diagram of the method (200) for dynamic distributed assembly level parsing in accordance with an embodiment of the present invention; and
[0038] Figure 3, represents a flow diagram of the method for dynamic distributed assembly level parsing in accordance with another embodiment of the present invention.
[0039] It should be appreciated by those skilled in the art that any block diagrams herein represent conceptual views of illustrative systems embodying the principles of the present invention. Similarly, it will be appreciated that any flowcharts, flow diagrams, and the like represent various processes that may be substantially represented in computer-readable medium and so executed by a computer or processor, whether or not such computer or processor is explicitly shown.

DETAILED DESCRIPTION
[0040] Some embodiments of the present disclosure, illustrating all its features, will now be discussed in detail. It must also be noted that as used herein and in the appended claims, the singular forms "a", "an" and "the" include plural references unless the context clearly dictates otherwise.
[0041] References in the specification to “one embodiment” or “an embodiment” mean that a particular feature, structure, characteristic, or function described in connection with the embodiment is included in at least one embodiment. The appearances of the phrase “in one embodiment” in various places in the specification are not necessarily all referring to the same embodiment.
[0042] The embodiments herein provide the dynamic distributed assembly level parsing system (hereinafter referred to as “system”) and a method thereof, configured to receive parameter-specific data from a plurality of devices on various types of Modbus / CAN bus controllers in real time and collects it in an IoT-based system. The system comprises a controller module, an IoT module, and a server.
[0043] Hereinafter, embodiments will be described in detail. For clarity of the description, known constructions and functions will be omitted.
[0044] Parts of the description may be presented in terms of operations performed by at least one processor, electrical/electronic circuit, a computer system, using terms such as data, state, link, fault, packet, and the like, consistent with the manner commonly employed by those skilled in the art to convey the substance of their work to others skilled in the art. As is well understood by those skilled in the art, these quantities take the form of data stored/transferred in the form of non-transitory, computer-readable electrical, magnetic, or optical signals capable of being stored, transferred, combined, and otherwise manipulated through mechanical and electrical components of the computer system; and the term computer system includes general purpose as well as special purpose data processing machines, switches, and the like, that are standalone, adjunct or embedded. For instance, some embodiments may be implemented by a processing system that executes program instructions so as to cause the processing system to perform operations involved in one or more of the methods described herein. The program instructions may be computer-readable code, such as compiled or non-compiled program logic and/or machine code, stored in a data storage that takes the form of a non-transitory computer-readable medium, such as a magnetic, optical, and/or flash data storage medium. Moreover, such processing systems and/or data storage may be implemented using a single computer system or may be distributed across multiple computer systems (e.g., servers) that are communicatively linked through a network to allow the computer systems to operate in a coordinated manner.
[0045] The present invention is illustrated with reference to the accompanying drawings, throughout which reference numbers indicate corresponding parts in the various figures. These reference numbers are shown in brackets in the following description.
[0046] In one of the exemplary embodiments of the present invention, the system is configured for receiving data, processing and finding an assembly relating to received data, fetching dynamic configuration of the assembly, compiling assembly data in runtime, processing compiled data in assembly, and storing processed data in cache.
[0047] In one of the exemplary embodiments of the present invention, the IoT module comprises an IoT device, a communication module, and a Modbus/CAN bus interface that can be selected among GSM, LTE, Ethernet, or Wi-Fi options.
[0048] In one of the exemplary embodiments of the present invention, the server is a cloud server or physical or virtual server connected through a network.
[0049] In one of the exemplary embodiments of the present invention, the system is configured for providing data from a plurality of devices to the IOT module via Modbus/CAN bus interface. In an exemplary embodiment, the plurality of devices can be any of an industrial equipment, battery management systems, heavy equipment, vehicles, lifts, cranes, or household equipment. The IOT module further pushes the received data to a processing service of the IOT device. In an exemplary embodiment, the processing service contains a plurality of strings containing the different types of equipment data with more than 100 parameters that need to be processed for thousands of connected devices simultaneously.
[0050] In an exemplary embodiment, the plurality of parameters may comprise but not limited to temperature, pressure, level, pH, and alike.
[0051] In one of the exemplary embodiments of the present invention, the mechanism is configured for handling a plurality of parameters from the plurality of devices.
[0052] In one of the exemplary embodiments of the present invention, the system is configured for processing a received data from connected devices. Modbus/CAN bus or both having all or selected Modbus address/CAN IDs are communicated over the connected interfaces.
[0053] In one of the exemplary embodiments of the present invention, the system is configured for processing the data, and while processing, the type of the device is identified. The system further configured to fetch the dynamic configuration of the device. The dynamic configuration is compiled during runtime, where an assembly is either found or generated for each device. In an exemplary embodiment, an assembly code is kept in external memory and gets into cache runtime depending operating system. In an exemplary embodiment, the system is configured to dynamically loading another code and expanding itself to do different operations at runtime.
[0054] The compiled configuration of the assembly relating to the device is further stored in cache of CPU.
[0055] In an exemplary embodiment, the data processing is done withing the loaded assembly with dynamic configuration. For the same type of device, the same assembly is used for processing. As the assembly is a low-level code it is executed in with minimum CPU consumption. In an exemplary embodiment, processing data can process different types machine data form different devices. This stream processing is dynamic and executing on server side with server-side cache.
[0056] In another exemplary embodiment, if the dynamic configuration is updated or modified, the corresponding runtime assemblies are updated.
[0057] In one of the exemplary embodiments of the present invention, the mechanism generates a plurality of data strings that are dynamic in nature and different data objects can be dynamically embedded therein without increasing payload size drastically.
[0058] In an implementation of one of the exemplary embodiments of the present invention, operation by the system (100) is explained by referring to Figure 1. A controller module (101) comprises a Modbus/CAN controller. The controller module (101) is communicatively coupled to an IoT module (102) via a wired connection. The IoT module (102) is configured to read data from connected interfaces frequently and decode the protocol to form a collection of required and desired parameters to be transferred to the server (104) of the choice. The IoT module (102) can be chosen among GSM, LTE, Ethernet, or Wi-Fi. The IoT module (102) is configured for converting the received data into a compiled assembly during runtime, processing and storing the compiled assembly in cache. The IoT module (102) further configured for transmitting the processed data to a server (104) in a wired or wireless manner.
[0059] In an implementation of one of the exemplary embodiments of the present invention, the method for dynamic distributed assembly level parsing (200) is explained by referring to Figure 2. The method (200) comprises steps such as receiving (201) data in the, checking (202) if the device sending data is authorized by finding (203) the type of device, finding (204) an assembly relating to the device in cache, processing (205) the data, verifying (206) and storing (207) the updated data in cache. If the assembly is not found in cache, then the method (200) further comprises steps such as fetching (208) dynamic configuration of the correspondence device, compiling (209) the assembly in runtime, and processing (205) the assembly data before verifying (206) and saving (207) in the cache.
[0060] In an implementation of one of the exemplary embodiments of the present invention, the method for dynamic distributed assembly level parsing (200) is further explained by referring to Figure 3, wherein when the dynamic configuration is updated or changed, the method checks for the assembly in cache, removes the assembly from therein, and further executes the assembly cache pool.
[0061] In accordance with an exemplary embodiment as illustrated in Figure 1 to Figure 3, a system 100, according to the embodiment of the present disclosure comprises a controller module 101 with a Modbus/CAN controller. An IoT module 102 wired to the controller module, configured to read data, decode protocols, compile data into an assembly, process and cache the assembly, and transmit processed data. The IoT module may transmit the processed data to a server in real-time.
[0062] Further in another aspect the controller module 101 may be configured to receive parameter-specific data from a plurality of devices and a server 104 configured to process and store the processed data from the IoT module 102. The IoT module 102 may be further configured to comprise a communication module, and a Modbus/CAN bus interface. The IoT module 102 is communicably connected to the server 104, selected from at least one of a cloud server, a physical server, and/or a virtual server.
[0063] The server 104 may further comprise includes a cache for storing compiled assembly data relating to the IoT devices. In some embodiments, the compiled assembly data may be dynamically loaded into the cache during runtime. In some embodiments, the dynamic configuration of the assembly may be updated, and the corresponding runtime assemblies may be updated in the cache.
[0064] The IoT module 102 is further configured to receive data from IoT devices and process the data received data comprising a plurality of strings with different types of equipment data. Further each string may contain more than one parameter to be processed for thousands of connected devices simultaneously.
[0065] Further in accordance with an aspect, the method comprises the step 201 of receiving data includes checking 202 if the device sending data may be authorized. In some embodiments, the dynamic configuration may be updated, and the method 200 includes removing an existing assembly from the cache and executing an updated assembly cache pool. In some embodiments, the plurality of devices may be connected via interfaces selected from the group consisting of Modbus and CAN bus.
[0066] The method may include identifying a type of device from which data may be received. At 208 the method may include fetching a dynamic configuration of the identified device. At 209 compiling an assembly based on the dynamic configuration during runtime. Processing 205 the compiled assembly data.
[0067] Advantages of the invention:
1. The system allows to process more than 100 parameters for thousands of connected devices.
2. The system facilitated less memory and CPU utilization.
3. The system maintains the property and dynamic configuration in process of optimization for different types of equipment connected via Modbus, CAN bus or any other standard protocols.
4. The system facilitates less IOPS (input/output operations per second) on database.
[0068] The foregoing objects of the invention are accomplished and the problems and shortcomings associated with prior art techniques and approaches are overcome by the present invention described in the present embodiment. Detailed descriptions of the preferred embodiment are provided herein; however, it is to be understood that the present invention may be embodied in various forms. Therefore, specific details disclosed herein are not to be interpreted as limiting, but rather as a basis for the claims and as a representative basis for teaching one skilled in the art to employ the present invention in virtually any appropriately detailed system, structure, or matter. The embodiments of the invention as described above and the methods disclosed herein will suggest further modification and alterations to those skilled in the art. Such further modifications and alterations may be made without departing from the scope of the invention. ,CLAIMS:I/We claim:

1. A system (100) for dynamic distributed assembly level parsing, comprising:
a controller module (101) configured to receive parameter-specific data from a plurality of devices;
an IoT module (102) comprising an IoT device, a communication module, and a Modbus/CAN bus interface, wherein the IoT module (102) is communicably connected to the controller module (101); and
a server (104) configured to process and store processed data from the IoT module (102).

2. The system (100) as claimed in claim 1, wherein the Modbus/CAN bus interface is selected from the group consisting of GSM, LTE, Ethernet, and Wi-Fi.
3. The system (100) as claimed in claim 1, wherein the server (104) is selected from the group consisting of a cloud server (104), a physical server (104), and a virtual server (104).
4. The system (100) as claimed in claim 1, wherein the plurality of IoT devices includes at least one of industrial equipment, battery management systems, heavy equipment, vehicles, lifts, cranes, and household equipment.
5. The system (100) as claimed in claim 1, wherein the IoT module (102) is configured to push received data to a processing service (205) containing a plurality of strings with different types of equipment data.
6. The system (100) as claimed in claim 5, wherein each string contains more than one parameter to be processed for thousands of connected devices simultaneously.
7. The system (100) as claimed in claim 1, wherein the server (104) includes a cache for storing (207) compiled assembly data relating to the devices.
8. The system (100) as claimed in claim 7, wherein the compiled assembly data is dynamically loaded into the cache during runtime.
9. The system (100) as claimed in claim 8, wherein the dynamic configuration of the assembly is updated, and the corresponding runtime assemblies are updated in the cache.

10. A method (200) for dynamic distributed assembly level parsing, comprising:
receiving (201) data from a plurality of devices;
identifying a type of device from which data is received;
fetching (208) a dynamic configuration of the identified device;
compiling (209) an assembly based on the dynamic configuration during runtime; and
processing (205) the compiled assembly data.

11. The method (200) as claimed in claim 10, further comprising storing (207) the processed data in a cache.
12. The method (200) as claimed in claim 10, wherein the step of receiving (201) data includes checking (202) if the device sending data is authorized.
13. The method (200) as claimed in claim 10, wherein the dynamic configuration is updated, and the method (200) includes removing an existing assembly from the cache and executing an updated assembly cache pool.
14. The method (200) as claimed in claim 10, wherein the plurality of devices are connected via interfaces selected from the group consisting of Modbus and CAN bus.

Dated this 07th Day of October, 2024
Prafulla Wange
Agent for Applicant
IN/PA-2058