[發明專利]一種基于Actor模型的數據處理方法及系統

在審

• 申請號: 202211315875.1
• 申請日: 2022-10-26
• 公開（公告）號: CN115695213A
• 公開（公告）日: 2023-02-03
• 發明（設計）人: 李欣;李元正;焦威;王思同
• 申請（專利權）人: 北京國泰網信科技有限公司;成都國泰網信科技有限公司
• 主分類號: H04L41/14
• 分類號: H04L41/14;H04L41/0806;H04L43/028;H04L49/25
• 代理公司: 成都九鼎天元知識產權代理有限公司 51214
• 代理人: 黎飛

1.一種基于Actor模型的數據處理方法，其特征在于，創建Actor模型，并按照用戶自定義的Actor節點結構及Actor節點間的關系，對采集到的數據進行數據處理。

2.根據權利要求1所述的一種基于Actor模型的數據處理方法，其特征在于，包括以下步驟：

S1，數據采集：采集不同的終端設備發送的數據；

S2，模型創建：創建Actor模型；

S3，處理鏈構建：自定義Actor節點結構及Actor節點間的關系，形成數據處理鏈；

S4，數據處理：按照定義好的數據處理鏈，對數據進行數據處理；所述數據處理，指數據轉換、過濾、轉發、儲存中的一種或多種。

3.根據權利要求2所述的一種基于Actor模型的數據處理方法，其特征在于，步驟S1中，采用KAFKA、MQTT或SYSLOG進行數據采集。

4.根據權利要求3所述的一種基于Actor模型的數據處理方法，其特征在于，步驟S2中，Actor模型中包含了多個Actor，Actor為數據處理節點，每個數據處理節點具有不同的數據處理能力。

5.根據權利要求4所述的一種基于Actor模型的數據處理方法，其特征在于，步驟S2中，而每個數據處理節點能力是預先定義好的。

6.根據權利要求5所述的一種基于Actor模型的數據處理方法，其特征在于，步驟S2中，并且每個數據處理節點是可以復用的。

7.根據權利要求6所述的一種基于Actor模型的數據處理方法，其特征在于，步驟S3中，對數據節點進行執行順序的定義，定義內容如下：定義根節點為INPUT節點，INPUT節點的下一級節點為string_change節點，string_change節點用于將字符串中源字符串替換為目標字符串；string_change下一級節點包含2個節點，分別為string_filter和save節點，其中，string_filter節點用于判斷傳遞過來的數據中是否包含某個內容，save節點用于將采集數據保存到本地數據庫；string_filter的下一級節點為external_kafka節點，external_kafka節點的用于將傳遞過來的數據發送給kafka服務器，并提供kafka服務器的配置。

8.根據權利要求2至7任一項所述的一種基于Actor模型的數據處理方法，其特征在于，步驟S4中，數據首先到達根節點，然后把數據發送給根節點的下一級所有節點，所有的節點按照節點定義的方法執行完后，將處理后的數據再發送給當前節點的下一級所有節點，直至所有節點中定義的方法全部執行完畢。

9.根據權利要求2至8任一項所述的一種基于Actor模型的數據處理方法，其特征在于，Actor節點通過消息傳遞的方式通信。

10.一種基于Actor模型的數據處理系統，其特征在于，用于實現權利要求1至9任一項所述的一種基于Actor模型的數據處理方法，包括以下模塊：

數據采集模塊：用以，采集不同的終端設備發送的數據；

模型創建模塊：用以，創建Actor模型；

處理鏈構建模塊：用以，自定義Actor節點結構及Actor節點間的關系，形成數據處理鏈；

數據處理模塊：用以，按照定義好的數據處理鏈，對數據進行數據處理；所述數據處理，指數據轉換、過濾、轉發、儲存中的一種或多種；

其中，模型創建模塊、處理鏈構建模塊、數據處理模塊依次連接，數據采集模塊與數據處理模塊連接。