[發明專利]一種數據集成化處理方法

在審

• 申請號: 201911420185.0
• 申請日: 2019-12-31
• 公開（公告）號: CN111158657A
• 公開（公告）日: 2020-05-15
• 發明（設計）人: 師尊俐
• 申請（專利權）人: 上海富勒信息科技有限公司
• 主分類號: G06F8/20
• 分類號: G06F8/20;G06F16/25;G06Q10/10
• 代理公司: 暫無信息
• 代理人: 暫無信息

1.一種數據集成化處理方法，其特征在于：利用包括但不限于Zookeeper、nginx、Kafka,、Redis,、MongoDB和關系數據庫，構建消息處理和存儲分析，通過適配器對數據進行集成處理，具體包括如下步驟：

S1、定義消息集，將所有消息統一歸屬為一個消息集分類；

S2、定義消息源，用于消息的主動獲取來源和發送目的地；

S3、定義消息，定義消息的入向、出向和應答。

2.根據權利要求1所述一種數據集成化處理方法，其特征在于：所述定義消息的步驟包括定義消息入向適配器、定義消息入向結構、定義消息入向Mapping、定義消息處理規則、定義消息出向適配器、定義消息出向結構和定義消息出向Mapping。

3.根據權利要求2所述一種數據集成化處理方法，其特征在于：所述定義消息入向適配器為選擇匹配消息來源的適配器，并設置適配器參數，FESTful適配器包括對應的字符集、Content-Type ,Http 連接參數，Http超時時間。

4.根據權利要求2所述一種數據集成化處理方法，其特征在于：所述定義消息入向結構為定義消息中的結構路徑與系統中結構路徑的對應關系，結構之間的隸屬關聯，消息中結構路徑根據消息體構成方式包括Xpath 表達式、固定字符串標識和SAP 表名。

5.根據權利要求2所述一種數據集成化處理方法，其特征在于：定義消息入向Mapping為定義每層的消息結構中對應的消息字段，完成具體的消息信息提取，包括定義每個消息字段的數值類型，長度，合法性校驗。

6.根據權利要求2所述一種數據集成化處理方法，其特征在于：所述定義消息處理規則為通過SQL規則、JS腳本、XQUERY和Java 代碼規則對消息做清洗轉換處理。

7.根據權利要求2所述一種數據集成化處理方法，其特征在于：所述定義消息出向結構為定義每個出項數據的消息結構，包括XML 結構節點、SAP 一個表結構和IDOC 結構。

8.根據權利要求2所述一種數據集成化處理方法，其特征在于：定義消息出向Mapping為根據每層的消息結構提取具體的消息映射信息完成后續的消息流轉和消息業務處理。

9.根據權利要求1所述一種數據集成化處理方法，其特征在于：所述定義消息集為設置一類消息共有屬性，包括語言特征、業務特征。