数据映射是集成中的关键元素。大多数杰出的集成工具为数据映射提供了不同的功能。在本文中,想到了如何在Kumologica中实现数据映射的共享。Kumologica使用JSONata作为数据映射的基础。JSONata是用于JSON数据的轻量级查询和转换语言。它支持可以用最少的语法实现的复杂查询表达式,并且具有Xpath 3.1的位置路径语义。
要了解Kumologica数据映射,请创建一个API,该API将接受JSON数据作为API请求,并将其映射到新的JSON数据结构并作为API响应提供。映射完成后,请求JSON数据也将按降序排序。Kumologica数据映射器节点将同时实现映射和排序功能。
前提条件
1.下载并安装了Kumologica Designer。(必需)
2.教程演练(可选)。
开发API
1.打开Kumologica Designer并创建一个新项目。
2.将EventListener节点从面板拖放到设计器画布上。
3.使用Source作为API Gateway配置EventListener节点。动词为POST ,路径为/ employee。
4.将数据映射器节点从面板拖放到设计器上。
5.在datamapper节点的Sample Input部分上,粘贴以下内容:
[
{
"Candidate_Name" : "Arun",
"Candidate_Age" : "25"
},
{
"Candidate_Name" : "John",
"Candidate_Age" : "32"
},
{
"Candidate_Name" : "Sarah",
"Candidate_Age" : "22"
},
{
"Candidate_Name" : "Harry",
"Candidate_Age" : "28"
}
]
在数据映射器节点的“ 映射”部分上,粘贴以下映射表达式。
$sort(
$map(
msg,
(
function($l){
{
"EmpName" : $l.Candidate_Name,
"Emp_Age" : $l.Candidate_Age
}
}
)
),
function($l,$r){$l.Emp_Age < $r.Emp_Age}
)
在datamapper节点的Result部分(底部)上,您可以看到针对提供的样本输入JSON数据运行映射表达式后,该节点将生成的结果输出。以下是结果输出。
[
{
"EmpName": "Jhon",
"Emp_Age": "32"
},
{
"EmpName": "Harry",
"Emp_Age": "28"
},
{
"EmpName": "Arun",
"Emp_Age": "25"
},
{
"EmpName": "Sarah",
"Emp_Age": "22"
}
]
如您所见,显示的Result输出已将JSON请求映射到新结构,并且还按降序对记录进行了排序。
6.现在,将EventListener End节点拖放到画布上。
7.打开EventListener End的设置,并将有效负载配置为msg.payload,并将其余的值保留为默认值。
8.将EventListener节点连接到Datamapper节点,并将Datamapper节点连接到EventListenerEnd节点。
部署方式
现在,将流程部署到AWS lambda。部署之前,请在云选项卡下选择AWS配置文件。还要确保您选择的AWS配置文件具有关联的Kumologica Designer角色。如果未关联适当的角色,则该流程将无法部署到AWS。现在,单击Deploy。
部署完成后,您将获得端点URL,以从您喜欢的任何客户端调用服务。
Kumologica中的映射机制很简单,并且遵循函数链,从而可以用最少的语法构建复杂的查询表达式。设计人员可以快速预览,而无需部署和运行整个流程,从而节省了大量时间。JSONata表达式语言看起来或多或少类似于Mulesoft Dataweave。因此,如果您熟悉dataweave,那么JSONata将需要零或最小的学习曲线。想了解更多关于大数据的信息,请继续关注中培伟业。