Search

CN-122023090-A - Municipal environment monitoring data real-time analysis method and system based on end cloud cooperation

CN122023090ACN 122023090 ACN122023090 ACN 122023090ACN-122023090-A

Abstract

The invention discloses a municipal environment monitoring data real-time analysis method and system based on end cloud cooperation, which relate to the technical field of smart cities and comprise the following steps: establishing a continuous period alignment chain for real-time data analysis, sequentially recording the abnormal amplitude change direction, the abnormal amplitude change rate and the abnormal arrival time according to each analysis period, and sequentially writing the recorded period analysis information into a unified time track to form an accumulated change trace. The invention realizes time continuous analysis and trend perception of environment monitoring data by constructing a continuous period alignment chain and an accumulated change trace belt, can identify potential risks in the initial stage of trend formation, realizes end cloud cooperative regulation and control by utilizing a transition contact list and a beat draft, releases dispersion abnormal accumulation by threshold value transfer and rhythm dislocation, ensures stable system operation and realizes advanced inhibition and dynamic response of trend risks.

Inventors

  • LIU LONGFEI
  • LI CHUNNING
  • LIANG KUN

Assignees

  • 济宁公用市政园林集团有限公司

Dates

Publication Date
20260512
Application Date
20260120

Claims (10)

  1. 1. The municipal environmental monitoring data real-time analysis method based on the end cloud cooperation is characterized by comprising the following steps of: Establishing a continuous period alignment chain for real-time data analysis, sequentially recording the variation direction, the variation rate and the arrival time of abnormal amplitude according to each analysis period, and sequentially writing the recorded period analysis information into a unified time track to form an accumulated variation trace; Performing adjacent period alignment analysis based on an accumulated change trace band formed by continuous periods, continuously spreading abnormal amplitude of each period along the same direction change direction, identifying a continuous section and a turnover section of a change slope, and generating a slope migration list; tracking an abnormal change track by using the generated slope migration list, positioning a trend acceleration starting point in the slope continuous enhancement section, marking a critical front moment corresponding to the trend acceleration starting point and the lengths of the continuous sections before and after the front, and constructing a transition contact list; Rearranging data analysis rhythms according to the transition contact lists, sequentially setting a threshold value transfer window, a data release window and a short-time silence window before and after each transition contact, embedding contact time sequence information into the rhythmic sequence, and generating a beat draft; And carrying out cloud collaborative adjustment on the execution end of the draft according to the beat, carrying out reverse respiration adjustment on the cloud analysis threshold along the threshold transfer window, carrying out dislocation release on data reporting on the opposite end side along the data release window, and interrupting the homodromous abnormal superposition path in the short-time silence window.
  2. 2. The method for real-time analysis of municipal environmental monitoring data based on end-cloud cooperation according to claim 1, wherein the cumulative variability trace band formation step is as follows: taking a preset analysis period as a time segmentation reference, carrying out time sequence reforming and period normalization on the data samples in each period, and unifying the time stamp information of different monitoring points to the same time axis scale; After feature normalization in the period is completed, sequentially linking the data results of adjacent analysis periods, keeping sequential continuity in the time dimension, recording the variation direction, variation rate and arrival time of abnormal amplitude, and writing a continuous time track; After forming a continuous time track, carrying out time sequence arrangement on the abnormal change direction, the change rate and the arrival time, and establishing a rate gradient mapping and a time coordinate zone; After finishing the time track arrangement, the recorded information is fused, and an accumulated change trace band is formed in time sequence.
  3. 3. The method for analyzing municipal environmental monitoring data in real time based on end cloud cooperation according to claim 2, wherein the abnormal amplitude change direction, the abnormal amplitude change rate and the arrival time are written in a continuous time track in a time sequence, so that a corresponding relation between a time axis and an analysis period is maintained, and the abnormal amplitude change trend and the abnormal amplitude change rate time gradient are synchronously recorded in a trace band.
  4. 4. The method for real-time analysis of municipal environmental monitoring data based on end-cloud collaboration according to claim 2, wherein the step of performing adjacent cycle alignment analysis based on the cumulative variation trace bands formed by successive cycles is as follows: After the cumulative variation trace band is obtained, aligning and arranging a periodic sequence recorded in the trace band, keeping adjacent periods continuously connected on a time axis, and extracting the abnormal amplitude variation direction to form a direction chain; Continuously spreading the abnormal amplitude of each period along the same direction change direction of the direction chain, and establishing a connection relation between the end point of each period and the starting point of the next period to form a time continuous change belt; synchronously analyzing the change rate based on the continuous spreading result, identifying a continuous section and a turnover section of the change slope and determining a time boundary; and uniformly sorting the time sequence, the amplitude characteristics and the direction information of the continuous section and the turning section to generate a slope migration list.
  5. 5. The method for real-time analysis of municipal environmental monitoring data based on end-cloud cooperation according to claim 4, wherein the time sequence and the amplitude characteristics of the continuous section and the overturning section are marked in a correlated manner, the continuous state and the reversing state of the changing direction are recorded under the time index, and the time gradient information of the rate change is synchronously written into the migration list.
  6. 6. The method for real-time analysis of municipal environmental monitoring data based on end-cloud cooperation according to claim 4, wherein the step of tracing back the abnormal change track by using the slope migration list comprises the steps of: After the slope migration list is obtained, trace backtracking is carried out on the slope change section in time sequence, and a time sequence with continuously enhanced slope is extracted to form a continuous trace line; Identifying a trend acceleration starting point according to a time range in which the slope continuously increases in the track line, and determining a time node in which the slope is changed from gradual increase to rapid increase as the trend acceleration starting point; Marking critical front time by taking a trend acceleration starting point as a center, measuring the lengths of front and rear continuous sections of the front, and determining a critical time boundary of trend evolution; And generating a transition contact list according to the corresponding relation between the trend acceleration starting point and the critical leading edge moment.
  7. 7. The method for real-time analysis of municipal environmental monitoring data based on end cloud cooperation according to claim 6, wherein in the process of generating the transition contact list, the time position of the starting point of trend acceleration and the critical leading edge moment are synchronously indexed, and a time interval map is built according to the lengths of the continuous sections before and after the leading edge, so that the time mark, the direction information and the slope enhancement feature of the transition contact keep a corresponding relation.
  8. 8. The method for analyzing municipal environmental monitoring data in real time based on end cloud cooperation according to claim 6, wherein the step of rearranging the data analysis rhythm according to the transition contact list is as follows: after the transition contact list is obtained, the contact time distribution and the duration are sorted in time sequence, the contact time position is used as a reference point for rhythm reconstruction, and the time structure reconstruction is completed; taking each transition contact as a center, and sequentially setting a threshold value transfer window, a data release window and a short-time silence window in the time interval before and after the contact, so that the data analysis rhythm is continuously connected on a time axis; binding parameter characteristics of a threshold value transfer window, a data release window and a short-time silence window with transition contact time sequence information, so that rhythm regulation and control can be adaptively adjusted along with contact change; And integrating the bound rhythm elements in time sequence to generate a beat draft.
  9. 9. The method for real-time analysis of municipal environmental monitoring data based on end cloud cooperation according to claim 8, wherein the step of executing end cloud cooperation adjustment according to a beat draft is as follows: After generating a beat draft, mapping time periods into an analysis chain of an end side and a cloud according to a rhythm sequence, establishing a cooperative control corresponding relation between the end clouds and keeping time synchronization; Implementing reverse respiration adjustment on the cloud analysis threshold along the threshold transfer window to enable the threshold to be transferred downwards in a trend acceleration stage and to be transferred upwards in a trend buffering stage, so that dynamic adjustment of sensitivity is realized; Performing dislocation release along the data release window opposite end side data report, and realizing the complementary balance of the end cloud analysis rhythm through time offset report; and interrupting the homodromous anomaly superposition path along the short-time silence window, suspending the continuous anomaly analysis response, and realizing effective dispersion of the accumulated driving source and advanced suppression of trend transition risks.
  10. 10. The municipal environmental monitoring data real-time analysis system based on the end cloud cooperation is used for realizing the municipal environmental monitoring data real-time analysis method based on the end cloud cooperation as set forth in any one of claims 1 to 9, and is characterized by comprising a period alignment and accumulation modeling module, a slope migration analysis module, a trend transition identification module, a rhythm arrangement and traction generation module and an end cloud cooperation regulation and control module: the period alignment and accumulation modeling module establishes a continuous period alignment chain for real-time data analysis, sequentially records the abnormal amplitude change direction, the abnormal amplitude change rate and the abnormal amplitude change arrival time according to each analysis period, and sequentially writes the recorded period analysis information into a unified time track to form an accumulation change trace; The slope migration analysis module is used for executing adjacent period alignment analysis based on an accumulated change trace zone formed by continuous periods, continuously spreading abnormal amplitude of each period along the same direction change direction, identifying a continuous section and a turnover section of a change slope, and generating a slope migration list; the trend transition identification module is used for tracing back an abnormal change track by utilizing the generated slope migration list, positioning a trend acceleration starting point in the slope continuous enhancement section, marking a critical front moment corresponding to the trend acceleration starting point and the lengths of the front continuous section and the rear continuous section, and constructing a transition contact list; the rhythm arrangement and traction generation module rearranges data analysis rhythms according to the transition contact list, sequentially sets a threshold value transfer window, a data release window and a short-time silence window before and after each transition contact, embeds contact time sequence information into a rhythm sequence, and generates a rhythm traction manuscript; And the end cloud cooperative regulation and control module executes end cloud cooperative regulation according to the beat draft, performs reverse respiration regulation on the cloud analysis threshold along the threshold transfer window, performs dislocation release on the end side data report along the data release window, and interrupts the homodromous abnormal superposition path in the short-time silence window.

Description

Municipal environment monitoring data real-time analysis method and system based on end cloud cooperation Technical Field The invention relates to the technical field of smart cities, in particular to a municipal environment monitoring data real-time analysis method and system based on end cloud cooperation. Background The real-time analysis of municipal environmental monitoring data based on end cloud cooperation refers to that in the municipal environmental monitoring process, the local processing capacity of front-end acquisition equipment, the data preprocessing capacity under a big data processing frame and the cloud centralized computing, storing and managing capacity are cooperatively matched, and continuous, synchronous and layered analysis processing modes are developed for the environmental monitoring data. Specifically, front-end monitoring equipment distributed on roads, pipelines, green belts, river channels or key areas performs primary screening, compression, abnormal prejudgment or time alignment processing on original data by means of data cleaning and stream processing ideas in big data processing while completing data acquisition, so that data redundancy is reduced and transmission and response efficiency is improved; the cloud end performs unified aggregation, time sequence association, cross-regional comparison and comprehensive analysis on the data from the plurality of front ends under the support of the big data processing platform to form an extensible data association relationship and an analysis view angle, so that overall cognition and dynamic judgment on municipal environment states are constructed. The method of combining the rapid response of the end side, the global cloud analysis and the big data processing capability realizes the real-time connection of municipal environmental data in the links of acquisition, transmission, analysis and feedback, and further enhances the processing capability, the continuity and the cooperativity of an environmental monitoring system on mass data on the basis of maintaining the original analysis logic. The prior art has the following defects: In the prior art, in the process of real-time analysis of municipal environmental monitoring data, a judgment result of a single analysis period is generally used as an alarm triggering basis. When the abnormal variation amplitude in each analysis period is in a preset acceptable range, the cloud real-time analysis link often judges the abnormal variation amplitude as normal fluctuation without triggering an alarm. However, in a continuous operation scenario, the seemingly acceptable abnormal changes are in a continuous superposition state in the real-time analysis chain, so that the environment monitoring data is subjected to implicit trend shift in the time dimension and gradually crosses the key evolution threshold under the condition of unrecognized environment monitoring data. Because the prior art focuses on single-step judgment and lacks the recognition capability of continuous superposition effect, early warning cannot be performed before trend level transition is formed, and finally the mutation of the environmental state is initiated in a very short time, and is difficult to recover by a conventional regulation and control means once the mutation occurs, so that serious municipal environmental risks are brought. The above information disclosed in the background section is only for enhancement of understanding of the background of the disclosure and therefore it may include information that does not form the prior art that is already known to a person of ordinary skill in the art. Disclosure of Invention The invention aims to provide a municipal environmental monitoring data real-time analysis method and system based on end cloud cooperation, so as to solve the problems in the background technology. In order to achieve the purpose, the invention provides the technical scheme that the municipal environmental monitoring data real-time analysis method based on end cloud cooperation comprises the following steps: establishing a continuous period alignment chain for real-time data analysis, sequentially recording the variation direction, the variation rate and the arrival time of the abnormal amplitude according to each analysis period, and sequentially writing the recorded period analysis information into a unified time track to form an accumulated variation trace band for describing periodic abnormal variation; Performing adjacent period alignment analysis based on an accumulated change trace band formed by continuous periods, continuously spreading abnormal amplitude of each period along the same direction change direction, identifying a continuous section and a turnover section of a change slope, and generating a slope migration list containing a slope migration relation among the periods; Tracking an abnormal change track by using the generated slope migration list, positioning a trend acceler