CN-122027433-A - Cloud platform high-cost balancing method for user storage equipment
Abstract
The invention relates to the technical field of household energy storage equipment cloud platform development and cloud service deployment, in particular to a household energy storage equipment-oriented cloud platform high-cost balancing method, wherein household energy storage equipment reports operation data to a message middleware layer through an equipment access layer, a single service layer deployed as single service subscribes messages from the message middleware layer, the interior of the single service layer is divided into a plurality of independent parallel consumption groups, different service data are respectively processed and written into corresponding databases, the monitoring and alarming layer monitors key operation indexes, when the indexes exceed a threshold value, an alarming flow is triggered, operation of one or more consumption groups is automatically or manually selected to be suspended according to a hierarchical degradation strategy based on I/O resource consumption sequencing, a non-core data storage function is enabled to enter a degradation state, core services are kept available, and suspended consumption groups are manually restored through the control and operation and maintenance layer after faults are eliminated. The invention realizes module-level fault isolation and automatic degradation, and balances cost constraint and high availability requirement of the system.
Inventors
- ZHANG WEI
Assignees
- 深圳市盛弘艾苏娜能源科技有限公司
Dates
- Publication Date
- 20260512
- Application Date
- 20260108
Claims (8)
- 1. The cloud platform high-cost balancing method for the user storage equipment is characterized by comprising the following steps of: the user storage equipment reports the information containing the operation data to the information middleware layer through the equipment access layer; The single service layer is deployed as a single service and is used as a consumer to subscribe and consume equipment messages from the message middleware layer, wherein the interior of the single service layer is divided into a plurality of mutually independent and parallel running consumption groups based on different business functions and data storage targets, and each consumption group processes corresponding business data and writes the business data into a database of a specified type; The monitoring and alarming layer periodically collects and monitors at least one preset key operation index of the single service layer and the message middleware layer, and when the value of any one of the monitored key operation indexes exceeds a preset threshold value, an alarming process is triggered; Responsive to the alert procedure, automatically or manually selectively suspending operation of one or more of the consumption groups within the monolithic service layer in accordance with a predefined hierarchical degradation policy based on a ranking of input/output resource consumption levels such that non-core data storage functions corresponding to suspended consumption groups enter a degraded state while remaining core business functions of the monolithic service layer remain available; After the fault condition triggering the alarm is eliminated, the operation of the suspended consumer group is manually resumed through an operation interface provided by the control and operation layer.
- 2. The method for balancing the high cost of the cloud platform facing the user storage equipment according to claim 1, wherein the message middleware layer is realized by adopting a message queue component based on a publish/subscribe mode, and a plurality of consumption groups in the single service layer consume the broadcasted and distributed equipment messages from the same message theme of the message middleware layer in a parallel mode; The consumer group includes: Logging in a consumption group, which is used for processing equipment registration and online information and writing relevant data into a memory database and a relational database; the real-time data consumption group is used for processing the real-time status information of the equipment and writing the data into the internal database; The business data consumption group is used for processing the equipment alarm information and the basic attribute data and writing the data into the relational database; And the historical data consumption group is used for processing the historical data of the equipment for archiving and writing the data into the time sequence database.
- 3. The method for balancing the cloud platform high cost of the user storage equipment according to claim 1, wherein the monitoring and alarming layer collects monitoring indexes according to configured sampling periods through a deployed lightweight monitoring tool; the key operation indexes comprise the total accumulation amount of messages to be consumed in the message middleware layer, message consumption delay time corresponding to each consumption group in the single service layer, the number of available connections in a database connection pool, and the write operation delay time or the write operation failure proportion of a database.
- 4. The method for balancing the cloud platform high cost of the user storage equipment according to claim 3, wherein the triggering alarm process comprises an automatic alarm channel and a manual alarm channel which are parallel; the automatic alarm channel automatically invokes a degradation processing application program interface exposed by the single service layer after the monitoring and alarm layer judges that the key operation index exceeds the threshold value; the manual alarm channel pushes notification information containing alarm details to a visual webpage control console or an external communication tool of the control and operation and maintenance layer synchronously by the monitoring and alarm layer, so that operation and maintenance personnel can check and manually trigger subsequent operations.
- 5. The method for balancing high cost of cloud platform for user storage device according to claim 1, wherein the selectively suspending consumer groups according to a predefined hierarchical degradation policy is performed in the following order: Firstly, suspending the operation of the historical data consumption group, and stopping writing the historical data of the equipment into a time sequence database; if the system load is not restored to the normal level, further suspending the operation of the service data consumption group, and stopping writing the service data into the relational database; and if the system load is still in a high level, finally suspending the operation of the real-time data consumption group, and stopping writing the real-time state data into the memory database.
- 6. The method for balancing the cloud platform high cost of the user storage equipment according to claim 1, wherein a global automatic management switch is arranged in the single service layer; When a degradation processing application program interface is called through the automatic alarm channel, the single service layer firstly checks the current state of the automatic management switch; If the automatic management switch is in an on state, automatically executing the grading and degrading strategy, and suspending the corresponding consumption group; if the automatic management switch is in a closed state, the single service layer does not execute automatic degradation operation and waits for manual intervention by the control and operation layer.
- 7. The method for balancing high cost of cloud platform for user storage equipment according to claim 1, wherein the operation interface provided by the control and operation layer is a visual web interface, and the interface at least provides the following functions: dynamically displaying the current running state and key indexes of each consumption group; providing manual start and stop operation controls for each consumer group; a master switch control is provided for globally enabling or disabling an automatic degradation function triggered by the automatic alert channel.
- 8. The cloud platform high-cost balancing method for the user storage equipment according to claim 1, wherein the equipment access layer is communicated with the user storage equipment through a message queue telemetry transmission protocol and forwards equipment messages to the message middleware layer through a message proxy, network communication is conducted among the message middleware layer, the single service layer and the monitoring and alarming layer through a transmission control protocol, and the control and operation layer interacts with the single service layer through a hypertext transmission protocol or a hypertext transmission security protocol.
Description
Cloud platform high-cost balancing method for user storage equipment Technical Field The invention relates to the technical field of development of a cloud platform and deployment of cloud services of household energy storage equipment, in particular to a high-cost balancing method of the cloud platform for the household energy storage equipment. Background The household energy storage equipment (hereinafter referred to as "household energy storage equipment") is taken as an important component of the distributed energy system, functions such as remote monitoring, data acquisition and intelligent management are usually required to be realized through a cloud platform, and in the architecture design and deployment implementation of the household energy storage equipment cloud platform, the balance problem between cost control and high availability of the system is usually faced. In the prior art, a household storage equipment cloud platform mainly adopts two main stream architecture modes: The micro-service architecture divides an application program into a plurality of independently deployed service units, each service is responsible for a specific service function, and has good modularization level and fault isolation capability, but the implementation needs to rely on complex infrastructures such as service registration and discovery, configuration centers, API gateways, distributed link tracking and the like, so that the development period is long, the operation and maintenance complexity is high, more server resources and professional operation and maintenance personnel are needed, the overall cost is high, and under the globalization deployment scene, the cost and the deployment difficulty are further increased due to the fact that complete micro-service clusters are required to be deployed in different areas respectively. The single architecture integrates all functional modules into a single executable application program, has the advantages of simple development, convenient deployment, low resource consumption and the like, is particularly suitable for rapid iteration in the early stage of projects and cost-sensitive scenes, however, each functional module in the traditional single architecture is highly coupled and lacks an effective fault isolation mechanism, and in the running process of a user storage equipment cloud platform, equipment continuously generates mass data and executes intensive I/O writing operation, and when a certain database channel has a writing performance bottleneck or fault, the blocking or even unavailability of the whole application program is easily caused, so that the usability and the stability of the system are seriously influenced. Under the realistic conditions of strong market competition and limited profit space of a single device in the household storage device industry, development and operation cost of a matched cloud platform are required to be strictly controlled, meanwhile, service facing an end user (C-terminal) is required to have higher availability, faults can be rapidly identified and isolated, and user experience is prevented from being influenced, so that contradiction between high cost and high complexity of a micro-service architecture and low availability and strong coupling of a single-unit architecture in the prior art becomes a main technical obstacle for restricting development of the household storage device cloud platform. Therefore, there is a need for a cloud platform high-cost balancing method for user storage devices, which improves on the above-mentioned problems. Disclosure of Invention The invention aims to provide a cloud platform high-cost balancing method for user storage equipment, which aims to solve the problems in the background technology. In order to achieve the above purpose, the present invention provides the following technical solutions: a cloud platform high-cost balancing method for user storage equipment comprises the following steps: And the user storage equipment reports the running state data to the message middleware layer through the equipment access layer. The single service layer deployed as single service subscribes and consumes the equipment message from the message middleware layer, the interior of the single service layer is divided into a plurality of independent and parallel consumption groups based on service functions and data storage types, and each group processes corresponding service data and writes the corresponding service data into a specified database. The monitoring and alarming layer monitors the key operation indexes of the single service layer in real time, and when any index exceeds a preset threshold value, an alarming process is triggered. Responsive to the alert, the operation of the corresponding consumer group is selectively suspended automatically or manually within the monolithic service layer in accordance with a predefined hierarchical degradation policy that is ordered based on the d