[發(fā)明專利]多水域的水質監(jiān)控方法、系統(tǒng)、存儲介質以及電子設備

有效

• 申請?zhí)枺?/td>: 202210755551.3
• 申請日: 2022-06-30
• 公開（公告）號: CN114817339B
• 公開（公告）日: 2022-10-11
• 發(fā)明（設計）人: 戈燕紅;黃輝勤;李建華;舒少君;彭芳
• 申請（專利權）人: 廣東盈峰科技有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06Q50/06;G06F16/2458;G06F16/28;G01N33/18;H04Q9/00;H04L67/1001;H04L67/12
• 代理公司: 深圳智匯遠見知識產(chǎn)權代理有限公司 44481
• 代理人: 聶磊

本發(fā)明涉及水質監(jiān)控領域，公開了一種多水域的水質監(jiān)控方法、系統(tǒng)、存儲介質以及電子設備。該方法包括：由多個水域的每一個水域中的多個監(jiān)測設備收集水域的水質數(shù)據(jù)，確定水質數(shù)據(jù)的風險等級；在水質數(shù)據(jù)的風險等級為第一等級的情況下，將水質數(shù)據(jù)負載均衡到第一目標應用程序框架，在水質數(shù)據(jù)的風險等級為第二等級的情況下，將水質數(shù)據(jù)負載均衡到第二目標應用程序框架；對分布式發(fā)布訂閱系統(tǒng)中的水質數(shù)據(jù)進行分析處理，得到水質結果；將水質結果存儲到緩存數(shù)據(jù)庫和數(shù)據(jù)倉庫中；按照設備標簽和收集時間，從緩存數(shù)據(jù)庫和數(shù)據(jù)倉庫中獲取到單個水域的水質結果。本發(fā)明解決了多水域的水質數(shù)據(jù)監(jiān)控的過程中，數(shù)據(jù)阻塞的技術問題。

技術領域

本發(fā)明涉及水質監(jiān)控領域，具體而言，涉及一種多水域的水質監(jiān)控方法、系統(tǒng)、存儲介質以及電子設備。

背景技術

現(xiàn)有技術中，在對水質進行監(jiān)控的過程中，如果要對多個水域的水質數(shù)據(jù)進行監(jiān)控，則需要收集多個水域的水質數(shù)據(jù)，并對多個水域的水質數(shù)據(jù)進行分析。然而，現(xiàn)有技術中，如果水域較多或每一個水域中要收集的水質數(shù)據(jù)較多，則會造成在同一時間數(shù)據(jù)的數(shù)據(jù)量較大，進而造成數(shù)據(jù)阻塞。

發(fā)明內(nèi)容

本發(fā)明實施例提供了一種多水域的水質監(jiān)控方法、系統(tǒng)、存儲介質以及電子設備，以至少解決多水域的水質數(shù)據(jù)監(jiān)控的過程中，數(shù)據(jù)阻塞的技術問題。

根據(jù)本發(fā)明實施例的一個方面，提供了一種多水域的水質監(jiān)控方法，包括：由多個水域的每一個水域中的多個監(jiān)測設備收集水域的水質數(shù)據(jù)，其中，每一個水域的多個監(jiān)測設備中，每一個監(jiān)測設備用于收集所在水域的一種水質數(shù)據(jù)；在任意一個監(jiān)測設備收集上述水質數(shù)據(jù)后，根據(jù)當前上述水質數(shù)據(jù)相對于上一次收集的水質數(shù)據(jù)的變化量，確定當前上述水質數(shù)據(jù)的風險等級，并將上述水質數(shù)據(jù)發(fā)送到處理設備，其中，上述變化量大于第一閾值的情況下，將上述風險等級確定為第一等級，上述變化量小于或等于上述第一閾值的情況下，將上述風險等級確定為第二等級；上述處理設備實時接收每一個上述監(jiān)測設備發(fā)送的上述水質數(shù)據(jù)；上述處理設備在接收到任意一個上述監(jiān)測設備發(fā)送的上述水質數(shù)據(jù)的情況下，記錄上述監(jiān)測設備的設備標簽和上述水質數(shù)據(jù)的收集時間，并在上述水質數(shù)據(jù)的風險等級為第一等級的情況下，將上述水質數(shù)據(jù)負載均衡到多個第一應用程序框架中的第一目標應用程序框架，并由上述第一目標應用程序框架將上述水質數(shù)據(jù)存儲到分布式發(fā)布訂閱系統(tǒng)中，在上述水質數(shù)據(jù)的風險等級為第二等級的情況下，將上述水質數(shù)據(jù)負載均衡到多個第二應用程序框架中的第二目標應用程序框架，并由上述第二目標應用程序框架將上述水質數(shù)據(jù)存儲到分布式發(fā)布訂閱系統(tǒng)中，其中，上述第一應用程序框架處理上述水質數(shù)據(jù)的速度高于上述第二應用程序框架處理上述水質數(shù)據(jù)的速度；對上述分布式發(fā)布訂閱系統(tǒng)中的上述水質數(shù)據(jù)進行分析處理，得到水質結果；將上述水質結果存儲到緩存數(shù)據(jù)庫和數(shù)據(jù)倉庫中；按照上述設備標簽和上述收集時間，從上述緩存數(shù)據(jù)庫和數(shù)據(jù)倉庫中獲取到單個水域的水質結果。

作為一種可選的示例，由上述監(jiān)測設備收集上述水質數(shù)據(jù)包括：由上述監(jiān)測設備收集水質成分數(shù)據(jù)并對上述水質成分數(shù)據(jù)進行分析；將分析結果作為上述水質數(shù)據(jù)。

作為一種可選的示例，由多個水域的每一個水域中的多個監(jiān)測設備收集水域的水質數(shù)據(jù)包括：由每一個上述監(jiān)測設備按照自身的時間周期，每一個時間周期收集一次所在水域的上述水質數(shù)據(jù)。

作為一種可選的示例，將上述水質數(shù)據(jù)負載均衡到多個應用程序框架中的目標應用程序框架包括：根據(jù)負載均衡加權最小連接數(shù)調度算法從多個第一應用程序框架中選擇一個應用程序框架作為上述第一目標應用程序框架或者根據(jù)負載均衡加權最小連接數(shù)調度算法從多個第二應用程序框架中選擇一個應用程序框架作為上述第二目標應用程序框架。

作為一種可選的示例，將上述水質數(shù)據(jù)負載均衡到多個應用程序框架中的目標應用程序框架包括：根據(jù)負載均衡基于權重的輪詢動態(tài)調度算法從多個第一應用程序框架中選擇一個應用程序框架作為上述第一目標應用程序框架或者根據(jù)負載均衡基于權重的輪詢動態(tài)調度算法從多個第二應用程序框架中選擇一個應用程序框架作為上述第二目標應用程序框架。