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

在審

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

本發明涉及一種基于pulsar的設備信息處理方法、系統、介質及計算機，本申請提出一種基于pulsar的設備信息處理方法，能夠將設備日志信息存儲系統的計算層和存儲層相互拆分，以實現任意擴容或者縮容，避免系統資源不足或者系統資源分配過多而導致浪費。同時通過引入深度學習模型，對過去的一定時間內的資源分配數量進行訓練，能夠對未來的某一段時間中，某一消息隊列所需要分配的系統資源進行預測，降低人為干預的次數，使系統更加智能化。

技術領域

本發明涉及包裝設備技術領域，更具體地說，它涉及一種基于pulsar的設備信息處理方法、系統介質及計算機。

背景技術

工廠要實現無人化，必須借助信息化技術，特別是物聯網技術，能夠大幅度提升工廠生產效率，使企業的人力成本下降。在紡織行業，依舊需要依賴信息技術去完成產業升級，提升紡織產業鏈中每一個環節的生產效率。在過去，從棉花到成品布再到成衣，一系列的流程需要人的肉眼去觀察每一步工序，現在我們可考慮引入各類傳感器和實時推送機制，讓企業員工坐在辦公室也能”感知”工序和機器的各種狀態變化，其中如何結合紡織行業的特點，實現狀態信息實時推送變成一個全新的挑戰。

紡織工序的每個業務線都存在：傳感器上報-中臺捕獲-展示端展示(或觸發業務邏輯)，類似這樣的場景，而各業務線實現又各不相同，有些方案過于復雜且容易出問題，現有的做法一般都是是考慮將推送模塊抽象統一，業界一般會使用傳統的類似kafka，rocketmq這些的消息中間件去進行實現，但紡織行業中從棉花到成品衣中間會經歷n道工序，涉及眾多不同的產品線，每個產品線的數據規模和推送頻率要求各不相同，基于傳統的消息系統下，存儲和路由推送功能緊密耦合在一起，很容易造成存儲和計算資源浪費，同時在需要進行業務升級時，還需要讓整體系統停止運轉，進而影響現企業的生產經營。

發明內容

針對現有技術存在的不足，本發明的目的在于提供一種基于pulsar的設備信息處理方法、系統介質及計算機，以解決現有的紡織設備生成日志數量和頻率變化較大、設備冗余過大而導致資源浪費的問題。

本發明的上述技術目的是通過以下技術方案得以實現的：一種基于pulsar的設備信息處理方法，包括：

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

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

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

可選的，所述步驟S3，還包括：

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

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

可選的，還包括：

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

可選的，還包括：

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

可選的，還包括：構建所述pulsar集群中每一個日志信息隊列所占用的系統資源數值與日期之間的非線性關系，針對每一個日志信息隊列，將所述系統資源數值和日期輸入到預先訓練好的預測模型中，根據所述預測模型輸出的系統資源數值，對應調整分配給所述日志信息隊列的系統資源數值。