[發明專利]信息處理方法、裝置、設備和介質

有效

• 申請號: 202011240270.1
• 申請日: 2020-11-09
• 公開（公告）號: CN112422412B
• 公開（公告）日: 2023-03-24
• 發明（設計）人: 陳勝
• 申請（專利權）人: 北京百度網訊科技有限公司
• 主分類號: H04L51/04
• 分類號: H04L51/04;H04L69/18;G06F16/242
• 代理公司: 北京市漢坤律師事務所 11602
• 代理人: 姜浩然;吳麗麗

1.一種信息處理方法，所述方法包括：

對從至少一個信息源獲得的采集數據進行處理以生成能夠用于流式處理的第一信息；

基于所述第一信息，經過流式計算生成第二信息，所述第二信息能夠體現所述第一信息在預定時間段內的指標；以及

將所述第二信息發送至云端服務器，

其中，基于所述第一信息，經過流式計算生成第二信息包括：以預定時間窗口為單位，統計所述預定時間窗口所確定的預定時間段內所述第一信息的指標，所述指標為平均值和最大值中的至少一種，其中，所述第二信息是經過邊緣計算得到的，并且

其中，所述方法還包括：

配置發送到本地消息中心的約定主題；

配置規則引擎以用于訂閱所述本地消息中心中的所述約定主題，并轉發給基于SQL語句的語法解析模塊；

配置流式計算規則以用于處理轉發到所述語法解析模塊的第一信息；以及

啟動所述本地消息中心。

2.根據權利要求1所述的方法，其中，所述對從至少一個信息源獲得的采集數據進行處理以生成能夠用于流式處理的第一信息，包括：

通過兼容的協議接口從多個信息源獲得采集數據。

3.根據權利要求2所述的方法，其中，

所述多個信息源包括應用于不同領域的多個傳感器，所述領域選自農業、電力和運輸領域。

4.根據權利要求2或3所述的方法，還包括：

定期采集所述多個信息源的信息以獲得所述采集數據。

5.根據權利要求4所述的方法，其中，所述對從至少一個信息源獲得的采集數據進行處理以生成能夠用于流式處理的第一信息，包括：

訂閱所述采集數據中的所述約定主題以生成篩選信息。

6.根據權利要求5所述的方法，所述對從至少一個信息源獲得的采集數據進行處理以生成能夠用于流式處理的第一信息，包括：

對所述篩選信息進行語法解析以生成所述第一信息。

7.根據權利要求1所述的方法，其中，

所述時間窗口為滾動窗口、滑動窗口或計數窗口。

8.根據權利要求1所述的方法，其中，

將所述第二信息發送至云端服務器，包括：

將第二信息進行同步后發送至所述云端服務器。

9.根據權利要求5所述的方法，還包括配置所述至少一個信息源。

10.一種信息處理裝置，包括：

生成模塊，被配置為用于對從至少一個信息源獲得的采集數據進行處理以生成能夠用于流式處理的第一信息；

計算模塊，被配置為用于基于所述第一信息，經過流式計算生成第二信息，所述第二信息能夠體現所述第一信息在預定時間段內的指標；以及

發送模塊，被配置為用于將所述第二信息發送至云端服務器，

其中，基于所述第一信息，經過流式計算生成第二信息包括：以預定時間窗口為單位，統計所述預定時間窗口所確定的預定時間段內所述第一信息的指標，所述指標為平均值和最大值中的至少一種，其中，所述第二信息是經過邊緣計算得到的，并且

其中，所述裝置還包括用于執行以下操作的模塊：

配置發送到本地消息中心的約定主題；

配置規則引擎以用于訂閱所述本地消息中心中的所述約定主題，并轉發給基于SQL語句的語法解析模塊；

配置流式計算規則以用于處理轉發到所述語法解析模塊的第一信息；以及

啟動所述本地消息中心。

11.一種電子設備，包括：

處理器；以及

存儲程序的存儲器，所述程序包括指令，所述指令在由所述處理器執行時使所述處理器執行根據權利要求1至9中任一項所述的方法。

12.一種存儲程序的計算機可讀存儲介質，所述程序包括指令，所述指令在由服務器的處理器執行時使得所述服務器執行根據權利要求1至9中任一項所述的方法。