IP Library Granted Patent US 12699701
Granted Patent B2
US 12699701 · App. 18/665,561 · Granted Aug 4, 2026

Method and a system for normalizing data in data processing pipelines

Inventors: Bhabesh Acharya (Bangalore, IN); Kumaresh Baabu (Madurai, IN); Kotni Ashutosh (Bhubaneswar, IN)
Assignee: HONEYWELL INTERNATIONAL INC.
G06F16/24573G06F16/24539G06F16/2477G06F16/254
View Patent ↗
Loading inventors, assignments & file history…
Monitor This Case
Get email alerts when status or documents change.
Order Certified Copies
Most orders are placed with the USPTO same day — all within 24 business hours.
Order via The Patent Place →
Pre-filled with this patent's details
Quick Facts
Patent No.
US 12699701
App. No.
18/665,561
Granted
Aug 4, 2026
Kind
B2
Abstract

The present disclosure provides a method and system for normalizing data related to assets in a business environment. The method comprises receiving at least one data from one or more assets within an enterprise and parsing the at least one data to identify at least one asset type. The method further comprises dynamically generating a structured query language (SQL) query corresponding to the at least one asset type and storing the SQL query in a metadata repository. The method further comprises executing the SQL query from the metadata repository on the at least one data. The method further comprises normalizing the at least one data by merging the results of the executed SQL query with the at least one data, and at least one configuration data to populate a dimensional model in real time, wherein the at least one configuration data comprises metadata associated with the one or more assets and an ontology model representing at least one of attributes, characteristics and relationships associated with the one or more assets. The method further comprises dynamically updating the at least one configuration data with the normalized data. A data processing system for normalizing data related to assets is also disclosed.

Claims (43)

1 . A method for processing data comprising:

receiving at least one data from one or more assets within an enterprise;

parsing the at least one data to identify at least one asset type;

dynamically generating a structured query language (SQL) query corresponding to the at least one asset type;

storing the SQL query in a metadata repository;

executing the SQL query from the metadata repository on the at least one data;

normalizing the at least one data by merging results of the executed SQL query with the at least one data, and at least one configuration data to populate a dimensional model in real time, wherein the said normalizing the at least one data comprises performing recursive normalization, wherein output data from a normalization run of the recursive normalization is iteratively fed as input for subsequent normalization runs of the recursive normalization to update the dimensional model, and wherein the at least one configuration data comprises metadata associated with the one or more assets and an ontology model representing at least one of attributes, characteristics and relationships associated with the one or more assets, and wherein the ontology model is dynamically updated with normalized data, and wherein the said normalizing includes calculating asset specific metrics for the one or more assets and wherein the calculating of the asset-specific metrics is performed in a multi-tenant environment; and

dynamically updating the at least one configuration data with the normalized at least one data.

2 . The method of claim 1 , wherein the at least one data comprises at least one sensor data representing operations of the one or more assets.

3 . The method of claim 2 , wherein the at least one sensor data is stored in one or more databases.

4 . The method of claim 3 , wherein the one or more databases is a time series database.

5 . The method of claim 1 , further comprising parsing the at least one data based on pre-defined grammar rules.

6 . The method of claim 1 , wherein the dimensional model defines a schema comprising one or more dimensions of the one or more assets.

7 . The method of claim 1 , further comprising verifying the at least one SQL query by checking syntax and semantics of the SQL query before storing in the metadata repository.

8 . The method of claim 1 , further comprising the said normalizing the at least one data by registering and executing one or more user defined functions, one or more libraries, one or more lambda expressions and one or more azure functions.

9 . The method of claim 1 , further comprising the said normalizing the at least one data by executing the SQL query and linking results of the executed SQL query to form a normalization output.

10 . A data processing system comprising:

a processor;

a memory storing program instructions which, when executed by the processor, causes the processor to:

receive at least one data from one or more assets within an enterprise;

parse the at least one data to identify at least one asset type;

dynamically generate a SQL query corresponding to the at least one asset type;

store the SQL query in a metadata repository;

execute the SQL query from the metadata repository on the at least one data;

normalize the at least one data by merging results of the executed SQL query with the at least one data, and at least one configuration data to populate a dimensional model in real time,

wherein the said normalizing the at least one data comprises performing recursive normalization, wherein output data from a normalization run of the recursive normalization is iteratively fed as input for subsequent normalization runs of the recursive normalization to update the dimensional model, and wherein the at least one configuration data comprises metadata associated with the one or more assets and an ontology model representing at least one of attributes, characteristics and relationships associated with the one or more assets, and wherein the ontology model is dynamically updated with normalized data, and wherein said normalizing includes calculating asset specific metrics for the one or more assets and wherein the calculating of the asset-specific metrics is performed in a multi-tenant environment; and

dynamically update the at least one configuration data with the normalized at least one data.

11 . The system of claim 10 , wherein the at least one data comprises at least one sensor data representing operations of the one or more assets.

12 . The system of claim 11 , wherein the at least one sensor data is stored in one or more databases.

13 . The system of claim 12 , wherein the one or more databases is a time series database.

14 . The system of claim 10 , wherein the parser is configured to parse the at least one data based on pre-defined grammar rules.

15 . The system of claim 10 , wherein the dimensional model defines a schema comprising one or more dimensions of one or more assets.

16 . The system of claim 10 , wherein the at least one data is said normalized by registering and executing one or more user defined functions, one or libraries, one or more lambda expressions and one or more azure functions.

17 . The system of claim 10 , wherein the at least one data is said normalized by executing the SQL query and linking results of the executed SQL query to form a normalization output.

18 . The system of claim 10 , wherein the at least one SQL query is verified by checking syntax and semantics of the SQL query before storing in the metadata repository.

19 . A non-transitory computer-readable storage medium storing program instructions for processing data, the instructions, when executed, perform steps of:

receiving at least one data from one or more assets within an enterprise;

parsing the at least one data to identify at least one asset type;

dynamically generating a structured query language (SQL) query corresponding to the at least one asset type;

storing the SQL query in a metadata repository;

executing the SQL query from the metadata repository on the at least one data;

normalizing the at least one data by merging results of the executed SQL query with the at least one data, and at least one configuration data to populate a dimensional model in real time, wherein the said normalizing the at least one data comprises performing recursive normalization, wherein output data from a normalization run of the recursive normalization is iteratively fed as input for subsequent normalization runs of the recursive normalization to update the dimensional model, and wherein the at least one configuration data comprises metadata associated with the one or more assets and an ontology model representing at least one of attributes, characteristics and relationships associated with the one or more assets, and wherein the ontology model is dynamically updated with normalized data, and wherein the said normalizing includes calculating asset specific metrics for the one or more assets and wherein the calculating of the asset-specific metrics is performed in a multi-tenant environment; and

dynamically updating the at least one configuration data with the normalized at least one data.