[發(fā)明專利]目標(biāo)數(shù)據(jù)獲取方法、裝置和存儲介質(zhì)及電子裝置

有效

• 申請?zhí)枺?/td>: 202011641862.4
• 申請日: 2020-12-31
• 公開（公告）號: CN112699149B
• 公開（公告）日: 2023-09-19
• 發(fā)明（設(shè)計）人: 程殿虎
• 申請（專利權(quán)）人: 青島海爾科技有限公司;海爾智家股份有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F16/27
• 代理公司: 北京康信知識產(chǎn)權(quán)代理有限責(zé)任公司 11240
• 代理人: 周婷婷

本發(fā)明公開了一種目標(biāo)數(shù)據(jù)獲取方法、裝置和存儲介質(zhì)及電子裝置。其中，該方法包括：獲取目標(biāo)數(shù)據(jù)查詢請求，其中，目標(biāo)數(shù)據(jù)查詢請求用于請求獲取與目標(biāo)主鍵值匹配的目標(biāo)數(shù)據(jù)；在目標(biāo)主鍵值包括第一主鍵值的情況下，響應(yīng)目標(biāo)數(shù)據(jù)查詢請求，獲取分布式系統(tǒng)中與目標(biāo)主鍵值匹配的一條緩存數(shù)據(jù)，并將一條緩存數(shù)據(jù)確定為目標(biāo)數(shù)據(jù)，其中，分布式系統(tǒng)中存儲有N條緩存數(shù)據(jù)，N條緩存數(shù)據(jù)包括各自的第一主鍵值，N為大于或等于2的正整數(shù)；在目標(biāo)主鍵值包括第二主鍵值的情況下，響應(yīng)目標(biāo)數(shù)據(jù)查詢請求，獲取分布式系統(tǒng)中與目標(biāo)主鍵值匹配的至少兩條緩存數(shù)據(jù)，并根據(jù)至少兩條緩存數(shù)據(jù)確定為目標(biāo)數(shù)據(jù)。本發(fā)明解決了目標(biāo)數(shù)據(jù)獲取的靈活度較低的技術(shù)問題。

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

本發(fā)明涉及計算機(jī)領(lǐng)域，具體而言，涉及一種目標(biāo)數(shù)據(jù)獲取方法、裝置和存儲介質(zhì)及電子裝置。

背景技術(shù)

現(xiàn)階段越來越多的業(yè)務(wù)場景需要對數(shù)據(jù)進(jìn)行實時處理，實時計算任務(wù)越來越多，其中Spark及Flink作為實時計算領(lǐng)域優(yōu)秀的計算框架已經(jīng)得到大規(guī)模的應(yīng)用。早期的實時計算框架版本(如Spark?Streaming)僅支持單條數(shù)據(jù)流的變換操作，并不支持實時數(shù)據(jù)流的關(guān)聯(lián)計算或聚合計算。近期在時間窗口函數(shù)的支持下，實時計算框架新版本(如SparkStructured?Streaming與Flink)實現(xiàn)了由時間窗口函數(shù)覆蓋的實時數(shù)據(jù)的關(guān)聯(lián)聚合計算。

但現(xiàn)有實時計算框架大抵直接使用分布式內(nèi)存作為第一計算資源，從資源利用率的角度看，針對單項實時計算任務(wù)，內(nèi)存等資源不可無限添加。因此在處理兩項或多項實時數(shù)據(jù)流的關(guān)聯(lián)計算或聚合計算任務(wù)時，即使是實時計算框架新版本仍然只能使用時間窗口函數(shù)對實時數(shù)據(jù)流進(jìn)行部分內(nèi)容緩存，不能直接使用全局?jǐn)?shù)據(jù)進(jìn)行關(guān)聯(lián)或匯總，這大大限制了目標(biāo)數(shù)據(jù)的獲取場景。換言之，現(xiàn)有技術(shù)中存在因數(shù)據(jù)存儲的限制性較高，而導(dǎo)致的目標(biāo)數(shù)據(jù)的獲取靈活度較低的技術(shù)問題。

針對上述的問題，目前尚未提出有效的解決方案。

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

本發(fā)明實施例提供了一種目標(biāo)數(shù)據(jù)獲取方法、裝置和存儲介質(zhì)及電子裝置，以至少解決目標(biāo)數(shù)據(jù)獲取的靈活度較低的技術(shù)問題。

根據(jù)本發(fā)明實施例的一個方面，提供了一種目標(biāo)數(shù)據(jù)獲取方法，包括：獲取目標(biāo)數(shù)據(jù)查詢請求，其中，上述目標(biāo)數(shù)據(jù)查詢請求用于請求獲取與目標(biāo)主鍵值匹配的目標(biāo)數(shù)據(jù)；在上述目標(biāo)主鍵值包括第一主鍵值的情況下，響應(yīng)上述目標(biāo)數(shù)據(jù)查詢請求，獲取分布式系統(tǒng)中與上述目標(biāo)主鍵值匹配的一條緩存數(shù)據(jù)，并將上述一條緩存數(shù)據(jù)確定為上述目標(biāo)數(shù)據(jù)，其中，上述分布式系統(tǒng)中存儲有N條緩存數(shù)據(jù)，上述N條緩存數(shù)據(jù)包括各自的上述第一主鍵值，上述N為大于或等于2的正整數(shù)；在上述目標(biāo)主鍵值包括第二主鍵值的情況下，響應(yīng)上述目標(biāo)數(shù)據(jù)查詢請求，獲取上述分布式系統(tǒng)中與上述目標(biāo)主鍵值匹配的至少兩條緩存數(shù)據(jù)，并根據(jù)上述至少兩條緩存數(shù)據(jù)確定為上述目標(biāo)數(shù)據(jù)。

根據(jù)本發(fā)明實施例的另一方面，還提供了一種目標(biāo)數(shù)據(jù)獲取裝置，包括：第一獲取單元，用于獲取目標(biāo)數(shù)據(jù)查詢請求，其中，上述目標(biāo)數(shù)據(jù)查詢請求用于請求獲取與目標(biāo)主鍵值匹配的目標(biāo)數(shù)據(jù)；第一響應(yīng)單元，用于在上述目標(biāo)主鍵值包括第一主鍵值的情況下，響應(yīng)上述目標(biāo)數(shù)據(jù)查詢請求，獲取分布式系統(tǒng)中與上述目標(biāo)主鍵值匹配的一條緩存數(shù)據(jù)，并將上述一條緩存數(shù)據(jù)確定為上述目標(biāo)數(shù)據(jù)，其中，上述分布式系統(tǒng)中存儲有N條緩存數(shù)據(jù)，上述N條緩存數(shù)據(jù)包括各自的上述第一主鍵值，上述N為大于或等于2的正整數(shù)；第二響應(yīng)單元，用于在上述目標(biāo)主鍵值包括第二主鍵值的情況下，響應(yīng)上述目標(biāo)數(shù)據(jù)查詢請求，獲取上述分布式系統(tǒng)中與上述目標(biāo)主鍵值匹配的至少兩條緩存數(shù)據(jù)，并根據(jù)上述至少兩條緩存數(shù)據(jù)確定為上述目標(biāo)數(shù)據(jù)。

根據(jù)本發(fā)明實施例的又一方面，還提供了一種計算機(jī)可讀的存儲介質(zhì)，該計算機(jī)可讀的存儲介質(zhì)中存儲有計算機(jī)程序，其中，該計算機(jī)程序被設(shè)置為運行時執(zhí)行上述目標(biāo)數(shù)據(jù)獲取方法。

根據(jù)本發(fā)明實施例的又一方面，還提供了一種電子裝置，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機(jī)程序，其中，上述處理器通過計算機(jī)程序執(zhí)行上述的目標(biāo)數(shù)據(jù)獲取方法。