CN-121980450-A - Energy consumption real-time alarm system and method

CN121980450ACN 121980450 ACN121980450 ACN 121980450ACN-121980450-A

Abstract

The embodiment of the application provides an energy consumption real-time warning system and method, which relate to the technical field of energy management, wherein the system comprises a warning rule management module, a warning rule calculation engine and a historical energy consumption library, wherein the warning rule management module is used for receiving warning rules and sending the warning rules to the Flink calculation engine; the energy consumption data source is used for collecting accumulated energy consumption values of the energy meter in real time and sending the collected real-time accumulated energy consumption values to the Flink computing engine, the historical energy consumption library is used for storing historical energy consumption data, setting a time window according to a time span period in an alarm rule, acquiring an initial energy consumption value of an index point position of the current time window according to an acquisition instruction and sending the initial energy consumption value to the Flink computing engine, and the Flink computing engine is used for calculating energy consumption in unit time in real time according to the alarm rule, the initial energy consumption value and the real-time accumulated energy consumption value and triggering an alarm when the energy consumption in unit time is detected to meet a preset threshold value. The application can realize the reliability of the identification of the potential energy safety hazard and the abnormal energy consumption event.

Inventors

ZHANG PENG
ZHU XIANG

Assignees

京东方能源科技股份有限公司

Dates

Publication Date: 20260505
Application Date: 20260109

Claims (10)

1. An energy consumption real-time warning system, characterized by comprising: The alarm rule management module is used for receiving alarm rules and sending the alarm rules to the Flink calculation engine and the historical energy consumption library, wherein the alarm rules comprise index point positions and time span periods; The energy consumption data source is used for collecting the accumulated energy consumption value of the energy meter in real time and sending the collected real-time accumulated energy consumption value to the Flink calculation engine; the historical energy consumption database is used for storing historical energy consumption data, setting a time window according to a time span period in an alarm rule, acquiring an initial energy consumption value of an index point position of the current time window according to an acquisition instruction, and transmitting the initial energy consumption value to the Flink calculation engine; and the Flink calculation engine is used for calculating the energy consumption in unit time in real time according to the alarm rule, the initial energy consumption value and the real-time accumulated energy consumption value, and triggering an alarm when the energy consumption in unit time is detected to meet the preset threshold value.
2. The energy consumption real-time alarm system according to claim 1, wherein the alarm rule further comprises a continuous alarm frequency threshold, and the index point position is single, and the Flink calculation engine is specifically configured to: Taking the initial energy consumption value of the current time window as a reference, and processing the real-time accumulated energy consumption value sent by the energy consumption data source in the current time window according to the time sequence: For each real-time accumulated energy consumption value, calculating the energy consumption per unit time and comparing the energy consumption with a preset threshold value: If the energy consumption value is larger than the preset threshold value, accumulating 1 by the alarm counter, and not processing the subsequent real-time accumulated energy consumption value in the current time window; If the energy consumption value is not greater than the preset threshold value, resetting the alarm counter, and continuing to process the next real-time accumulated energy consumption value; And if the alarm counter is detected to reach the threshold value of the continuous alarm times, triggering an alarm, otherwise, updating the next time window into the current time window, and repeating the steps.
3. The energy consumption real-time alarm system according to claim 1, wherein the alarm rule further comprises a continuous alarm number threshold, a plurality of index points, and a link calculation engine, specifically configured to: In the current time window, calculating the unit time energy consumption of each index point based on the initial energy consumption value and the corresponding real-time accumulated energy consumption value of each index point; calculating the average value of the energy consumption of the index points in unit time according to the energy consumption of each index point in unit time; For each index point, judging whether the deviation between the unit time energy consumption of the current index point and the average value exceeds a deviation threshold value: If the current index point is exceeded, accumulating 1 by an alarm counter of the current index point, and neglecting other real-time accumulated energy consumption values of the current index point in a current time window; if the current index point is not exceeded, resetting an alarm counter of the current index point, and continuing to process the next real-time accumulated energy consumption value of the current index point; detecting whether an alarm counter of each index point position reaches a continuous alarm frequency threshold value: if the alarm is reached, triggering an alarm; if not, the next time window is used for updating the current time window, and the processing steps are repeated.
4. The energy use real-time alert system according to claim 2 or 3, further comprising a Redis in-memory database; The historical energy consumption database is used for sending the initial energy consumption value of the queried current time window to the Redis memory database; The Redis memory database is used for caching the initial energy consumption value, sending the initial energy consumption value to the Flink computing engine, setting the key failure time in the key failure monitoring mechanism, and sending an acquisition instruction to the historical energy consumption database when the key fails.
5. The energy consumption real-time alert system according to claim 4, further comprising an alert notification module; In the aspect of triggering alarm, the Flink computing engine is specifically used for sending alarm indication to the alarm notification module, wherein the alarm indication comprises abnormal index points, real-time accumulated energy consumption values when the abnormality occurs and a time window when the abnormality occurs; And the alarm notification module is used for pushing the alarm indication to the user.
6. The energy consumption real-time alert system according to claim 5, wherein the alert notification module is specifically configured to: and pushing the alarm indication to the user through one or more modes of mail, short message or APP.
7. The energy consumption real-time alert system according to claim 1, wherein the alert rule management module is further configured to: When detecting that the alarm rule is changed, pushing the changed alarm rule to the Flink calculation engine and the historical energy consumption library; The Flink calculation engine is also used for applying new rules to the unprocessed historical energy consumption data and the newly acquired real-time energy consumption data to execute processing; The historical energy consumption library is also used for adjusting historical energy consumption data query logic according to the changed alarm rule and sending the historical energy consumption data conforming to the new rule time window to the Flink calculation engine.
8. The energy consumption real-time warning method is characterized in that the method is applied to the energy consumption real-time warning system according to any one of claims 1-7, and the energy consumption real-time warning system comprises a warning rule management module, an energy consumption data source, a historical energy consumption library and a Flink calculation engine, and comprises the following steps: the alarm rule management module receives alarm rules and sends the alarm rules to the Flink calculation engine and the historical energy consumption library, wherein the alarm rules comprise index point positions and time span periods; The energy consumption data source collects the accumulated energy consumption value of the energy meter in real time and sends the collected real-time accumulated energy consumption value to the Flink calculation engine; The historical energy consumption data is stored, a time window is set according to a time span period in an alarm rule, and an initial energy consumption value of an index point position of the current time window is obtained according to an obtaining instruction and is sent to the Flink calculation engine; The Flink calculation engine calculates the energy consumption in unit time in real time according to the alarm rule, the initial energy consumption value and the real-time accumulated energy consumption value, and triggers an alarm when detecting that the energy consumption in unit time meets a preset threshold.
9. The energy consumption real-time warning system according to claim 8, wherein the warning rule further includes a continuous warning frequency threshold, and the index point location is single, the link calculation engine calculates the energy consumption in unit time in real time according to the warning rule, the initial energy consumption value and the real-time accumulated energy consumption value, and when the energy consumption in unit time is detected to meet the preset threshold, the warning is triggered, including: Taking the initial energy consumption value of the current time window as a reference, and processing the real-time accumulated energy consumption value sent by the energy consumption data source in the current time window according to the time sequence: For each real-time accumulated energy consumption value, calculating the energy consumption per unit time and comparing the energy consumption with a preset threshold value: If the energy consumption value is larger than the preset threshold value, accumulating 1 by the alarm counter, and not processing the subsequent real-time accumulated energy consumption value in the current time window; If the energy consumption value is not greater than the preset threshold value, resetting the alarm counter, and continuing to process the next real-time accumulated energy consumption value; And if the alarm counter is detected to reach the threshold value of the continuous alarm times, triggering an alarm, otherwise, updating the next time window into the current time window, and repeating the steps.
10. The energy consumption real-time warning system according to claim 8, wherein the warning rule further includes a continuous warning number threshold, the index points are plural, the link calculation engine calculates the energy consumption per unit time in real time according to the warning rule, the initial energy consumption value and the real-time accumulated energy consumption value, and when the energy consumption per unit time is detected to satisfy the preset threshold, the warning is triggered, including: In the current time window, calculating the unit time energy consumption of each index point based on the initial energy consumption value and the corresponding real-time accumulated energy consumption value of each index point; calculating the average value of the energy consumption of the index points in unit time according to the energy consumption of each index point in unit time; For each index point, judging whether the deviation between the unit time energy consumption of the current index point and the average value exceeds a deviation threshold value: If the current index point is exceeded, accumulating 1 by an alarm counter of the current index point, and neglecting other real-time accumulated energy consumption values of the current index point in a current time window; if the current index point is not exceeded, resetting an alarm counter of the current index point, and continuing to process the next real-time accumulated energy consumption value of the current index point; detecting whether an alarm counter of each index point position reaches a continuous alarm frequency threshold value: if the alarm is reached, triggering an alarm; if not, the next time window is used for updating the current time window, and the processing steps are repeated.

Description

Energy consumption real-time alarm system and method Technical Field The invention relates to the technical field of energy management, in particular to an energy consumption real-time warning system and method. Background Under the dual drive of global energy shortage and low-carbon development, energy management has become a core issue for industrial production, building operation and maintenance and urban energy networks. The method monitors the energy consumption state in real time and timely triggers abnormal alarms, is a key support for guaranteeing the energy supply continuity and improving the energy utilization efficiency, and is an important technical means for achieving the aims of energy conservation and emission reduction. Along with the deep integration of intelligent manufacturing and the Internet of things technology, the energy monitoring scene is continuously expanded, the energy consumption metering of single equipment is updated to full-flow multi-dimensional dynamic monitoring, and the rigidity requirement is provided for the real-time response capability and the data processing precision of an energy alarm system. The traditional energy alarm system generally adopts a timing batch processing mechanism, and performs centralized summarization, offline calculation and threshold comparison analysis on the dispersed and collected energy consumption data. The passive data processing mode has the remarkable limitation that due to the fact that the data processing has delay of a fixed time interval, when sudden abnormal fluctuation of energy consumption occurs, the system cannot sense and trigger an alarm in real time, the real-time response requirement cannot be met completely, and the potential energy safety hazard and the energy consumption abnormal event are difficult to identify at the first time. Disclosure of Invention The embodiment of the invention provides an energy consumption real-time warning system and method, which aim to solve the problem that potential energy safety hazards and energy consumption abnormal events cannot be identified at the first time. The embodiment of the invention discloses an energy consumption real-time alarm system, which comprises: The alarm rule management module is used for receiving alarm rules and sending the alarm rules to the Flink calculation engine and the historical energy consumption library, wherein the alarm rules comprise index point positions and time span periods; The energy consumption data source is used for collecting the accumulated energy consumption value of the energy meter in real time and sending the collected real-time accumulated energy consumption value to the Flink calculation engine; the historical energy consumption database is used for storing historical energy consumption data, setting a time window according to a time span period in an alarm rule, acquiring an initial energy consumption value of an index point position of the current time window according to an acquisition instruction, and transmitting the initial energy consumption value to the Flink calculation engine; and the Flink calculation engine is used for calculating the energy consumption in unit time in real time according to the alarm rule, the initial energy consumption value and the real-time accumulated energy consumption value, and triggering an alarm when the energy consumption in unit time is detected to meet the preset threshold value. In one embodiment, the alarm rule further comprises a continuous alarm times threshold, wherein the index point position is single, and the Flink calculation engine is specifically used for: Taking the initial energy consumption value of the current time window as a reference, and processing the real-time accumulated energy consumption value sent by the energy consumption data source in the current time window according to the time sequence: For each real-time accumulated energy consumption value, calculating the energy consumption per unit time and comparing the energy consumption with a preset threshold value: If the energy consumption value is larger than the preset threshold value, accumulating 1 by the alarm counter, and not processing the subsequent real-time accumulated energy consumption value in the current time window; If the energy consumption value is not greater than the preset threshold value, resetting the alarm counter, and continuing to process the next real-time accumulated energy consumption value; And if the alarm counter is detected to reach the threshold value of the continuous alarm times, triggering an alarm, otherwise, updating the next time window into the current time window, and repeating the steps. In one embodiment, the alarm rule further comprises a continuous alarm times threshold, wherein the index points are multiple, and the Flink calculation engine is specifically used for: In the current time window, calculating the unit time energy consumption of each index point based on the initial