[發明專利]一種基于pulsar的設備信息處理方法、系統介質及計算機

在審

• 申請號: 202310207849.5
• 申請日: 2023-03-07
• 公開（公告）號: CN116204313A
• 公開（公告）日: 2023-06-02
• 發明（設計）人: 馮斯偉;陸丹峰;王震
• 申請（專利權）人: 上海致景信息科技有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F16/25;G06F9/54;G06N20/00;G06Q50/04
• 代理公司: 廣州立凡知識產權代理有限公司 44563
• 代理人: 付才

1.一種基于pulsar的設備信息處理方法，其特征在于，包括：

S1、接收紡織設備生成的日志信息；

S2、將所述日志信息寫入至pulsar集群中的一個或者多個日志信息隊列中，對應生成優化日志信息；

S3、將優化日志信息寫入數據庫，進行持久化存儲。

2.根據權利要求1所述的一種基于pulsar的設備信息處理方法，其特征在于，所述步驟S3，還包括：

S31、將所述優化日志信息寫入到pulsar集群中的一個或者多個消費主題信息隊列中，以供訂閱對應消費主題的消費者進行消費；

S32、將所述消費者消費后的優化日志信息寫入數據庫中，進行持久化存儲。

3.根據權利要求1所述的一種基于pulsar的設備信息處理方法，其特征在于，還包括：

獲取所述pulsar集群中每一個日志信息隊列所占用的系統資源數值，并判斷每一個日志信息隊列所占用的系統資源數值是否大于該日志信息隊列所對應的第一系統資源閾值；若是，則擴充所述日志信息隊列對應分配的系統資源的數量，并對應調整所述日志信息隊列對應的第一系統資源閾值。

4.根據權利要求3所述的一種基于pulsar的設備信息處理方法，其特征在于，還包括：

獲取所述pulsar集群中每一個日志信息隊列所占用的系統資源數值，并判斷每一個日志信息隊列所占用的系統資源數值是否小于該日志信息隊列所對應的第二系統資源閾值；若是，則縮減所述日志信息隊列對應分配的系統資源的數量，并對應調整所述日志信息隊列對應的第二系統資源閾值。

5.根據權利要求1所述的一種基于pulsar的設備信息處理方法，其特征在于，還包括：構建所述pulsar集群中每一個日志信息隊列所占用的系統資源數值與日期之間的非線性關系，針對每一個日志信息隊列，將所述系統資源數值和日期輸入到預先訓練好的預測模型中，根據所述預測模型輸出的系統資源數值，對應調整分配給所述日志信息隊列的系統資源數值。

6.根據權利要求5所述的一種基于pulsar的設備信息處理方法，其特征在于，所述構建所述pulsar集群中每一個日志信息隊列所占用的系統資源數值與日期之間的非線性關系，包括：

收集預定時間段內任一日志信息隊列所占用的系統資源數值，并按照日期的先后順序以及系統資源數值的大小順序，將系統資源數值以及日期組合進行排序，并對應生成關于系統資源數值以及日期的矩陣，將所述矩陣輸入到預先訓練好的殘差網絡模型中，以確定該日志信息隊列所占用的系統資源數值與日期之間的非線性關系。

7.根據權利要求6所述的一種基于pulsar的設備信息處理方法，其特征在于，所述消費者包括：HTTP服務器、Redis緩存、分布式文件系統以及Hbase數據庫。

8.一種基于pulsar的設備信息處理系統，其特征在于，包括：

日志信息接收模塊：用于接收紡織設備生成的日志信息；

日志信息寫入模塊：用于將所述日志信息寫入至pulsar集群中的一個或者多個日志信息隊列中，對應生成優化日志信息；

日志信息消費模塊：用于將所述優化日志信息寫入到pulsar集群中的一個或者多個消費主題信息隊列中，以供訂閱對應消費主題的消費者進行消費；

日志信息存儲模塊：用于將優化日志信息寫入數據庫，進行持久化存儲

系統資源分配模塊：用于根據每一個日志信息隊列所占用的系統資源數值，對應調整分配給該日志信息隊列的系統資源的數值；

系統資源預測模塊：用于構建所述pulsar集群中每一個日志信息隊列所占用的系統資源數值與日期之間的非線性關系，并根據所述非線性關系對應調整分配給所述日志信息隊列的系統資源數值。

9.一種計算機設備，包括存儲器和處理器，所述存儲器存儲有計算機程序，其特征在于，所述處理器執行所述計算機程序時實現權利要求1至7中任一項所述的方法的步驟。

10.一種計算機可讀存儲介質，其上存儲有計算機程序，其特征在于，所述計算機程序被處理器執行時實現權利要求1至7中任一項所述的方法的步驟。