數據映射是集成中的關鍵元素。大多數杰出的集成工具為數據映射提供了不同的功能。在本文中,想到了如何在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將需要零或最小的學習曲線。想了解更多關于大數據的信息,請繼續關注中培偉業。