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

有效

• 申請(qǐng)?zhí)枺?/td>: 201811354268.X
• 申請(qǐng)日: 2018-11-14
• 公開（公告）號(hào): CN109542903B
• 公開（公告）日: 2022-02-25
• 發(fā)明（設(shè)計(jì)）人: 鄧及翔;朱虹;吳崇龍
• 申請(qǐng)（專利權(quán)）人: 珠海格力智能裝備有限公司;珠海格力電器股份有限公司
• 主分類號(hào): G06F16/22
• 分類號(hào): G06F16/22;G06F16/23
• 代理公司: 北京康信知識(shí)產(chǎn)權(quán)代理有限責(zé)任公司 11240
• 代理人: 趙囡囡;董文倩

本發(fā)明公開了一種數(shù)據(jù)處理方法及裝置。其中，該方法包括：獲取預(yù)設(shè)數(shù)據(jù)接口傳輸?shù)臄?shù)據(jù)；解析數(shù)據(jù)，得到操作指令；在操作指令有效的情況下，依據(jù)操作指令的類型，對(duì)目標(biāo)數(shù)據(jù)隊(duì)列進(jìn)行檢索，得到檢索結(jié)果；依據(jù)檢索結(jié)果，將目標(biāo)數(shù)據(jù)隊(duì)列中的初始入隊(duì)數(shù)據(jù)取出，并將初始入隊(duì)數(shù)據(jù)存入結(jié)果數(shù)據(jù)隊(duì)列，其中，結(jié)果數(shù)據(jù)隊(duì)列用于將數(shù)據(jù)存儲(chǔ)至預(yù)設(shè)數(shù)據(jù)庫中。本發(fā)明解決了相關(guān)技術(shù)中在處理龐大的數(shù)據(jù)量的數(shù)據(jù)時(shí)，由于通過單線程進(jìn)行數(shù)據(jù)存儲(chǔ)，容易造成數(shù)據(jù)存儲(chǔ)錯(cuò)誤或者損失大量數(shù)據(jù)的技術(shù)問題。

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

本發(fā)明涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，具體而言，涉及一種數(shù)據(jù)處理方法及裝置。

背景技術(shù)

在相關(guān)技術(shù)中，在處理數(shù)據(jù)時(shí)，一般是通過線程存儲(chǔ)的方式進(jìn)行存儲(chǔ)，但是當(dāng)前的存儲(chǔ)方式，對(duì)于數(shù)據(jù)量巨大，且將會(huì)產(chǎn)生不同類型的數(shù)據(jù)，無法進(jìn)行有效存儲(chǔ)，由于數(shù)據(jù)量巨大的數(shù)據(jù)，所有數(shù)據(jù)需要按照一定的數(shù)據(jù)格式存儲(chǔ)至數(shù)據(jù)庫，若考慮基本的單線程數(shù)據(jù)存儲(chǔ)方式，將會(huì)導(dǎo)致數(shù)據(jù)存儲(chǔ)錯(cuò)誤或者損失大量數(shù)據(jù)；另一方面，在進(jìn)行數(shù)據(jù)存儲(chǔ)時(shí)，如果存儲(chǔ)要求的時(shí)間較短，且處理時(shí)間較短，則需要多個(gè)單線程進(jìn)行協(xié)作處理，這時(shí)就會(huì)出現(xiàn)協(xié)作處理過程中由于繁忙而造成數(shù)據(jù)存儲(chǔ)出現(xiàn)錯(cuò)誤的情況發(fā)生。

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

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

本發(fā)明實(shí)施例提供了一種數(shù)據(jù)處理方法及裝置，以至少解決相關(guān)技術(shù)中在處理龐大的數(shù)據(jù)量的數(shù)據(jù)時(shí)，由于通過單線程進(jìn)行數(shù)據(jù)存儲(chǔ)，容易造成數(shù)據(jù)存儲(chǔ)錯(cuò)誤或者損失大量數(shù)據(jù)的技術(shù)問題。

根據(jù)本發(fā)明實(shí)施例的一個(gè)方面，提供了一種數(shù)據(jù)處理方法，包括：獲取預(yù)設(shè)數(shù)據(jù)接口傳輸?shù)臄?shù)據(jù)；解析所述數(shù)據(jù)，得到操作指令；在所述操作指令有效的情況下，依據(jù)所述操作指令的類型，對(duì)目標(biāo)數(shù)據(jù)隊(duì)列進(jìn)行檢索，得到檢索結(jié)果；依據(jù)所述檢索結(jié)果，將目標(biāo)數(shù)據(jù)隊(duì)列中的初始入隊(duì)數(shù)據(jù)取出，并將所述初始入隊(duì)數(shù)據(jù)存入結(jié)果數(shù)據(jù)隊(duì)列，其中，所述結(jié)果數(shù)據(jù)隊(duì)列用于將數(shù)據(jù)存儲(chǔ)至預(yù)設(shè)數(shù)據(jù)庫中。

進(jìn)一步地，所述目標(biāo)數(shù)據(jù)隊(duì)列為：側(cè)方數(shù)據(jù)隊(duì)列或下方數(shù)據(jù)隊(duì)列，所述方法還包括：利用第一子線程執(zhí)行入隊(duì)操作，以將檢測(cè)到的新數(shù)據(jù)一存儲(chǔ)至所述側(cè)方數(shù)據(jù)隊(duì)列，其中，所述第一子線程不受所述操作指令干擾；和/或，利用第二子線程執(zhí)行入隊(duì)操作，以將檢測(cè)到的新數(shù)據(jù)二存儲(chǔ)至所述下方數(shù)據(jù)隊(duì)列，其中，所述第二子線程不受所述操作指令干擾。

進(jìn)一步地，依據(jù)所述操作指令的類型，對(duì)目標(biāo)數(shù)據(jù)隊(duì)列進(jìn)行檢索，得到檢索結(jié)果包括：在所述操作指令為側(cè)方操作指令時(shí)，對(duì)所述側(cè)方數(shù)據(jù)隊(duì)列中的數(shù)據(jù)進(jìn)行檢索，得到檢索結(jié)果一；在所述操作指令為下方操作指令時(shí)，對(duì)所述下方數(shù)據(jù)隊(duì)列中的數(shù)據(jù)進(jìn)行檢索，得到檢索結(jié)果二；依據(jù)檢索結(jié)果，將目標(biāo)數(shù)據(jù)隊(duì)列中的初始入隊(duì)數(shù)據(jù)取出，并將所述初始入隊(duì)數(shù)據(jù)存入結(jié)果數(shù)據(jù)隊(duì)列包括：依據(jù)所述檢索結(jié)果一，將所述側(cè)方數(shù)據(jù)隊(duì)列中的初始入隊(duì)數(shù)據(jù)取出，并將初始入隊(duì)數(shù)據(jù)存儲(chǔ)至結(jié)果數(shù)據(jù)隊(duì)列；或者，依據(jù)所述檢索結(jié)果二，將所述下方數(shù)據(jù)隊(duì)列中的初始入隊(duì)數(shù)據(jù)取出，并將所述初始入隊(duì)數(shù)據(jù)存儲(chǔ)至所述結(jié)果數(shù)據(jù)隊(duì)列。

進(jìn)一步地，依據(jù)檢索結(jié)果，將目標(biāo)數(shù)據(jù)隊(duì)列中的初始入隊(duì)數(shù)據(jù)取出，并將初始入隊(duì)數(shù)據(jù)存入結(jié)果數(shù)據(jù)隊(duì)列還包括：在所述操作指令包括側(cè)方操作指令和下方操作指令時(shí)，將所述檢索結(jié)果一和所述檢索結(jié)果二組合，并執(zhí)行入隊(duì)操作，以將初始入隊(duì)數(shù)據(jù)存儲(chǔ)至所述結(jié)果數(shù)據(jù)隊(duì)列。

進(jìn)一步地，將目標(biāo)數(shù)據(jù)隊(duì)列中的初始入隊(duì)數(shù)據(jù)取出，并將初始入隊(duì)數(shù)據(jù)存入結(jié)果數(shù)據(jù)隊(duì)列包括：在將目標(biāo)數(shù)據(jù)隊(duì)列中的初始入隊(duì)數(shù)據(jù)取出后，將所述初始入隊(duì)數(shù)據(jù)暫存在預(yù)設(shè)的緩存區(qū)；從所述緩存區(qū)中讀取初始入隊(duì)數(shù)據(jù)，并將初始入隊(duì)數(shù)據(jù)存入結(jié)果數(shù)據(jù)隊(duì)列。

進(jìn)一步地，還包括：利用第三子線程對(duì)所述結(jié)果數(shù)據(jù)隊(duì)列執(zhí)行出隊(duì)操作，以將所述結(jié)果數(shù)據(jù)隊(duì)列中的數(shù)據(jù)存儲(chǔ)至所述預(yù)設(shè)數(shù)據(jù)庫；在檢測(cè)到所述結(jié)果數(shù)據(jù)隊(duì)列為空的情況下，發(fā)送終結(jié)指令，其中，所述終結(jié)指令用于指示所述第三子線程停止工作。

進(jìn)一步地，所述預(yù)設(shè)數(shù)據(jù)接口為串口數(shù)據(jù)接口或網(wǎng)口數(shù)據(jù)接口。