Gateway system that maps points into a graph schema

Abstract

A system including a processing circuit configured to receive tags describing points of a piece of equipment, the piece of equipment connected to the system. The processing circuit configured to map the tags to classes of a schema of a graph data structure. The processing circuit configured to perform clustering to generate clusters of the points. The processing circuit configured to identify, based on the clusters, relationships in the schema of the graph data structure between the tags mapped to the classes of the schema of the graph data structure. The processing circuit configured to communicate data to a second system based at least in part on the tags mapped to the classes and the relationships.

What is claimed: 
     
         1 . A gateway system of an environment, the gateway system comprising:
 a processing circuit configured to:
 receive a plurality of tags describing a plurality of points of a piece of equipment of the environment; 
 generate a first plurality of embeddings of the plurality of tags; 
 compare the first plurality of embeddings with a second plurality of embeddings of a plurality of classes of a schema of a graph data structure; 
 map at least a portion of the plurality of tags to the plurality of classes based on the comparison; 
 identify an order to execute a plurality of classification models for one tag of the plurality of tags based on a result of the comparison; 
 execute the plurality of classification models according to the order for the one tag of the plurality of tags to map the one tag of the plurality of tags to one class of the plurality of classes of the schema of the graph data structure; 
 identify, via machine learning, a plurality of relationships including relationship types selected from a plurality of available relationship types of the schema of the graph data structure between the plurality of tags mapped to the plurality of classes of the schema of the graph data structure; and 
 communicate data to a system based at least in part on the plurality of tags mapped to the plurality of classes and the plurality of relationships. 
   
     
     
         2 . The gateway system of  claim 1 , wherein the processing circuit is configured to:
 construct the graph data structure in the schema based on the plurality of tags mapped to the plurality of classes and the plurality of relationships in the schema of the graph data structure; and   communicate at least a portion of the graph data structure to the system.   
     
     
         3 . The gateway system of  claim 1 , wherein the processing circuit is configured to:
 communicate indications of the plurality of classes that the plurality of tags are mapped to and indications of the plurality of relationships to the system.   
     
     
         4 . The gateway system of  claim 1 , wherein the processing circuit is configured to:
 receive telemetry data from the piece of equipment; and   transmit the telemetry data to the system based at least in part on the plurality of tags mapped to the plurality of classes and the plurality of relationships.   
     
     
         5 . The gateway system of  claim 1 , wherein the processing circuit is configured to:
 receive one or more software components from the system, the one or more software components configured to cause the processing circuit to operate as a gateway for the piece of equipment and cause the processing circuit to:
 receive and execute a service, the service configured to:
 map the plurality of tags to the plurality of classes; and 
 identify, via the machine learning, the plurality of relationships; 
 
 receive telemetry data from the piece of equipment; and 
 communicate the telemetry data to the system based at least in part on the plurality of tags mapped to the plurality of classes and the plurality of relationships. 
   
     
     
         6 . The gateway system of  claim 1 , wherein the processing circuit is configured to:
 receive a layout of the environment;   identify a plurality of spaces of the environment based on the layout;   perform clustering by:
 setting a plurality of centroids based on the plurality of spaces; 
 clustering the plurality of points based on the plurality of centroids; and 
 identifying a plurality of spatial relationships of the plurality of relationships in the schema of the graph data structure based on the clustering of the plurality of points. 
   
     
     
         7 . The gateway system of  claim 1 , wherein the processing circuit is configured to:
 receive timeseries data for the plurality of points;   analyze the timeseries data to identify a behavior between a first point of the plurality of points and a second point of the plurality of points; and   identify a functional relationship of the plurality of relationships between a first tag representing the first point and a second tag representing the second point responsive to identifying the behavior between the first point and the second point.   
     
     
         8 . The gateway system of  claim 1 , wherein the processing circuit is configured to:
 perform a first clustering to cluster the plurality of points based on characteristics of the plurality of points;   perform a second clustering to cluster the plurality of points based on at least one layout of the environment;   merge results of the first clustering and the second clustering; and   identify the plurality of relationships of the schema of the graph data structure based on the result.   
     
     
         9 . The gateway system of  claim 1 , wherein the processing circuit is configured to:
 generate an embedding of a tag of the plurality of tags;   generate the second plurality of embeddings of the plurality of classes of the schema of the graph data structure;   generate a plurality of similarities between the embedding of the tag of the plurality of tags and the second plurality of embeddings of the plurality of classes of the schema of the graph data structure;   select a class of the plurality of classes based on the plurality of similarities; and   map the tag to the class responsive to the selection of the class.   
     
     
         10 . The gateway system of  claim 1 , wherein the processing circuit is configured to:
 generate an embedding vector of a tag of the plurality of tags;   generate a plurality of embedding vectors of the plurality of classes of the schema of the graph data structure;   generate a plurality of similarity levels based on angles formed between the embedding vector of the tag and the plurality of embedding vectors of the plurality of classes of the schema of the graph data structure;   select a class of the plurality of classes based on the plurality of similarity levels; and   map the tag to the class responsive to the selection of the class.   
     
     
         11 . The gateway system of  claim 1 , wherein the processing circuit is configured to:
 receive an indication that similarities between an embedding of the one tag of the plurality of tags and the second plurality of embeddings of the plurality of classes of the schema of the graph data structure are less than a threshold;   receive timeseries data for a point represented by the one tag of the plurality of tags; and   determine the order to execute the plurality of classification models comprising a first model and a second model to process the timeseries data,
 the first model outputting a first probability of the point being mapped to a first class of the plurality of classes; and 
 the second model outputting a second probability of the point being mapped to a second class of the plurality of classes, 
 the order indicating to process the timeseries data with the first model and then the second model responsive to an identification of a first similarity between the embedding of the one tag of the plurality of tags and a first embedding of the first class being greater than the embedding of the one tag of the plurality of tags and a second embedding of the second class; and 
   process the timeseries data with the first model and then the second model.   
     
     
         12 . The gateway system of  claim 1 , wherein the processing circuit is configured to:
 receive point data describing the plurality of points;   execute a plurality of models to map the plurality of points to the plurality of tags;   map the plurality of tags to the plurality of classes of the schema of the graph data structure; and   identify the plurality of relationships responsive to mapping the plurality of points to the plurality of tags.   
     
     
         13 . The gateway system of  claim 1 , wherein the processing circuit is configured to construct the graph data structure by:
 generating, based on mappings between the plurality of tags and the plurality of classes, a plurality of nodes for the graph data structure, wherein:
 a first node of the plurality of nodes is generated in a first class of the plurality of classes to represent a first tag of the plurality of tags mapped to the first class; and 
 a second node of the plurality of nodes is generated in a second class of the plurality of classes to represent a second tag of the plurality of tags mapped to the second class; and 
   generating an edge between the first node and the second node to represent a relationship of the plurality of relationships.   
     
     
         14 . A method of a gateway, comprising:
 receiving, by one or more processing circuits of the gateway, a plurality of tags describing a plurality of points of a piece of equipment of an environment;   generating, by the one or more processing circuits of the gateway, a first plurality of embeddings of the plurality of tags;   comparing, by the one or more processing circuits of the gateway, the first plurality of embeddings with a second plurality of embeddings of a plurality of classes of a schema of a graph data structure;   mapping, by the one or more processing circuits, at least a portion of the plurality of tags to the plurality of classes based on the comparison;   identifying, by the one or more processing circuits of the gateway, an order to execute a plurality of classification models for one tag of the plurality of tags based on a result of the comparison;   executing, by the one or more processing circuits of the gateway, the plurality of classification models according to the order for the one tag of the plurality of tags to map the one tag of the plurality of tags to one class of the plurality of classes of the schema of the graph data structure;   identifying, by the one or more processing circuits of the gateway, via machine learning, a plurality of relationships including relationship types selected from a plurality of available relationship types of the schema of the graph data structure between the plurality of tags mapped to the plurality of classes of the schema of the graph data structure; and   communicating, by the one or more processing circuits of the gateway, data to a system based at least in part on the plurality of tags mapped to the plurality of classes and the plurality of relationships.   
     
     
         15 . The method of  claim 14 , comprising:
 receiving, by the one or more processing circuits of the gateway, telemetry data from the piece of equipment; and   transmitting, by the one or more processing circuits of the gateway, the telemetry data to the system based at least in part on the plurality of tags mapped to the plurality of classes and the plurality of relationships.   
     
     
         16 . The method of  claim 14 , comprising:
 receiving, by the one or more processing circuits of the gateway, one or more software components from the system, the one or more software components configured to cause the one or more processing circuits to:
 receive and execute a service, the service configured to:
 map the plurality of tags to the plurality of classes; and 
 identify, via the machine learning, the plurality of relationships; 
 
   receiving, by the one or more processing circuits of the gateway, telemetry data from the piece of equipment; and   communicating, by the one or more processing circuits of the gateway, the telemetry data to the system based at least in part on the plurality of tags mapped to the plurality of classes and the plurality of relationships.   
     
     
         17 . The method of  claim 14 , comprising:
 generating, by the one or more processing circuits of the gateway, an embedding vector of a tag of the plurality of tags;   generating, by the one or more processing circuits of the gateway, a plurality of embedding vectors of the plurality of classes of the schema of the graph data structure;   generating, by the one or more processing circuits of the gateway, a plurality of similarity levels based on angles formed between the embedding vector of the tag and the plurality of embedding vectors of the plurality of classes of the schema of the graph data structure;   selecting, by the one or more processing circuits of the gateway, a class of the plurality of classes based on the plurality of similarity levels; and   mapping, by the one or more processing circuits of the gateway, the tag to the class responsive to the selection of the class.   
     
     
         18 . The method of  claim 14 , comprising:
 receiving, by the one or more processing circuits of the gateway, an indication that similarities between an embedding of one tag of the plurality of tags and the second plurality of embeddings of the plurality of classes of the schema of the graph data structure are less than a threshold;   receiving, by the one or more processing circuits of the gateway, timeseries data for a point represented by the one tag of the plurality of tags; and   determining, by the one or more processing circuits of the gateway, the order to execute the plurality of classification models comprising a first model and a second model to process the timeseries data,
 the first model outputting a first probability of the point being mapped to a first class of the plurality of classes; and 
 the second model outputting a second probability of the point being mapped to a second class of the plurality of classes, 
 the order indicating to process the timeseries data with the first model and then the second model responsive to an identification of a first similarity between the embedding of the one tag of the plurality of tags and a first embedding of the first class being greater than the embedding of the one tag of the plurality of tags and a second embedding of the second class; and 
   processing, by the one or more processing circuits of the gateway, the timeseries data with the first model and then the second model.   
     
     
         19 . One or more computer readable media storing instructions thereon, that, when executed by one or more processors, cause the one or more processors to perform operations comprising:
 receiving a plurality of tags describing a plurality of points of a piece of equipment of an environment;   generating a first plurality of embeddings of the plurality of tags;   comparing the first plurality of embeddings with a second plurality of embeddings of a plurality of classes of a schema of a graph data structure;   mapping at least a portion of the plurality of tags to the plurality of classes based on the comparison;   identifying an order to execute a plurality of classification models for one tag of the plurality of tags based on a result of the comparison;   executing the plurality of classification models according to the order for the one tag of the plurality of tags to map the one tag of the plurality of tags to one class of the plurality of classes of the schema of the graph data structure;   identifying via machine learning, a plurality of relationships including relationship types selected from a plurality of available relationship types of the schema of the graph data structure between the plurality of tags mapped to the plurality of classes of the schema of the graph data structure; and   communicating data to a system based at least in part on the plurality of tags mapped to the plurality of classes and the plurality of relationships.   
     
     
         20 . The one or more computer readable media of  claim 19 , the operations comprising:
 performing a first clustering to cluster the plurality of points based on characteristics of the plurality of points;   performing a second clustering to cluster the plurality of points based on at least one layout of the environment;   merging results of the first clustering and the second clustering; and   identifying the plurality of relationships of the schema of the graph data structure based on the result.