Configurable integration infrastructure service in software architecture
A method including identifying, a first message of a plurality of messages to be handled by a first controller, the first message representing a first data, obtaining a syntax information of the first message, obtaining a logical information of the first message, including a first data unit type, obtaining a semantic information of the first message, the semantic information including a concept represented by the first message, identifying a second message of the plurality of messages, the second message being handled by a second controller, wherein the second message is compatible with the first message, wherein the second message has the same syntax information, the same logical information, or the same semantic information as the first message, determining a data transformation to convert the second message to the first message, and generating a pipeline of primitive code blocks to perform the data transformation on the first controller.
1 . A method, comprising:
identifying, by a first controller, a first message of a plurality of messages to be handled by the first controller, wherein the first message represents first data;
obtaining, by the first controller, a syntax information of the first message;
obtaining, by the first controller, a logical information of the first message, the logical information of the first message including a first data unit type;
obtaining, by the first controller, a semantic information of the first message, the semantic information including a concept represented by the first message;
identifying, by the first controller, a second message of the plurality of messages,
wherein the second message is being handled by a second controller,
wherein the second message is compatible with the first message, and
wherein the second message has at least one of the same syntax information, the same logical information, or the same semantic information as the first message;
determining, by the first controller, a data transformation to convert the second message to the first message;
generating, by the first controller, a pipeline of primitive code blocks to perform the data transformation on the first controller;
querying, by the first controller, a data model for information about the plurality of messages; and
obtaining, by the first controller, the syntax information, the logical information, and the semantic information of the first message from a response to the querying of the data model.
2 . The method of claim 1 , wherein the syntax information of the first message includes a first data value, a first data position and a first data representation.
3 . The method of claim 2 , wherein a syntax information of the second message includes a second data value, a second data position, and a second data representation, and wherein one of the second data value, the second data position, or the second data representation is different than one of the first data value, the first data position, or the first data representation.
4 . The method of claim 1 , wherein the second message has the same logical information as the first message, and wherein the data transformation converts the syntax information of the second message to the syntax information of the first message.
5 . The method of claim 1 , wherein the second message has the same semantic information as the first message, and wherein the data transformation converts the logical information of the second message to the logical information of the first message.
6 . The method of claim 1 , wherein the pipeline of primitive code blocks includes primitive code for performing at least one of filter, split, join, transform, or queue operations.
7 . A non-transitory machine-readable medium having stored thereon instructions for performing a method of generating a pipeline of primitive code blocks for performing a data transformation, comprising machine executable code which when executed by a processor, causes the processor to:
identify a first message of a plurality of messages, wherein the first message represents first data;
obtain a syntax information of the first message;
obtain a logical information of the first message, the logical information of the first message including a first data unit type;
obtain a semantic information of the first message, the semantic information including a concept represented by the first message;
identify a second message of the plurality of messages,
wherein the second message is being handled by a second controller,
wherein the second message is compatible with the first message, and
wherein the second message has at least one of the same syntax information, the same logical information, or the same semantic information as the first message;
determine the data transformation to convert the second message to the first message;
generate the pipeline of primitive code blocks to perform the data transformation;
query a data model for information about the plurality of messages; and
obtain the syntax information, the logical information, and the semantic information of the first message from a response to the query of the data model.
8 . The non-transitory machine-readable medium of claim 7 , wherein the syntax information of the first message includes a first data value, a first data position and a first data representation.
9 . The non-transitory machine-readable medium of claim 8 , wherein a syntax information of the second message includes a second data value, a second data position, and a second data representation, and wherein one of the second data value, the second data position, or the second data representation is different than one of the first data value, the first data position, or the first data representation.
10 . The non-transitory machine-readable medium of claim 7 , wherein the second message has the same logical information as the first message, and wherein the data transformation converts the syntax information of the second message to the syntax information of the first message.
11 . The non-transitory machine-readable medium of claim 7 , wherein the second message has the same semantic information as the first message, and wherein the data transformation converts the logical information of the second message to the logical information of the first message.
12 . The non-transitory machine-readable medium of claim 7 , wherein the pipeline of primitive code blocks includes primitive code for performing at least one of filter, split, join, transform, or queue operations.
13 . A system, comprising:
a first controller;
a second controller in communication with the first controller;
a processor operatively coupled to the first controller; and
a memory operatively coupled to the processor, the memory comprising instructions stored thereon that, when executed by the processor, cause the processor to:
identify a first message of a plurality of messages to be handled by the first controller, wherein the first message represents first data;
obtain a syntax information of the first message;
obtain a logical information of the first message, the logical information of the first message including a first data unit type;
obtain a semantic information of the first message, the semantic information including a concept represented by the first message;
identify a second message of the plurality of messages,
wherein the second message is being handled by the second controller,
wherein the second message is compatible with the first message, and
wherein the second message has at least one of the same syntax information, the same logical information, or the same semantic information as the first message;
determine a data transformation to convert the second message to the first message;
generate a pipeline of primitive code blocks to perform the data transformation;
query a data model for information about the plurality of messages; and
obtain the syntax information, the logical information, and the semantic information of the first message from a response to the query of the data model.
14 . The system of claim 13 , wherein the syntax information of the first message includes a first data value, a first data position and a first data representation.
15 . The system of claim 14 , wherein a syntax information of the second message includes a second data value, a second data position, and a second data representation, and wherein one of the second data value, the second data position, or the second data representation is different than one of the first data value, the first data position, or the first data representation.
16 . The system of claim 13 , wherein the second message has the same logical information as the first message, and wherein the data transformation converts the syntax information of the second message to the syntax information of the first message.
17 . The system of claim 13 , wherein the second message has the same semantic information as the first message, and wherein the data transformation converts the logical information of the second message to the logical information of the first message.