System and method to control a cross domain workflow based on a hierarchical engine framework
Provided are a system and method for controlling a workflow across domains on the basis of a hierarchical engine framework. Inventive workflow control makes it possible to configure a flexible hierarchical engine framework and provide a workflow service with low latency. Also, the system and method make it possible to control a workflow by building an engine and a data pipeline across domains.
1. A workflow control system for controlling a workflow based on a hierarchical engine framework, the workflow control system comprising:
an edge system comprising an edge networking entity configured to provide connectivity with a terminal, an intelligent computing entity configured to execute at least one engine for analyzing data of the terminal collected through the edge networking entity and processing a workflow, and an edge gateway entity configured to provide a function of interworking with another system through a data pipeline built based on the hierarchical engine framework; and
an intelligent control system configured to control the workflow based on the at least one engine and the data pipeline,
wherein the hierarchical engine framework is an architecture in which engines of an engine group executing a workflow are structured according to layers, and
wherein the data pipeline is a data path for transferring the data collected or analyzed by the edge system from the edge system to the other system.
2. The workflow control system of claim 1 , further comprising a cluster server group,
wherein the cluster server group comprises:
an engine node configured to execute at least one engine to process the workflow based on data received from the edge system; and
a gateway node configured to provide interworking with the edge system through the data pipeline built based on the hierarchical engine framework.
3. The workflow control system of claim 2 , wherein the gateway node provides a data input and output function to the at least one engine through the data pipeline according to the workflow.
4. An intelligent edge computing system comprising:
a plurality of edge systems each comprising an edge networking entity configured to provide connectivity with a terminal, an intelligent computing entity configured to analyze data of the terminal collected through the edge networking entity, and an edge gateway entity configured to provide interworking with another edge system through a data pipeline built based on a hierarchical engine framework; and
an edge identity management entity configured to separately manage identity information of the edge networking entities, the intelligent computing entities, and the edge gateway entities,
wherein the hierarchical engine framework is an architecture in which engines of an engine group executing a workflow are structured according to layers, and
wherein the data pipeline is a data path for transferring the data collected or analyzed by the edge system from the edge system to the other edge system.
5. The intelligent edge computing system of claim 4 , wherein the plurality of edge systems comprise a first edge system and a second edge system, and
when a request for connection with the second edge system is received from the edge gateway entity of the first edge system, the edge identity management entity searches for a location of the second edge system and transmits the connection request to the edge gateway entity of the second edge system.
6. The intelligent edge computing system of claim 4 , wherein the plurality of edge systems comprise a first edge system and a second edge system, and
when the second edge system receives a connection request of the first edge system from the edge identity management entity through the edge gateway entity of the second edge system, the edge gateway entity of the second edge system requests the intelligent computing entity of the second edge system to authorize the connection request, the intelligent computing entity of the second edge system authorizes the connection request and transfers a reply to the connection request to the edge gateway entity of the second edge system, and the edge gateway entity of the second edge system prepares to establish the connection and transmits the reply to the edge gateway entity of the first edge system.
7. The intelligent edge computing system of claim 4 , wherein the plurality of edge systems comprise a first edge system and a second edge system,
the intelligent computing entity of the first edge system transmits a request for connection with the second edge system to the edge identity management entity through the edge gateway entity of the first edge system and receives a reply to the connection request from the second edge system through the edge gateway entity of the first edge system, and
the edge gateway entity of the first edge system configures a connection with the edge gateway entity of the second edge system and forwards a reply including a result of the connection to the intelligent computing entity of the first edge system.
8. The intelligent edge computing system of claim 4 , wherein the plurality of edge systems comprise a first edge system and a second edge system,
the first edge system analyzes a service profile in a first domain and poses a query to the edge identity management entity to find a relevant engine container,
the edge identity management entity searches an engine database of the first domain and forwards the query to a cloud server when the relevant engine container is not present,
an intelligent control system in a second domain forwards the query to the second edge system through a cluster server group of the second domain, when the cloud server forwards the query to the intelligent control system in the second domain, and when an engine framework having the relevant engine container is present in the second domain,
the second edge system transfers a reply to the query to the first edge system through the cluster server group in the second domain, the cloud server, the edge identity management entity, and
the edge gateway entity of the first edge system and the edge gateway entity of the first edge system are connected with the data pipeline.
9. An edge system for processing a workflow based on a hierarchical engine framework, the edge system comprising:
an edge networking entity configured to provide connectivity with a terminal;
an intelligent computing entity configured to execute at least one engine for analyzing data of the terminal collected through the edge networking entity and processing a workflow; and
an edge gateway entity configured to provide interworking with another system through a data pipeline built based on the hierarchical engine framework,
wherein the hierarchical engine framework is an architecture in which engines of an engine group executing a workflow are structured according to layers, and
wherein the data pipeline is a data path for transferring the data collected or analyzed by the edge system from the edge system to the other system.
10. The edge system of claim 9 , wherein the other system is another edge system in a domain identical to a domain of the edge system, and
the edge system sequentially interworks with the other edge system through the data pipeline, the hierarchical engine framework on which the data pipeline is based being a horizontal engine framework.
11. The edge system of claim 9 , wherein the other system is a cluster server group in a domain identical to a domain of the edge system, and
the edge system hierarchically interworks with the cluster server group through the data pipeline.
12. The edge system of claim 9 , wherein the other system is another edge system or a cluster server group, and
the data pipeline is a data path for transferring the data analyzed by the intelligent computing entity to the other edge system or the cluster server group through the edge gateway entity.