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

在審

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

1.一種數(shù)據(jù)處理方法，其特征在于，包括：

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

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

2.如權(quán)利要求1所述的數(shù)據(jù)處理方法，其特征在于，所述通過預設的kafka組件獲取待處理的預警數(shù)據(jù)的步驟，包括：

與預設的kafka組件建立連接；

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

3.如權(quán)利要求2所述的數(shù)據(jù)處理方法，其特征在于，所述與預設的kafka組件建立連接的步驟，包括：

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

通過所述express組件對預設的kafka組件進行偵聽處理，以建立連接。

4.如權(quán)利要求2所述的數(shù)據(jù)處理方法，其特征在于，所述獲取所述kafka組件發(fā)送的預警數(shù)據(jù)的步驟，包括：

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

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

5.如權(quán)利要求1所述的數(shù)據(jù)處理方法，其特征在于，所述對所述預警數(shù)據(jù)進行預處理的步驟，包括：

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

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

6.如權(quán)利要求5所述的數(shù)據(jù)處理方法，其特征在于，所述對所述過濾預警數(shù)據(jù)進行轉(zhuǎn)換處理，得到待推送數(shù)據(jù)的步驟，包括：

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

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

7.如權(quán)利要求1所述的數(shù)據(jù)處理方法，其特征在于，所述websocket組件設置有Socket.io組件，所述通過預設的websocket組件將所述預處理后的預警數(shù)據(jù)推送至對應的用戶的步驟，包括：

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

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

8.一種數(shù)據(jù)處理裝置，其特征在于，包括：

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

數(shù)據(jù)處理模塊，用于對所述預警數(shù)據(jù)進行預處理，并通過預設的websocket組件將預處理后的預警數(shù)據(jù)推送至對應的用戶。

9.一種電子設備，其特征在于，包括存儲器和處理器，所述處理器用于執(zhí)行所述存儲器中存儲的可執(zhí)行的計算機程序，以實現(xiàn)權(quán)利要求1-7任意一項所述的數(shù)據(jù)處理方法。

10.一種計算機可讀存儲介質(zhì)，其特征在于，其上存儲有計算機程序，該程序被執(zhí)行時實現(xiàn)權(quán)利要求1-7任意一項所述數(shù)據(jù)處理方法的步驟。