[發(fā)明專利]一種基于高可配可變更的數(shù)據(jù)處理方法

在審

• 申請(qǐng)?zhí)枺?/td>: 201910960991.0
• 申請(qǐng)日: 2019-10-11
• 公開（公告）號(hào): CN110705891A
• 公開（公告）日: 2020-01-17
• 發(fā)明（設(shè)計(jì)）人: 崔晶晶;劉中洋
• 申請(qǐng)（專利權(quán)）人: 集奧聚合(北京)人工智能科技有限公司
• 主分類號(hào): G06Q10/06
• 分類號(hào): G06Q10/06
• 代理公司: 11617 北京瑞盛銘杰知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙)
• 代理人: 李績(jī)

1.一種基于高可配可變更的數(shù)據(jù)處理方法，其特征在于，包括如下步驟：

步驟S1，接入多數(shù)據(jù)源的高可配可變更數(shù)據(jù)；

步驟S2，根據(jù)接入的高可配可變更數(shù)據(jù)，自定義處理流程的工具模板，制定業(yè)務(wù)線的處理流程；

步驟S3，根據(jù)接入的高可配可變更數(shù)據(jù)，自定義處理邏輯的工具模板，執(zhí)行業(yè)務(wù)線的處理邏輯；

步驟S4，輸出處理邏輯的高可配可變更數(shù)據(jù)；

步驟S5，對(duì)輸出的高可配可變更數(shù)據(jù)，采用反射機(jī)制將步驟S2的業(yè)務(wù)線的處理流程和步驟S3的業(yè)務(wù)線的處理邏輯，反射到Flink，由Flink采用實(shí)時(shí)流處理技術(shù)，代為按照處理邏輯執(zhí)行業(yè)務(wù)線的處理流程；

步驟S6，執(zhí)行業(yè)務(wù)線的處理流程，進(jìn)行自動(dòng)化處理和私有化定制數(shù)據(jù)服務(wù)，得到目標(biāo)數(shù)據(jù)。

2.如權(quán)利要求1所述的基于高可配可變更的數(shù)據(jù)處理方法，其特征在于，在所述步驟S2和步驟S3中，采用java技術(shù)自定義處理流程的工具模板和處理邏輯的工具模板。

3.如權(quán)利要求1所述的基于高可配可變更的數(shù)據(jù)處理方法，其特征在于，在所述步驟S1中，依次采用工廠模式和抽象模式對(duì)高可配可變更數(shù)據(jù)進(jìn)行處理，以進(jìn)行多個(gè)等級(jí)數(shù)據(jù)的處理，實(shí)現(xiàn)高可配可可變更多數(shù)據(jù)源的數(shù)據(jù)接入。

4.如權(quán)利要求1所述的基于高可配可變更的數(shù)據(jù)處理方法，其特征在于，在所述步驟S3中，在基于已定義的數(shù)據(jù)處理邏輯的基礎(chǔ)上，進(jìn)一步增加制定針對(duì)多數(shù)據(jù)源的不同處理邏輯，包括但不限于文本、圖片、視頻、指紋的數(shù)據(jù)類型。

5.如權(quán)利要求1所述的基于高可配可變更的數(shù)據(jù)處理方法，其特征在于，在所述步驟S4中，對(duì)不同數(shù)據(jù)輸出位置采用不同的數(shù)據(jù)處理邏輯，包括但不限于關(guān)系型數(shù)據(jù)庫、非關(guān)系型數(shù)據(jù)庫和文件存儲(chǔ)系統(tǒng)。

6.如權(quán)利要求1所述的基于高可配可變更的數(shù)據(jù)處理方法，其特征在于，

(1)對(duì)Objcet進(jìn)行基礎(chǔ)配置；

(2)對(duì)接數(shù)據(jù)請(qǐng)求方數(shù)據(jù)；

(3)Flink通過廣播實(shí)現(xiàn)對(duì)數(shù)據(jù)請(qǐng)求方數(shù)據(jù)的具體消費(fèi)；

(4)Object對(duì)自定義接口實(shí)現(xiàn)配置輸入輸出；

(5)通過執(zhí)行器反射技術(shù)完成對(duì)業(yè)務(wù)class類方法的加載；

(6)執(zhí)行器獲取Object基礎(chǔ)配置和對(duì)業(yè)務(wù)class類方法的加載，遠(yuǎn)程實(shí)現(xiàn)實(shí)例化接口對(duì)象；

(7)自定義接口對(duì)目標(biāo)數(shù)據(jù)實(shí)現(xiàn)具體接口邏輯。