Data mapping is a key element in integration. Most of the prominent integration tools provide different capabilities for data mapping. In this article I thought of sharing on how data mapping can be achieved in Kumologica. Kumologica uses JSONata as the base for data mapping. JSONata is a Lightweight query and transformation language for JSON data. It supports complex queries expression which can be achieved with minimal syntax and has a location path semantics of Xpath 3.1.
For more info on JSONata you may refer the following link. https://jsonata.org/
To understand the Kumologica data mapping lets create an API which will accept a JSON data as an API request which will be mapped to a new JSON data structure and provide as API response. The request JSON data will also be sorted in descending order when mapping is done. Kumologica data mapper node will achieve both mapping and sorting function together.
Now let’s get started.
Pre-requisite
Developing an API
[
{
"Candidate_Name" : "Arun",
"Candidate_Age" : "25"
},
{
"Candidate_Name" : "John",
"Candidate_Age" : "32"
},
{
"Candidate_Name" : "Sarah",
"Candidate_Age" : "22"
},
{
"Candidate_Name" : "Harry",
"Candidate_Age" : "28"
}
]
On the Mapping section of the datamapper node paste the following mapping expression.
$sort(
$map(
msg,
(
function($l){
{
"EmpName" : $l.Candidate_Name,
"Emp_Age" : $l.Candidate_Age
}
}
)
),
function($l,$r){$l.Emp_Age < $r.Emp_Age}
)
On the Result section (Bottom) of the datamapper node you could see the resultant output that would be generated by the node after running the mapping expression against the sample input JSON data provided. Following is the resultant output .
[
{
"EmpName": "Jhon",
"Emp_Age": "32"
},
{
"EmpName": "Harry",
"Emp_Age": "28"
},
{
"EmpName": "Arun",
"Emp_Age": "25"
},
{
"EmpName": "Sarah",
"Emp_Age": "22"
}
]
As you can see the Result output shown has mapped the JSON request to a new structure and also sorted the records in descending order.
6. Now Drag and drop the EventListener End node on to the canvas.
7. Open the settings for EventListener End and configure the payload as msg.payload and leave rest of the values as default.
8. Wire the EventListener node to Datamapper node and Datamapper node to EventListenerEnd node. The final flow would like as given below.
Deployment
Now let’s deploy the flow to AWS lambda. Before deployment select the AWS profile under the cloud tab. Also ensure that your AWS profile selected is having Kumologica Designer Role associated. If proper role is not associated the flow will fail to deploy to AWS.
Now Click Deploy .
Once the deployment is completed you will get the endpoint url to invoke the service from any of your favourite client. The url will look like as shown below.
https://t7cq0rkdk.execute-api.ap-southeast-1.amazonaws.com/test/employee
Conclusion
The mapping mechanism in Kumologica was easy and follows function chaining which allows to build sophisticated query expressions with minimal syntax. The designer gives quick preview without deploying and running the whole flow which saves a lot of time. JSONata expression language looks more or less similar to Mulesoft Dataweave. So If you are familiar with dataweave then JSONata would require zero or minimal learning curve.
If you want to try out this application you can clone the repo using the below given Github url or import the flow json into your project workspace in designer.
https://github.com/ab73863/kumologica-datamapper
References