[發(fā)明專利]數(shù)據(jù)處理方法和裝置、電子設(shè)備及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 201911324113.6
• 申請(qǐng)日: 2019-12-20
• 公開（公告）號(hào): CN111049846A
• 公開（公告）日: 2020-04-21
• 發(fā)明（設(shè)計(jì)）人: 李偉
• 申請(qǐng)（專利權(quán)）人: 北京明略軟件系統(tǒng)有限公司
• 主分類號(hào): H04L29/06
• 分類號(hào): H04L29/06;H04L29/08
• 代理公司: 北京超成律師事務(wù)所 11646
• 代理人: 許書音

本申請(qǐng)實(shí)施例提供的數(shù)據(jù)處理方法和裝置、電子設(shè)備及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，涉及數(shù)據(jù)處理技術(shù)領(lǐng)域。在本申請(qǐng)實(shí)施例中，首先，通過預(yù)設(shè)的kafka組件獲取待處理的預(yù)警數(shù)據(jù)。其次，對(duì)所述預(yù)警數(shù)據(jù)進(jìn)行預(yù)處理，并通過預(yù)設(shè)的websocket組件將預(yù)處理后的預(yù)警數(shù)據(jù)推送至對(duì)應(yīng)的用戶。通過上述方法，可以提高數(shù)據(jù)處理的效率。

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

本申請(qǐng)涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，具體而言，涉及一種數(shù)據(jù)處理方法和裝置、電子設(shè)備及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)。

背景技術(shù)

公安部門在日常工作過程中，需要及時(shí)獲知重點(diǎn)人、最新指令、通知等預(yù)警數(shù)據(jù)，以做到及時(shí)處理和應(yīng)對(duì)，并做出及時(shí)的反饋，保證工作的高效穩(wěn)定進(jìn)行。

但是，經(jīng)發(fā)明人研究發(fā)現(xiàn)，在現(xiàn)有技術(shù)中，通過數(shù)據(jù)輪詢獲取預(yù)警數(shù)據(jù)進(jìn)行展示，從而存在著數(shù)據(jù)處理的效率低的問題。

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

有鑒于此，本申請(qǐng)的目的在于提供一種數(shù)據(jù)處理方法和裝置、電子設(shè)備及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，以改善現(xiàn)有技術(shù)中存在的問題。

為實(shí)現(xiàn)上述目的，本申請(qǐng)實(shí)施例采用如下技術(shù)方案：

一種數(shù)據(jù)處理方法，包括：

通過預(yù)設(shè)的kafka組件獲取待處理的預(yù)警數(shù)據(jù)；

對(duì)所述預(yù)警數(shù)據(jù)進(jìn)行預(yù)處理，并通過預(yù)設(shè)的websocket組件將預(yù)處理后的預(yù)警數(shù)據(jù)推送至對(duì)應(yīng)的用戶。

在本申請(qǐng)實(shí)施例較佳的選擇中，所述通過預(yù)設(shè)的kafka組件獲取待處理的預(yù)警數(shù)據(jù)的步驟，包括：

與預(yù)設(shè)的kafka組件建立連接；

獲取所述kafka組件發(fā)送的預(yù)警數(shù)據(jù)。

在本申請(qǐng)實(shí)施例較佳的選擇中，所述與預(yù)設(shè)的kafka組件建立連接的步驟，包括：

通過npm組件獲取并安裝express組件；

通過所述express組件對(duì)預(yù)設(shè)的kafka組件進(jìn)行偵聽處理，以建立連接。

在本申請(qǐng)實(shí)施例較佳的選擇中，所述獲取所述kafka組件發(fā)送的預(yù)警數(shù)據(jù)的步驟，包括：

通過npm組件獲取并安裝kafka-node組件；

獲取通過所述kafka-node組件得到并發(fā)送的所述預(yù)警數(shù)據(jù)。

在本申請(qǐng)實(shí)施例較佳的選擇中，所述對(duì)所述預(yù)警數(shù)據(jù)進(jìn)行預(yù)處理的步驟，包括：

對(duì)所述預(yù)警數(shù)據(jù)進(jìn)行過濾處理，得到過濾預(yù)警數(shù)據(jù)；

對(duì)所述過濾預(yù)警數(shù)據(jù)進(jìn)行轉(zhuǎn)換處理，得到待推送數(shù)據(jù)。

在本申請(qǐng)實(shí)施例較佳的選擇中，所述對(duì)所述過濾預(yù)警數(shù)據(jù)進(jìn)行轉(zhuǎn)換處理，得到待推送數(shù)據(jù)的步驟，包括：

對(duì)所述過濾預(yù)警數(shù)據(jù)進(jìn)行關(guān)聯(lián)處理，得到關(guān)聯(lián)預(yù)警數(shù)據(jù)；

對(duì)所述關(guān)聯(lián)預(yù)警數(shù)據(jù)進(jìn)行格式化處理，得到待推送數(shù)據(jù)。

在本申請(qǐng)實(shí)施例較佳的選擇中，所述websocket組件設(shè)置有Socket.io組件，所述通過預(yù)設(shè)的websocket組件將所述預(yù)處理后的預(yù)警數(shù)據(jù)推送至對(duì)應(yīng)的用戶的步驟，包括：

通過npm組件獲取并安裝Socket.io組件；

通過所述Socket.io組件將所述預(yù)處理后的預(yù)警數(shù)據(jù)推送至對(duì)應(yīng)的用戶。

本申請(qǐng)實(shí)施例還提供了一種數(shù)據(jù)處理裝置，包括：

數(shù)據(jù)獲取模塊，用于通過預(yù)設(shè)的kafka組件獲取待處理的預(yù)警數(shù)據(jù)；