[發(fā)明專利]數(shù)據(jù)交換方法、裝置以及電子設(shè)備

在審

• 申請?zhí)枺?/td>: 202011643760.6
• 申請日: 2020-12-30
• 公開（公告）號: CN112862245A
• 公開（公告）日: 2021-05-28
• 發(fā)明（設(shè)計）人: 任亮;傅雨梅;李孟
• 申請（專利權(quán)）人: 北京知因智慧科技有限公司
• 主分類號: G06Q10/06
• 分類號: G06Q10/06;G06Q40/04;G06Q40/06;G06F16/36
• 代理公司: 北京超凡宏宇專利代理事務(wù)所(特殊普通合伙) 11463
• 代理人: 張萌

本申請?zhí)峁┝艘环N數(shù)據(jù)交換方法、裝置以及電子設(shè)備，涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，緩解了數(shù)據(jù)交換性能較低的技術(shù)問題。該方法包括：響應(yīng)于針對第一數(shù)據(jù)層中的第一數(shù)據(jù)源的選擇操作，在第二數(shù)據(jù)層中查找所述第一數(shù)據(jù)源匹配的第二數(shù)據(jù)源；基于所述第一數(shù)據(jù)源和所述第二數(shù)據(jù)源，利用預(yù)設(shè)函數(shù)生成目標(biāo)鏈路，所述目標(biāo)鏈路用于交換所述第一數(shù)據(jù)源和所述第二數(shù)據(jù)源；執(zhí)行所述目標(biāo)鏈路，并交換所述第一數(shù)據(jù)源和所述第二數(shù)據(jù)源。

技術(shù)領(lǐng)域

本申請涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，尤其是涉及一種數(shù)據(jù)交換方法、裝置以及電子設(shè)備。

背景技術(shù)

目前，由于金融行業(yè)的公司是面向toB(要約收購)的，公司主要的工作內(nèi)容是數(shù)據(jù)交換，主要的交換對象是客戶的大數(shù)據(jù)集群等數(shù)據(jù)，具體的交換方法大多是開發(fā)人員編寫多種API傳輸數(shù)據(jù)，或者開發(fā)人員使用編程語言調(diào)用JDBC傳輸數(shù)據(jù)，或者用些簡單的組件傳輸數(shù)據(jù)。

但是，當(dāng)客戶的大數(shù)據(jù)集群種類特別多時，會需要多種異構(gòu)數(shù)據(jù)源及多種計算引擎，現(xiàn)有的技術(shù)方案只能支撐一些簡單的數(shù)據(jù)源交換，不能滿足針對多種大數(shù)據(jù)集群的交換場景，導(dǎo)致數(shù)據(jù)交換的實現(xiàn)方法較難。

發(fā)明內(nèi)容

本申請的目的在于提供一種數(shù)據(jù)交換方法、裝置以及電子設(shè)備，以緩解數(shù)據(jù)交換性能較低的技術(shù)問題。

第一方面，本申請實施例提供了一種所述數(shù)據(jù)的結(jié)構(gòu)中包括：多個數(shù)據(jù)層，每個所述數(shù)據(jù)層中存在數(shù)據(jù)源，所述方法包括：

響應(yīng)于針對第一數(shù)據(jù)層中的第一數(shù)據(jù)源的選擇操作，在第二數(shù)據(jù)層中查找所述第一數(shù)據(jù)源匹配的第二數(shù)據(jù)源；

基于所述第一數(shù)據(jù)源和所述第二數(shù)據(jù)源，利用預(yù)設(shè)函數(shù)生成目標(biāo)鏈路，所述目標(biāo)鏈路用于交換所述第一數(shù)據(jù)源和所述第二數(shù)據(jù)源；

執(zhí)行所述目標(biāo)鏈路，并交換所述第一數(shù)據(jù)源和所述第二數(shù)據(jù)源。

在一個可能的實現(xiàn)中，所述響應(yīng)于針對第一數(shù)據(jù)層中的第一數(shù)據(jù)源的選擇操作，在第二數(shù)據(jù)層中查找所述第一數(shù)據(jù)源匹配的第二數(shù)據(jù)源的步驟，包括：

響應(yīng)于針對第一數(shù)據(jù)層中的第一數(shù)據(jù)源的選擇操作，確定所述第一數(shù)據(jù)源的類型；

在第二數(shù)據(jù)層中查找所述類型匹配的第二數(shù)據(jù)源。

在一個可能的實現(xiàn)中，所述目標(biāo)鏈路包括：

將所述第一數(shù)據(jù)源交換到所述第二數(shù)據(jù)層的第一目標(biāo)鏈路，以及將所述第二數(shù)據(jù)源交換到所述第一數(shù)據(jù)層的第二目標(biāo)鏈路。

在一個可能的實現(xiàn)中，所述執(zhí)行所述目標(biāo)鏈路的步驟，包括：

對所述目標(biāo)鏈路進行解析，得到相應(yīng)的DAG視圖，所述DAG視圖中存在多個節(jié)點；

按照DAG視圖中的多個所述節(jié)點的指向順序執(zhí)行所述鏈路。

在一個可能的實現(xiàn)中，所述方法還包括：

基于所述數(shù)據(jù)源建立事件模型，所述事件模型的功能包括：導(dǎo)入所述數(shù)據(jù)源、導(dǎo)出所述數(shù)據(jù)源及停止交換所述數(shù)據(jù)源。

在一個可能的實現(xiàn)中，所述交換所述第一數(shù)據(jù)源和所述第二數(shù)據(jù)源的步驟，包括：

通過所述事件模型的導(dǎo)出所述數(shù)據(jù)源的功能，將所述第一數(shù)據(jù)源由所述第一數(shù)據(jù)層導(dǎo)出，傳輸至所述第二數(shù)據(jù)層；

通過所述事件模型的導(dǎo)入所述數(shù)據(jù)源的功能，將所述第二數(shù)據(jù)源由所述第二數(shù)據(jù)層導(dǎo)出，傳輸至所述第一數(shù)據(jù)層。

在一個可能的實現(xiàn)中，所述方法還包括：

當(dāng)執(zhí)行第一目標(biāo)鏈路失敗時，對所述第一目標(biāo)鏈路添加第一標(biāo)識，所述第一標(biāo)識用于表示所述第一目標(biāo)鏈路執(zhí)行失敗；

當(dāng)執(zhí)行第二目標(biāo)鏈路失敗時，對所述第二目標(biāo)鏈路添加第二標(biāo)識，所述第二標(biāo)識用于表示所述第二目標(biāo)鏈路執(zhí)行失敗；