[發明專利]一種數據交換方法和裝置

有效

• 申請號: 201710121280.5
• 申請日: 2017-03-02
• 公開（公告）號: CN106888264B
• 公開（公告）日: 2019-09-17
• 發明（設計）人: 王建毅;鄭高;褚占峰;江峰;李晶
• 申請（專利權）人: 杭州數夢工場科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京博思佳知識產權代理有限公司 11415
• 代理人: 陳蕾

1.一種數據交換方法，應用于數據交換系統中的服務端，其特征在于，所述數據交換系統還包括至少兩個Kettle客戶端，所述Kettle客戶端運行在指定模式，且在指定模式下，所述Kettle客戶端具有超文本傳輸協議HTTP服務功能，并通過監聽所述服務端的請求來運行與所述請求匹配的任務，所述方法包括：

向至少兩個Kettle客戶端中的第一Kettle客戶端發送第一類參數，以使所述第一Kettle客戶端根據所述第一類參數創建針對第一子數據庫的第一數據源；向所述至少兩個Kettle客戶端中的第二Kettle客戶端發送第二類參數，以使所述第二Kettle客戶端根據所述第二類參數創建針對第二子數據庫的第二數據源；

向第一Kettle客戶端發送第一控制消息，以使第一Kettle客戶端根據所述第一數據源從所述第一子數據庫中抽取數據，并將抽取的數據存儲到中心數據庫；

向第二Kettle客戶端發送第二控制消息，以使第二Kettle客戶端從中心數據庫中抽取數據，并根據所述第二數據源將抽取的數據存儲到所述第二子數據庫。

2.根據權利要求1所述的方法，其特征在于，

所述向第一Kettle客戶端發送第一控制消息之后，所述向第二Kettle客戶端發送第二控制消息之前，所述方法還包括：

接收所述第一Kettle客戶端發送的統計信息，所述統計信息包括抽取狀態；若所述抽取狀態為未完成，則禁止向第二Kettle客戶端發送第二控制消息；若所述抽取狀態為已完成，則執行向第二Kettle客戶端發送第二控制消息的過程。

3.根據權利要求2所述的方法，其特征在于，

所述第一類參數包括以下內容之一或者任意組合：所述第一子數據庫對應的統一資源定位符URL信息、認證信息、端口信息、schema信息、數據表信息；

所述第二類參數包括以下內容之一或者任意組合：所述第二子數據庫對應的URL信息、認證信息、端口信息、schema信息、數據表信息；

所述統計信息還包括以下內容之一或者任意組合：抽取結果、日志信息、歷史信息、執行時間、當前已抽取的數據數量、當前已抽取的數據速率。

4.根據權利要求1或2所述的方法，其特征在于，

所述向至少兩個Kettle客戶端中的第一Kettle客戶端發送第一類參數之前，所述方法還包括：通過WEB頁面接收用戶請求消息，所述用戶請求消息攜帶所述第一Kettle客戶端的地址信息以及所述第二Kettle客戶端的地址信息。

5.根據權利要求2所述的方法，其特征在于，

所述接收所述第一Kettle客戶端發送的統計信息之后，所述方法還包括：

通過WEB頁面展示所述統計信息。

6.一種數據交換裝置，應用于數據交換系統中的服務端，其特征在于，所述數據交換系統還包括至少兩個Kettle客戶端，所述Kettle客戶端運行在指定模式，且在指定模式下，所述Kettle客戶端具有超文本傳輸協議HTTP服務功能，并通過監聽所述服務端的請求來運行與所述請求匹配的任務，所述裝置包括：

第一發送模塊，用于向所述至少兩個Kettle客戶端中的第一Kettle客戶端發送第一類參數，以使所述第一Kettle客戶端根據所述第一類參數創建針對第一子數據庫的第一數據源；

第二發送模塊，用于向所述至少兩個Kettle客戶端中的第二Kettle客戶端發送第二類參數，以使所述第二Kettle客戶端根據所述第二類參數創建針對第二子數據庫的第二數據源；

第三發送模塊，用于向所述第一Kettle客戶端發送第一控制消息，以使所述第一Kettle客戶端根據所述第一數據源從所述第一子數據庫中抽取數據，并將抽取的數據存儲到中心數據庫；

第四發送模塊，用于向所述第二Kettle客戶端發送第二控制消息，以使所述第二Kettle客戶端從所述中心數據庫中抽取數據，并根據所述第二數據源將抽取的數據存儲到所述第二子數據庫。