[發(fā)明專利]一種異構(gòu)數(shù)據(jù)接入方法和裝置

在審

• 申請?zhí)枺?/td>: 201810535652.3
• 申請日: 2018-05-29
• 公開（公告）號: CN110543507A
• 公開（公告）日: 2019-12-06
• 發(fā)明（設(shè)計）人: 向鵬;何勝鋒;劉緒寧
• 申請（專利權(quán)）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F16/25
• 分類號: G06F16/25
• 代理公司: 11262 北京安信方達知識產(chǎn)權(quán)代理有限公司
• 代理人: 李紅爽;栗若木<國際申請>=<國際公布>

1.一種異構(gòu)數(shù)據(jù)接入方法，其特征在于，包括：

根據(jù)異構(gòu)數(shù)據(jù)源的接口協(xié)議類型采用對應(yīng)的數(shù)據(jù)獲取方式接收所述數(shù)據(jù)源發(fā)送的源數(shù)據(jù)；

根據(jù)源數(shù)據(jù)的數(shù)據(jù)格式采用預(yù)設(shè)的轉(zhuǎn)換規(guī)則將所述源數(shù)據(jù)轉(zhuǎn)換為預(yù)設(shè)格式的數(shù)據(jù)；

按照預(yù)設(shè)的映射關(guān)系根據(jù)預(yù)設(shè)格式的數(shù)據(jù)生成事件數(shù)據(jù)。

2.如權(quán)利要求1所述的方法，其特征在于：還包括：

對所述事件數(shù)據(jù)進行過濾，獲得并保存觸發(fā)事件。

3.如權(quán)利要求1所述的方法，其特征在于：所述數(shù)據(jù)獲取方式包括：

主動輪詢數(shù)據(jù)源接口的方式或者監(jiān)聽數(shù)據(jù)源接口的消息的方式。

4.如權(quán)利要求1或3所述的方法，其特征在于：根據(jù)異構(gòu)數(shù)據(jù)源的接口協(xié)議類型采用對應(yīng)的數(shù)據(jù)獲取方式接收所述數(shù)據(jù)源發(fā)送的源數(shù)據(jù)包括：

根據(jù)異構(gòu)數(shù)據(jù)源應(yīng)用程序編程接口的特點和業(yè)務(wù)方的開發(fā)能力選擇對應(yīng)的數(shù)據(jù)獲取方式；

利用選擇的數(shù)據(jù)獲取方式接收所述數(shù)據(jù)源發(fā)送的源數(shù)據(jù)。

5.如權(quán)利要求1所述的方法，其特征在于：根據(jù)源數(shù)據(jù)的數(shù)據(jù)格式采用預(yù)設(shè)的轉(zhuǎn)換規(guī)則將所述源數(shù)據(jù)轉(zhuǎn)換為預(yù)設(shè)格式的數(shù)據(jù)包括：

根據(jù)源數(shù)據(jù)的數(shù)據(jù)格式采用預(yù)設(shè)的轉(zhuǎn)換規(guī)則將所述源數(shù)據(jù)轉(zhuǎn)換為JSON數(shù)組格式的數(shù)據(jù)。

6.如權(quán)利要求5所述的方法，其特征在于：

源數(shù)據(jù)的數(shù)據(jù)格式包括：XML格式，或者字符串?dāng)?shù)組，單一字符串。

7.如權(quán)利要求1所述的方法，其特征在于：根據(jù)預(yù)設(shè)的映射關(guān)系將轉(zhuǎn)換格式后的所述源數(shù)據(jù)生成事件數(shù)據(jù)包括：

根據(jù)用戶設(shè)定或者選擇的映射關(guān)系確定所述源數(shù)據(jù)的事件字段，提取所述源數(shù)據(jù)的事件字段中的預(yù)設(shè)字段作為事件的元信息；

為所述事件設(shè)置唯一確定的索引；

將所述事件的元信息和索引合并成事件數(shù)據(jù)；

其中，所述元信息的含義和作用為預(yù)先約定或者配置。

8.如權(quán)利要求7所述的方法，其特征在于：確定所述映射關(guān)系包括：

根據(jù)用戶的選擇從源數(shù)據(jù)中確定關(guān)鍵字段作為事件字段，忽略其他未選中的數(shù)據(jù)字段，檢測用戶的編排操作，將所述編排過程保存為映射關(guān)系。

9.如權(quán)利要求8所述的方法，其特征在于：檢測用戶的編排操作，將所述編排過程保存為映射關(guān)系包括：

接收用戶使用圖形化工具預(yù)覽選擇的事件字段，將選擇的所述事件字段以樹形結(jié)構(gòu)組織在一起；

接收用戶對所述樹形結(jié)構(gòu)組織結(jié)構(gòu)編排，將所述編排的過程保存為映射關(guān)系。

10.如權(quán)利要求2所述的方法，其特征在于：對所述事件數(shù)據(jù)進行過濾，獲得并保存觸發(fā)事件包括：

根據(jù)預(yù)設(shè)校驗規(guī)則對事件數(shù)據(jù)進行校驗，刪除不滿足校驗規(guī)則的所述事件數(shù)據(jù)，或者，刪除已保存的不滿足校驗規(guī)則的觸發(fā)事件，保存所述事件數(shù)據(jù)。

11.一種異構(gòu)數(shù)據(jù)接入裝置，其特征在于，包括：

適配器模塊，設(shè)置為根據(jù)異構(gòu)數(shù)據(jù)源的接口協(xié)議類型采用對應(yīng)的數(shù)據(jù)獲取方式接收所述數(shù)據(jù)源發(fā)送的源數(shù)據(jù)；

轉(zhuǎn)換模塊，設(shè)置為根據(jù)源數(shù)據(jù)的數(shù)據(jù)格式采用預(yù)設(shè)的轉(zhuǎn)換規(guī)則將所述源數(shù)據(jù)轉(zhuǎn)換為預(yù)設(shè)格式的數(shù)據(jù)；

生成模塊，設(shè)置為按照預(yù)設(shè)的映射關(guān)系根據(jù)預(yù)設(shè)格式的數(shù)據(jù)生成事件數(shù)據(jù)。

12.如權(quán)利要求11所述的裝置，其特征在于：還包括：

存儲模塊，設(shè)置為對所述事件數(shù)據(jù)進行過濾，獲得并保存觸發(fā)事件。

13.如權(quán)利要求11所述的裝置，其特征在于：所述適配器模塊數(shù)據(jù)獲取方式包括：

主動輪詢數(shù)據(jù)源接口的方式或者監(jiān)聽數(shù)據(jù)源接口的消息的方式。