[發(fā)明專利]數(shù)據(jù)處理方法及相關(guān)裝置

在審

• 申請?zhí)枺?/td>: 202111583565.3
• 申請日: 2021-12-22
• 公開（公告）號: CN114328580A
• 公開（公告）日: 2022-04-12
• 發(fā)明（設(shè)計）人: 戴嘉樂;彭帥果
• 申請（專利權(quán)）人: 深圳市歡太數(shù)字科技有限公司
• 主分類號: G06F16/242
• 分類號: G06F16/242
• 代理公司: 廣州三環(huán)專利商標代理有限公司 44202
• 代理人: 熊永強

本申請?zhí)峁┝艘环N數(shù)據(jù)處理方法及相關(guān)裝置，所述方法包括：獲取原始數(shù)據(jù)，所述原始數(shù)據(jù)為流數(shù)據(jù)中的數(shù)據(jù)，所述原始數(shù)據(jù)至少包括通過第一數(shù)據(jù)源中間件獲取的第一數(shù)據(jù)，所述第一數(shù)據(jù)源中間件所采集數(shù)據(jù)不支持結(jié)構(gòu)化查詢語言SQL；根據(jù)所述原始數(shù)據(jù)確定適配SQL的目標數(shù)據(jù)；通過所述SQL處理所述目標數(shù)據(jù)，得到處理結(jié)果。這樣，實現(xiàn)了針對不支持SQL的原始數(shù)據(jù)的轉(zhuǎn)換處理，使得用戶能夠使用SQL處理轉(zhuǎn)換后的目標數(shù)據(jù)，避免服務(wù)器無法直接通過SQL便捷地對數(shù)據(jù)進行處理，提高原始數(shù)據(jù)處理的便捷性和效率。

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

本申請屬于數(shù)據(jù)處理領(lǐng)域，具體涉及一種數(shù)據(jù)處理方法及相關(guān)裝置。

背景技術(shù)

目前，服務(wù)器對異構(gòu)來源流數(shù)據(jù)進行實時處理時，一般是針對不同來源的數(shù)據(jù)類型調(diào)用不同的程序組件進行處理，這使得對異構(gòu)數(shù)據(jù)源的數(shù)據(jù)處理過程比較復(fù)雜，難以滿足用戶需求。

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

本申請?zhí)峁┝艘环N數(shù)據(jù)處理方法及相關(guān)裝置，以期提高對流數(shù)據(jù)處理的便捷性和效率。

第一方面，本申請實施例提供了一種數(shù)據(jù)處理方法，所述方法應(yīng)用于服務(wù)器，包括：

獲取原始數(shù)據(jù)，所述原始數(shù)據(jù)為流數(shù)據(jù)中的數(shù)據(jù)，所述原始數(shù)據(jù)至少包括通過第一數(shù)據(jù)源中間件獲取的第一數(shù)據(jù)，所述第一數(shù)據(jù)源中間件所采集數(shù)據(jù)不支持結(jié)構(gòu)化查詢語言SQL；

根據(jù)所述原始數(shù)據(jù)確定適配SQL的目標數(shù)據(jù)；

通過所述SQL處理所述目標數(shù)據(jù)，得到處理結(jié)果。

第二方面，本申請實施例提供了一種數(shù)據(jù)處理裝置，所述裝置包括：

獲取單元，用于獲取原始數(shù)據(jù)，所述原始數(shù)據(jù)為流數(shù)據(jù)中的數(shù)據(jù)，所述原始數(shù)據(jù)至少包括通過第一數(shù)據(jù)源中間件獲取的第一數(shù)據(jù)，所述第一數(shù)據(jù)源中間件所采集數(shù)據(jù)不支持結(jié)構(gòu)化查詢語言SQL；確定單元，用于根據(jù)所述原始數(shù)據(jù)確定適配SQL的目標數(shù)據(jù)；處理單元，用于通過所述SQL處理所述目標數(shù)據(jù)，得到處理結(jié)果。

第三方面，本申請實施例提供了一種服務(wù)器設(shè)備，包括處理器、存儲器、通信接口，以及一個或多個程序，所述一個或多個程序被存儲在所述存儲器中，并且被配置由所述處理器執(zhí)行，所述程序包括用于執(zhí)行本申請實施例第一方面中的步驟的指令。

第四方面，本申請實施例提供了一種計算機存儲介質(zhì)，其特征在于，存儲用于電子數(shù)據(jù)交換的計算機程序，其中，所述計算機程序使得計算機執(zhí)行如本實施例第一方面中所描述的部分或全部步驟。

第五方面，本申請實施例提供了一種計算機程序產(chǎn)品，其中，上述計算機程序產(chǎn)品包括存儲了計算機程序的非瞬時性計算機可讀存儲介質(zhì)，上述計算機程序可操作來使計算機執(zhí)行如本申請實施例第一方面中所描述的部分或全部步驟。

可以看出，本申請實施例中，服務(wù)器首先獲取原始數(shù)據(jù)，所述原始數(shù)據(jù)為流數(shù)據(jù)中的數(shù)據(jù)，所述原始數(shù)據(jù)至少包括通過第一數(shù)據(jù)源中間件獲取的第一數(shù)據(jù)，所述第一數(shù)據(jù)源中間件所采集數(shù)據(jù)不支持結(jié)構(gòu)化查詢語言SQL，然后根據(jù)所述原始數(shù)據(jù)確定適配SQL的目標數(shù)據(jù)，最后通過所述SQL處理所述目標數(shù)據(jù)，得到處理結(jié)果。這樣，實現(xiàn)了針對不支持SQL的原始數(shù)據(jù)的轉(zhuǎn)換處理，使得用戶能夠使用SQL處理轉(zhuǎn)換后的目標數(shù)據(jù)，避免服務(wù)器無法直接通過SQL便捷地對數(shù)據(jù)進行處理，提高原始數(shù)據(jù)處理的便捷性和效率。

附圖說明

為了更清楚地說明本申請實施例或現(xiàn)有技術(shù)中的技術(shù)方案，下面將對實施例或現(xiàn)有技術(shù)描述中所需要使用的附圖作簡單地介紹，顯而易見地，下面描述中的附圖僅僅是本申請的一些實施例，對于本領(lǐng)域普通技術(shù)人員來講，在不付出創(chuàng)造性勞動的前提下，還可以根據(jù)這些附圖獲得其他的附圖。

圖1是本申請實施例提供的一種數(shù)據(jù)處理系統(tǒng)的系統(tǒng)架構(gòu)圖；

圖2是本申請實施例提供的一種數(shù)據(jù)處理方法的流程示意圖；

圖3a是本申請實施例提供的一種數(shù)據(jù)源連接管理頁面的例圖；