+

CN115840640A - Operation acceleration system and method for power edge intelligent algorithm - Google Patents

Operation acceleration system and method for power edge intelligent algorithm Download PDF

Info

Publication number
CN115840640A
CN115840640A CN202211502410.7A CN202211502410A CN115840640A CN 115840640 A CN115840640 A CN 115840640A CN 202211502410 A CN202211502410 A CN 202211502410A CN 115840640 A CN115840640 A CN 115840640A
Authority
CN
China
Prior art keywords
data
acceleration
power edge
sub
module
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Pending
Application number
CN202211502410.7A
Other languages
Chinese (zh)
Inventor
辛明勇
徐长宝
高吉普
王宇
何雨旻
祝健杨
林呈辉
冯起辉
杨婧
文屹
吕黔苏
谈竹奎
徐玉韬
代奇迹
孟令雯
文贤馗
申彧
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Guizhou Power Grid Co Ltd
Original Assignee
Guizhou Power Grid Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Guizhou Power Grid Co Ltd filed Critical Guizhou Power Grid Co Ltd
Priority to CN202211502410.7A priority Critical patent/CN115840640A/en
Publication of CN115840640A publication Critical patent/CN115840640A/en
Pending legal-status Critical Current

Links

Images

Classifications

    • YGENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
    • Y02TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
    • Y02DCLIMATE CHANGE MITIGATION TECHNOLOGIES IN INFORMATION AND COMMUNICATION TECHNOLOGIES [ICT], I.E. INFORMATION AND COMMUNICATION TECHNOLOGIES AIMING AT THE REDUCTION OF THEIR OWN ENERGY USE
    • Y02D10/00Energy efficient computing, e.g. low power processors, power management or thermal management

Landscapes

  • Management, Administration, Business Operations System, And Electronic Commerce (AREA)

Abstract

The invention discloses an operation acceleration system and method for an intelligent algorithm of a power edge, which comprises the following steps: determining target operation data to be calculated, and splitting the target operation data into a plurality of data groups according to different operation nodes; determining scheduling levels corresponding to the operation submodules respectively according to the historical resource loss and the calculation amount required for executing the corresponding operation tasks and performing data scheduling distribution; and monitoring each operation submodule, and carrying out operation acceleration according to a preset acceleration calculation rule when the operation time and the resource consumption of the corresponding target operation submodule exceed preset thresholds. The operation acceleration system and method for the power edge intelligent algorithm ensure that each operation task can be allocated to a proper operation sub-module to be effectively implemented, improve the operation efficiency, accelerate the operation when the operation timeout is determined, improve the capability and efficiency of the system for processing complex operation and reduce the power consumption overhead.

Description

一种针对电力边缘智能算法的运算加速系统及方法A computing acceleration system and method for power edge intelligent algorithm

技术领域technical field

本发明涉及运算加速技术领域,具体为一种针对电力边缘智能算法的运算加速系统及方法。The invention relates to the technical field of operation acceleration, in particular to an operation acceleration system and method for power edge intelligent algorithms.

背景技术Background technique

随着进入信息时代,将电力边缘智能算法应用在电力系统中已变得越来越普遍,但是由于计算量大、计算过程复杂、且边缘计算的实时性要求较高,亟需针对终端中所运行的算法模型进行加速,以避免降低运算的执行效率。With the entry of the information age, the application of power edge intelligent algorithms in power systems has become more and more common. The running algorithm model is accelerated to avoid reducing the execution efficiency of the operation.

目前,采用到的运算加速方法包括引入运算加速部件执行复杂运算,虽然上述方法能够在一定程度上提高处理复杂运算的能力和效率,但对于运算数据量大、以及如何有效调度计算资源,现有方法并没有提出一个有效的解决方案,存在运算效果不佳的问题。At present, the calculation acceleration methods adopted include introducing calculation acceleration components to perform complex calculations. Although the above methods can improve the ability and efficiency of processing complex calculations to a certain extent, for the large amount of calculation data and how to effectively schedule computing resources, existing The method does not propose an effective solution, and there is a problem of poor operation effect.

发明内容Contents of the invention

本部分的目的在于概述本发明的实施例的一些方面以及简要介绍一些较佳实施例。在本部分以及本申请的说明书摘要和发明名称中可能会做些简化或省略以避免使本部分、说明书摘要和发明名称的目的模糊,而这种简化或省略不能用于限制本发明的范围。The purpose of this section is to outline some aspects of embodiments of the invention and briefly describe some preferred embodiments. Some simplifications or omissions may be made in this section, as well as in the abstract and titles of this application, to avoid obscuring the purpose of this section, the abstract and titles, and such simplifications or omissions should not be used to limit the scope of the invention.

鉴于上述存在的问题,提出了本发明。In view of the above problems, the present invention has been proposed.

因此,本发明解决的技术问题是:现有的电力边缘计算方法存在对运算数据量大、运算复杂的运算效果不佳的问题,以及如何有效调度计算资源的优化问题。Therefore, the technical problem to be solved by the present invention is: the existing electric power edge computing method has the problem of poor operation effect on large amount of computing data and complex computing, and the problem of how to effectively schedule the optimization of computing resources.

为解决上述技术问题,本发明提供如下技术方案:一种针对电力边缘智能算法的运算加速方法,包括:In order to solve the above-mentioned technical problems, the present invention provides the following technical solutions: an operation acceleration method for power edge intelligent algorithms, including:

确定待执行计算的目标操作数据,并按照不同的运算节点,将所述目标操作数据拆分成多个数据分组;determining the target operation data to be calculated, and splitting the target operation data into multiple data packets according to different computing nodes;

根据历史资源损耗量、执行相应运算任务所需的计算量,确定各运算子模块分别对应的调度级别并进行数据调度分配;According to the amount of historical resource consumption and the amount of calculation required to perform corresponding calculation tasks, determine the corresponding scheduling level of each calculation sub-module and perform data scheduling and allocation;

对各所述运算子模块进行监控,并在确定相应目标运算子模块的运算时间、以及资源消耗量均超过预设阈值时,按照预设的加速计算规则进行运算加速。Each operation sub-module is monitored, and when it is determined that the operation time and resource consumption of the corresponding target operation sub-module exceed a preset threshold, the operation is accelerated according to a preset acceleration calculation rule.

作为本发明所述的针对电力边缘智能算法的运算加速方法的一种优选方案,其中:所述确定待执行计算的目标操作数据包括:获取初始操作数据,并按照预设的遍历方式,对获取到的各项初始操作数据进行遍历;在遍历的过程中,根据预设的数据处理方式对遍历到的初始操作数据进行处理,以确定目标操作数据。As a preferred solution of the calculation acceleration method for power edge intelligent algorithms in the present invention, wherein: the determination of the target operation data to be calculated includes: obtaining the initial operation data, and according to the preset traversal method, the acquired During the traversal process, process the traversed initial operation data according to the preset data processing method to determine the target operation data.

作为本发明所述的针对电力边缘智能算法的运算加速方法的一种优选方案,其中:所述遍历方式包括递归、非递归和层次三种遍历方式;所述数据处理方式包括用于剔除包含预设关键字的无效数据的无效数据过滤方式、补全缺失数据的信息补全方式以及噪声数据处理方式中的至少一种。As a preferred solution of the calculation acceleration method for power edge intelligent algorithms in the present invention, wherein: the traversal methods include three traversal methods: recursive, non-recursive and hierarchical; At least one of an invalid data filtering method for invalid data of keywords, an information completion method for filling missing data, and a noise data processing method is set.

作为本发明所述的针对电力边缘智能算法的运算加速方法的一种优选方案,其中:所述每个数据分组分别对应于相应运算节点中对应涵盖到的运算任务,且包括执行所述运算任务所需使用到的运算数据。As a preferred solution of the computing acceleration method for power edge intelligent algorithms described in the present invention, wherein: each of the data packets corresponds to the corresponding computing tasks covered by the corresponding computing nodes, and includes executing the computing tasks The required operational data.

作为本发明所述的针对电力边缘智能算法的运算加速方法的一种优选方案,其中:所述运算节点是指所述目标操作数据对应的完整运算阶段由多个运算节点组成,且各运算节点之间具备先后执行顺序。As a preferred solution of the calculation acceleration method for the power edge intelligent algorithm described in the present invention, wherein: the calculation node means that the complete calculation stage corresponding to the target operation data is composed of multiple calculation nodes, and each calculation node There is a sequence of execution among them.

作为本发明所述的针对电力边缘智能算法的运算加速方法的一种优选方案,其中:所述数据调度分配包括:对所述数据分组进行处理,得到相应的局部运算结果;按照运算节点的先后执行顺序,对经由相应运算子模块输出的局部运算结果进行整合,以得到对应完整运算阶段的整体运算结果。As a preferred solution of the calculation acceleration method for power edge intelligent algorithms described in the present invention, wherein: the data scheduling allocation includes: processing the data packets to obtain corresponding local calculation results; according to the order of the calculation nodes The execution sequence is to integrate the partial operation results output by the corresponding operation sub-modules to obtain the overall operation results corresponding to the complete operation stage.

作为本发明所述的针对电力边缘智能算法的运算加速系统的一种优选方案,其中:数据获取模块,用于确定待执行计算的目标操作数据,并按照不同的运算节点,将所述目标操作数据拆分成多个数据分组;As a preferred solution of the computing acceleration system for power edge intelligent algorithms described in the present invention, wherein: the data acquisition module is used to determine the target operation data to be calculated, and according to different computing nodes, the target operation The data is split into multiple data packets;

并行计算模块,包括多个运算子模块以及连接到各所述运算子模块的主控模块,其中:所述主控模块用于进行数据调度分配和对各运算子模块进行监控判断是否需要进行运算加速。A parallel computing module, including a plurality of operation sub-modules and a main control module connected to each of the operation sub-modules, wherein: the main control module is used to perform data scheduling and distribution and monitor each operation sub-module to determine whether operation is required accelerate.

作为本发明所述的针对电力边缘智能算法的运算加速系统的一种优选方案,其中:所述运算子模块,用于对经由所述主控模块分配到的数据分组进行处理,得到相应的局部运算结果;As a preferred scheme of the computing acceleration system for power edge intelligent algorithms described in the present invention, wherein: the computing sub-module is used to process the data packets allocated via the main control module to obtain the corresponding local operation result;

所述主控模块,还用于按照运算节点的先后执行顺序,对经由相应运算子模块输出的局部运算结果进行整合,以得到对应完整运算阶段的整体运算结果。The main control module is also used to integrate the local operation results output by the corresponding operation sub-modules according to the execution sequence of the operation nodes, so as to obtain the overall operation results corresponding to the complete operation stage.

作为本发明所述的针对电力边缘智能算法的运算加速系统的一种优选方案,其中:所述运算加速系统还包括性能优化模块,用于在确定并行运算任务存在多个子任务时,对所述并行运算任务中同步产生的执行数据进行切分操作,以得到各子任务分别对应的子执行数据块。As a preferred solution of the computing acceleration system for power edge intelligent algorithms described in the present invention, wherein: the computing accelerating system further includes a performance optimization module, which is used to optimize the The execution data synchronously generated in the parallel computing task is segmented to obtain sub-execution data blocks corresponding to each sub-task.

作为本发明所述的针对电力边缘智能算法的运算加速系统的一种优选方案,其中:所述性能优化模块还用于分别确定在对相应子执行数据块进行并行处理操作时,产生的性能消耗信息;根据所述性能消耗信息,进行故障运行分析,并在确定存在故障运行隐患时,反馈对应的性能优化策略到主控端,以触发主控端根据接收到的性能优化策略,进行系统优化。As a preferred solution of the computing acceleration system for power edge intelligent algorithms described in the present invention, wherein: the performance optimization module is also used to respectively determine the performance consumption generated when performing parallel processing operations on corresponding sub-execution data blocks Information; according to the performance consumption information, perform fault operation analysis, and when it is determined that there is a hidden danger of fault operation, feed back the corresponding performance optimization strategy to the main control end, so as to trigger the main control end to perform system optimization according to the received performance optimization strategy .

本发明的有益效果:本发明提供的针对电力边缘智能算法的运算加速系统及方法通过对并行运算任务进行分析,并在进行数据调度分配之前,通过对各运算子模块所对应的调度级别进行识别,以确保每一个运算任务都能分配到合适的运算子模块进行有效实施,提高了运算效率。另外,通过主控模块对各所述运算子模块在执行运算任务时,产生的运算时间以及资源消耗量进行监控,并在确定存在运算超时的情况下,按照预设的加速计算规则进行运算加速,提高系统处理复杂运算的能力和效率,降低功耗开销。Beneficial effects of the present invention: the computing acceleration system and method for power edge intelligent algorithms provided by the present invention analyze the parallel computing tasks and identify the scheduling level corresponding to each computing sub-module before data scheduling and allocation , so as to ensure that each computing task can be assigned to a suitable computing sub-module for effective implementation, which improves the computing efficiency. In addition, the main control module monitors the calculation time and resource consumption generated by each of the calculation sub-modules when performing calculation tasks, and when it is determined that there is a calculation timeout, the calculation is accelerated according to the preset acceleration calculation rule , improve the ability and efficiency of the system to process complex operations, and reduce power consumption.

附图说明Description of drawings

为了更清楚地说明本发明实施例的技术方案,下面将对实施例描述中所需要使用的附图作简单地介绍,显而易见地,下面描述中的附图仅仅是本发明的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动性的前提下,还可以根据这些附图获得其它的附图。其中:In order to more clearly illustrate the technical solutions of the embodiments of the present invention, the following will briefly introduce the accompanying drawings that need to be used in the description of the embodiments. Obviously, the accompanying drawings in the following description are only some embodiments of the present invention. For Those of ordinary skill in the art can also obtain other drawings based on these drawings without any creative effort. in:

图1为本发明第一个实施例提供的一种针对电力边缘智能算法的运算加速系统及方法的方法流程图;Fig. 1 is a method flowchart of a computing acceleration system and method for power edge intelligent algorithms provided by the first embodiment of the present invention;

图2为本发明第二个实施例提供的一种针对电力边缘智能算法的运算加速系统及方法的系统结构示意图;FIG. 2 is a schematic diagram of the system structure of a computing acceleration system and method for power edge intelligent algorithms provided by the second embodiment of the present invention;

图3为本发明第三个实施例提供的一种针对电力边缘智能算法的运算加速系统及方法的48h负荷预测结果与历史真实数据对比曲线图。Fig. 3 is a comparison graph of 48h load forecast results and historical real data of a computing acceleration system and method for power edge intelligent algorithms provided by the third embodiment of the present invention.

具体实施方式Detailed ways

为使本发明的上述目的、特征和优点能够更加明显易懂,下面结合说明书附图对本发明的具体实施方式做详细的说明,显然所描述的实施例是本发明的一部分实施例,而不是全部实施例。基于本发明中的实施例,本领域普通人员在没有做出创造性劳动前提下所获得的所有其他实施例,都应当属于本发明的保护的范围。In order to make the above-mentioned purposes, features and advantages of the present invention more obvious and easy to understand, the specific implementation modes of the present invention will be described in detail below in conjunction with the accompanying drawings. Obviously, the described embodiments are part of the embodiments of the present invention, not all of them. Example. Based on the embodiments of the present invention, all other embodiments obtained by ordinary persons in the art without creative efforts shall fall within the protection scope of the present invention.

在下面的描述中阐述了很多具体细节以便于充分理解本发明,但是本发明还可以采用其他不同于在此描述的其它方式来实施,本领域技术人员可以在不违背本发明内涵的情况下做类似推广,因此本发明不受下面公开的具体实施例的限制。In the following description, a lot of specific details are set forth in order to fully understand the present invention, but the present invention can also be implemented in other ways different from those described here, and those skilled in the art can do it without departing from the meaning of the present invention. By analogy, the present invention is therefore not limited to the specific examples disclosed below.

其次,此处所称的“一个实施例”或“实施例”是指可包含于本发明至少一个实现方式中的特定特征、结构或特性。在本说明书中不同地方出现的“在一个实施例中”并非均指同一个实施例,也不是单独的或选择性的与其他实施例互相排斥的实施例。Second, "one embodiment" or "an embodiment" referred to herein refers to a specific feature, structure or characteristic that may be included in at least one implementation of the present invention. "In one embodiment" appearing in different places in this specification does not all refer to the same embodiment, nor is it a separate or selective embodiment that is mutually exclusive with other embodiments.

本发明结合示意图进行详细描述,在详述本发明实施例时,为便于说明,表示器件结构的剖面图会不依一般比例作局部放大,而且所述示意图只是示例,其在此不应限制本发明保护的范围。此外,在实际制作中应包含长度、宽度及深度的三维空间尺寸。The present invention is described in detail in conjunction with schematic diagrams. When describing the embodiments of the present invention in detail, for the convenience of explanation, the cross-sectional view showing the device structure will not be partially enlarged according to the general scale, and the schematic diagram is only an example, which should not limit the present invention. scope of protection. In addition, the three-dimensional space dimensions of length, width and depth should be included in actual production.

同时在本发明的描述中,需要说明的是,术语中的“上、下、内和外”等指示的方位或位置关系为基于附图所示的方位或位置关系,仅是为了便于描述本发明和简化描述,而不是指示或暗示所指的装置或元件必须具有特定的方位、以特定的方位构造和操作,因此不能理解为对本发明的限制。此外,术语“第一、第二或第三”仅用于描述目的,而不能理解为指示或暗示相对重要性。At the same time, in the description of the present invention, it should be noted that the orientation or positional relationship indicated by "upper, lower, inner and outer" in the terms is based on the orientation or positional relationship shown in the accompanying drawings, and is only for the convenience of describing the present invention. The invention and the simplified description do not indicate or imply that the device or element referred to must have a specific orientation, be constructed and operate in a specific orientation, and thus should not be construed as limiting the present invention. In addition, the terms "first, second or third" are used for descriptive purposes only, and should not be construed as indicating or implying relative importance.

本发明中除非另有明确的规定和限定,术语“安装、相连、连接”应做广义理解,例如:可以是固定连接、可拆卸连接或一体式连接;同样可以是机械连接、电连接或直接连接,也可以通过中间媒介间接相连,也可以是两个元件内部的连通。对于本领域的普通技术人员而言,可以具体情况理解上述术语在本发明中的具体含义。Unless otherwise specified and limited in the present invention, the term "installation, connection, connection" should be understood in a broad sense, for example: it can be a fixed connection, a detachable connection or an integrated connection; it can also be a mechanical connection, an electrical connection or a direct connection. A connection can also be an indirect connection through an intermediary, or it can be an internal communication between two elements. Those of ordinary skill in the art can understand the specific meanings of the above terms in the present invention in specific situations.

实施例1Example 1

参照图1,为本发明的一个实施例,提供了一种针对电力边缘智能算法的运算加速方法,包括:Referring to Fig. 1, it is an embodiment of the present invention, which provides a calculation acceleration method for power edge intelligent algorithm, including:

S1:确定待执行计算的目标操作数据,并按照不同的运算节点,将所述目标操作数据拆分成多个数据分组;S1: Determine the target operation data to be calculated, and split the target operation data into multiple data packets according to different computing nodes;

更进一步的,每个数据分组分别对应于相应运算节点中对应涵盖到的运算任务,且包括执行所述运算任务所需使用到的运算数据。Furthermore, each data group corresponds to a computing task covered by a corresponding computing node, and includes computing data required to execute the computing task.

更进一步的,确定待执行计算的目标操作数据,包括:Furthermore, determine the target operation data to be calculated, including:

数据获取模块获取初始操作数据,并按照预设的遍历方式,对获取到的各项初始操作数据进行遍历。所述遍历方式包括递归、非递归和层次三种遍历方式。The data acquisition module acquires initial operation data, and traverses the acquired initial operation data according to a preset traversal method. The traversal modes include three traversal modes: recursive, non-recursive and hierarchical.

数据获取模块在遍历的过程中,根据预设的数据处理方式对遍历到的初始操作数据进行处理,以确定目标操作数据,其中,所述数据处理方式包括用于剔除包含预设关键字的无效数据的无效数据过滤方式、补全缺失数据的信息补全方式以及噪声数据处理方式中的至少一种。During the traversal process, the data acquisition module processes the traversed initial operation data according to the preset data processing method to determine the target operation data, wherein the data processing method includes removing invalid data containing preset keywords. At least one of an invalid data filtering method of data, an information complementing method of supplementing missing data, and a noise data processing method.

需要说明的是,在构建遍历规则时,数据获取模块可以基于数据获取时间的先后顺序,从最开始获取的数据依次往最后一时间点获取到的数据进行遍历。或依据数据类型以及数据间的关联程度,例如:针对关联程度高的多项目标数据,进行统一遍历;针对同一类型的数据,将统一进行遍历。或其他数据特征确定遍历规则,本申请实施例对此不作限定。It should be noted that when constructing the traversal rules, the data acquisition module can traverse from the data acquired at the beginning to the data acquired at the last time point in sequence based on the order of data acquisition time. Or according to the data type and the degree of correlation between the data, for example: perform unified traversal for multiple target data with a high degree of correlation; for the same type of data, perform unified traversal. or other data characteristics to determine the traversal rule, which is not limited in this embodiment of the present application.

数据获取模块可以将获取到的各项初始操作数据分别存储至预设的数据表中不同存储标识分别对应的存储地址中,后续再根据存储标识对该数据表中存储的多条数据进行遍历。The data acquisition module can store the acquired initial operation data in the storage addresses corresponding to different storage identifiers in the preset data table, and then traverse multiple pieces of data stored in the data table according to the storage identifiers.

更进一步的,目标操作数据对应的完整运算阶段由多个运算节点组成,且各运算节点之间具备先后执行顺序。Furthermore, the complete operation stage corresponding to the target operation data is composed of multiple operation nodes, and each operation node has a sequence of execution.

S2:根据历史资源损耗量、执行相应运算任务所需的计算量,确定各运算子模块分别对应的调度级别并进行数据调度分配;S2: According to the amount of historical resource consumption and the amount of calculation required to perform corresponding calculation tasks, determine the corresponding scheduling level of each calculation sub-module and perform data scheduling and allocation;

需要说明的是,通过对并行运算任务进行分析,并在进行数据调度分配之前,对各运算子模块所对应的调度级别进行识别,确保了每一个运算任务都能分配到合适的运算子模块进行有效实施,提高了运算效率。It should be noted that by analyzing parallel computing tasks and identifying the scheduling level corresponding to each computing sub-module before data scheduling and allocation, it is ensured that each computing task can be assigned to a suitable computing sub-module for execution. Effective implementation improves operational efficiency.

S3:对各所述运算子模块进行监控,并在确定相应目标运算子模块的运算时间、以及资源消耗量均超过预设阈值时,按照预设的加速计算规则进行运算加速;S3: Monitor each operation sub-module, and when it is determined that the operation time and resource consumption of the corresponding target operation sub-module exceed a preset threshold, perform operation acceleration according to a preset acceleration calculation rule;

更进一步的,运算子模块对经由所述主控模块分配到的数据分组进行处理,得到相应的局部运算结果。Furthermore, the operation sub-module processes the data packets allocated via the main control module to obtain corresponding local operation results.

需要说明的是,运算子模块在对分配到的数据分组进行处理之前,可以先查询整个系统的历史运算记录,看过去是否做过相同的运算处理,若有,则根据历史运算记录确定相应的局部运算结果,如此,可以在避免反复运算操作的情况下,提高运算效率、以及资源利用率。It should be noted that before processing the assigned data group, the operation sub-module can first query the historical operation records of the entire system to see whether the same operation has been done in the past, and if so, determine the corresponding operation according to the historical operation records. Local calculation results, in this way, can improve calculation efficiency and resource utilization while avoiding repeated calculation operations.

还需要说明的是,经由运算子模块计算所得的局部运算结果将统一缓存到预设的存储空间中,以便于后续的整合调用以及历史运算记录的搜索。It should also be noted that the local operation results calculated by the operation sub-module will be uniformly cached in the preset storage space, so as to facilitate the subsequent integrated call and the search of historical operation records.

更进一步的,在提高运算速度方面,例如,针对运算量大,运行时间长所导致的数据处理效率低的问题。运算子模块还可以基于预设的运算关键字段,对获取到的数据分组进行分段处理;数据分段方式可以为水平分段或垂直分段。之后,再针对分段所得的数据中包含的每个数据段分别进行计算,以此提高数据处理效率。Furthermore, in terms of increasing the computing speed, for example, it aims at the problem of low data processing efficiency caused by a large amount of computing and long running time. The operation sub-module can also segment the obtained data group based on the preset operation key field; the data segmentation method can be horizontal segmentation or vertical segmentation. Afterwards, calculations are performed on each data segment included in the segmented data, so as to improve data processing efficiency.

更进一步的,主控模块按照运算节点的先后执行顺序,对经由相应运算子模块输出的局部运算结果进行整合,以得到对应完整运算阶段的整体运算结果。Furthermore, the main control module integrates the local operation results output by the corresponding operation sub-modules according to the execution sequence of the operation nodes, so as to obtain the overall operation results corresponding to the complete operation stage.

需要说明的是,主控模块对各所述运算子模块在执行运算任务时,产生的运算时间以及资源消耗量进行监控,并在确定存在运算超时的情况下,按照预设的加速计算规则进行运算加速,提高系统处理复杂运算的能力和效率,降低功耗开销。主控模块还可以通过提高主频、适时地调整计算资源的分配情况等方式优化各运算子模块的运算速度,提高系统工作效率。It should be noted that the main control module monitors the calculation time and resource consumption generated by each of the calculation sub-modules when performing calculation tasks, and when it is determined that there is a calculation timeout, the calculation is performed according to the preset accelerated calculation rules. Computing acceleration, improving the system's ability and efficiency in processing complex operations, and reducing power consumption. The main control module can also optimize the operation speed of each operation sub-module by increasing the main frequency and adjusting the allocation of computing resources in a timely manner, so as to improve the working efficiency of the system.

需要说明的是,通过对并行运算任务进行分析,能够及时了解各运算子模块是否存在故障运行隐患以及能否支撑当前的运算处理,并及时性能优化,避免断情况的发生,以确保每一个运算任务都能有效实施,提高了运算效率。It should be noted that through the analysis of parallel computing tasks, it is possible to know in a timely manner whether each computing sub-module has a hidden danger of faulty operation and whether it can support the current computing processing, and optimize performance in time to avoid the occurrence of outages, so as to ensure that each computing The tasks can be effectively implemented, and the computing efficiency is improved.

实施例2Example 2

参照图2,为本发明的一个实施例,提供了一种针对电力边缘智能算法的运算加速系统,包括:数据获取模块100和并行计算模块200。Referring to FIG. 2 , an embodiment of the present invention provides an operation acceleration system for intelligent algorithms at the power edge, including: a data acquisition module 100 and a parallel computing module 200 .

更进一步的,数据获取模块100,用于确定待执行计算的目标操作数据,并按照不同的运算节点,将所述目标操作数据拆分成多个数据分组,其中,每个数据分组分别对应于相应运算节点中对应涵盖到的运算任务,且包括执行所述运算任务所需使用到的运算数据;数据获取模块还用于获取初始操作数据,并按照预设的遍历方式,对获取到的各项初始操作数据进行遍历。Furthermore, the data acquisition module 100 is configured to determine the target operation data to be calculated, and split the target operation data into multiple data packets according to different computing nodes, wherein each data packet corresponds to The computing tasks covered in the corresponding computing nodes include the computing data needed to execute the computing tasks; the data acquisition module is also used to obtain initial operating data, and perform each acquired Item initial operation data to traverse.

并行计算模块200,包括多个运算子模块201以及连接到各所述运算子模块的主控模块202。The parallel computing module 200 includes a plurality of computing sub-modules 201 and a main control module 202 connected to each of the computing sub-modules.

其中,主控模块202用于根据历史资源损耗量、执行相应运算任务所需的计算量,确定各所述运算子模块201分别对应的调度级别,并按照所述调度级别,进行数据调度分配;主控模块202还用于对各所述运算子模块201在执行运算任务时,产生的运算时间以及资源消耗量进行监控,并在确定相应目标运算子模块201的运算时间、以及资源消耗量均超过预设阈值时,按照预设的加速计算规则进行运算加速。Wherein, the main control module 202 is used to determine the scheduling level corresponding to each of the operation sub-modules 201 according to the amount of historical resource consumption and the amount of calculation required to perform the corresponding calculation task, and perform data scheduling and allocation according to the scheduling level; The main control module 202 is also used to monitor the computing time and resource consumption generated by each computing sub-module 201 when performing computing tasks, and determine the computing time and resource consumption of the corresponding target computing sub-module 201. When the preset threshold is exceeded, the calculation is accelerated according to the preset acceleration calculation rules.

更进一步的,该系统还包括性能优化模块300,性能优化模块300在确定并行运算任务存在多个子任务时,对所述并行运算任务中同步产生的执行数据进行切分操作,以得到各子任务分别对应的子执行数据块。Furthermore, the system also includes a performance optimization module 300. When the performance optimization module 300 determines that there are multiple subtasks in the parallel computing task, it performs a segmentation operation on the execution data synchronously generated in the parallel computing task to obtain the subtasks The corresponding sub-execution data blocks respectively.

性能优化模块300分别确定在对相应子执行数据块进行并行处理操作时,产生的性能消耗信息。其中,性能消耗信息包括缓存信息、对计算资源的占用情况,例如,CPU的占用情况、内容资源的占用情况、硬盘消耗情况等。The performance optimization module 300 respectively determines performance consumption information generated when performing parallel processing operations on corresponding sub-execution data blocks. Wherein, the performance consumption information includes cache information, occupancy of computing resources, for example, occupancy of CPU, occupancy of content resources, consumption of hard disk, and the like.

更进一步的,根据所述性能消耗信息,进行故障运行分析,并在确定存在故障运行隐患时,反馈对应的性能优化策略到主控端,以触发主控端根据接收到的性能优化策略,进行系统优化。Furthermore, according to the performance consumption information, the failure operation analysis is performed, and when it is determined that there is a hidden danger of failure operation, the corresponding performance optimization strategy is fed back to the main control terminal, so as to trigger the main control terminal to perform the operation according to the received performance optimization strategy System Optimization.

性能优化模块300还可以结合一定时间段内的资源消耗趋势,来判断各运算子模块是否存在性能过剩的情况,若是,则可以向主控模块202请求降低对应的计算资源配置。并在确定相应运算子模块的性能不足以支撑当前的运算处理时,可以向主控模块请求分配更多地计算资源给该运算子模块,以避免运算中断情况的发生。The performance optimization module 300 can also combine the resource consumption trend within a certain period of time to determine whether each operation sub-module has excess performance, and if so, can request the main control module 202 to reduce the corresponding computing resource configuration. And when it is determined that the performance of the corresponding operation sub-module is not enough to support the current operation processing, the main control module may be requested to allocate more computing resources to the operation sub-module, so as to avoid the occurrence of operation interruption.

实施例3Example 3

以下为本发明的一个实施例,提供了一种针对电力边缘智能算法的运算加速系统及方法,为了验证本发明的有益效果,通过仿真对比实验进行科学论证。The following is an embodiment of the present invention, which provides a computing acceleration system and method for power edge intelligent algorithms. In order to verify the beneficial effects of the present invention, a scientific demonstration is carried out through simulation and comparison experiments.

选取贵阳市某充电站2020年12月数据负荷值作为本次试验的数据源进行仿真处理,结合历史天气情况利用电力边缘计算进行48h负荷预测。The data load value of a charging station in Guiyang City in December 2020 was selected as the data source of this experiment for simulation processing, and combined with historical weather conditions, the 48h load forecast was performed using power edge computing.

对于同一执行任务,本仿真实验中使用的电力边缘智能算法的运算加速系统及方法与传统运算加速系统与方法相比,实验效果如下表所示:For the same execution task, the calculation acceleration system and method of the power edge intelligent algorithm used in this simulation experiment are compared with the traditional calculation acceleration system and method, and the experimental results are shown in the following table:

传统方法traditional method 本方法This method 执行任务所需时间time required to perform tasks 0.637s0.637s 0.475s0.475s 效率efficiency 47.5%47.5% 81.5%81.5% 功耗power consumption 7.2W7.2W 1.2W1.2W

可见,采用本发明的电力边缘智能算法的运算加速系统,大大提高了加速效果,成倍降低了运算时间,效率提升了70%以上,功耗大幅度降低。It can be seen that the operation acceleration system adopting the power edge intelligent algorithm of the present invention greatly improves the acceleration effect, doubles the operation time, improves the efficiency by more than 70%, and greatly reduces the power consumption.

如图3可见,将本方法所得48h负荷预测结果与历史真实数据相比所得曲线趋势大致相同,证明了本方法计算的准确性和有效性。As can be seen in Figure 3, the curve trend obtained by comparing the 48h load prediction results obtained by this method with the historical real data is roughly the same, which proves the accuracy and effectiveness of this method.

应说明的是,以上实施例仅用以说明本发明的技术方案而非限制,尽管参照较佳实施例对本发明进行了详细说明,本领域的普通技术人员应当理解,可以对本发明的技术方案进行修改或者等同替换,而不脱离本发明技术方案的精神和范围,其均应涵盖在本发明的权利要求范围当中。It should be noted that the above embodiments are only used to illustrate the technical solutions of the present invention without limitation, although the present invention has been described in detail with reference to the preferred embodiments, those of ordinary skill in the art should understand that the technical solutions of the present invention can be carried out Modifications or equivalent replacements without departing from the spirit and scope of the technical solution of the present invention shall be covered by the claims of the present invention.

Claims (10)

1. An operation acceleration method for a power edge intelligent algorithm is characterized by comprising the following steps:
determining target operation data to be calculated, and splitting the target operation data into a plurality of data groups according to different operation nodes;
determining scheduling levels corresponding to the operation submodules respectively according to the historical resource loss and the calculation amount required for executing the corresponding operation tasks and performing data scheduling distribution;
and monitoring each operation submodule, and carrying out operation acceleration according to a preset acceleration calculation rule when the operation time and the resource consumption of the corresponding target operation submodule exceed preset thresholds.
2. The operation acceleration method for the power edge intelligence algorithm according to claim 1, characterized in that: the determining target operation data of a calculation to be performed comprises: acquiring initial operation data, and traversing each item of acquired initial operation data according to a preset traversal mode; and in the traversing process, processing the traversed initial operation data according to a preset data processing mode to determine target operation data.
3. The operation acceleration method for the power edge intelligence algorithm according to claim 2, characterized in that: the traversal modes comprise a recursive mode, a non-recursive mode and a hierarchical traversal mode; the data processing mode comprises at least one of an invalid data filtering mode for eliminating invalid data containing preset keywords, an information complementing mode for complementing missing data and a noise data processing mode.
4. The operation acceleration method for the power edge intelligence algorithm according to claim 1, characterized in that: each data packet corresponds to the operation task correspondingly covered in the corresponding operation node and comprises operation data required to be used for executing the operation task.
5. An operation acceleration method for a power edge intelligence algorithm according to claim 1 or 4, characterized by: the operation nodes mean that the complete operation stage corresponding to the target operation data is composed of a plurality of operation nodes, and the operation nodes have a sequential execution sequence.
6. The operation acceleration method for the power edge intelligence algorithm according to claim 1, characterized in that: the data scheduling assignment includes: processing the data packet to obtain a corresponding local operation result; and integrating the local operation results output by the corresponding operation sub-modules according to the sequential execution sequence of the operation nodes to obtain an overall operation result corresponding to the complete operation stage.
7. An operation acceleration system for a power edge intelligence algorithm, comprising:
the data acquisition module (100) is used for determining target operation data to be calculated, and dividing the target operation data into a plurality of data groups according to different operation nodes;
a parallel computing module (200) comprising a plurality of operational sub-modules (201) and a master control module (202) connected to each of said operational sub-modules, wherein: the main control module (202) is used for carrying out data scheduling distribution and monitoring each operation submodule (201) to judge whether operation acceleration is needed.
8. The operation acceleration system for a power edge intelligence algorithm of claim 7, characterized by: the operation submodule is used for processing the data packets distributed by the main control module to obtain corresponding local operation results;
the main control module is further configured to integrate the local operation results output by the corresponding operation sub-modules according to the execution sequence of the operation nodes, so as to obtain an overall operation result corresponding to the complete operation stage.
9. The operation acceleration system for a power edge intelligence algorithm of claim 7, characterized by: the operation acceleration system further comprises a performance optimization module (300) which is used for performing segmentation operation on the execution data synchronously generated in the parallel operation task when the parallel operation task is determined to have a plurality of subtasks so as to obtain the sub execution data blocks respectively corresponding to the subtasks.
10. The system for operational acceleration of a power edge intelligence algorithm of claim 9, wherein: the performance optimization module (300) is further configured to determine performance consumption information generated when performing parallel processing operations on corresponding sub-execution data blocks, respectively; and performing fault operation analysis according to the performance consumption information, and feeding back a corresponding performance optimization strategy to the main control end when determining that the fault operation hidden danger exists, so as to trigger the main control end to perform system optimization according to the received performance optimization strategy.
CN202211502410.7A 2022-11-28 2022-11-28 Operation acceleration system and method for power edge intelligent algorithm Pending CN115840640A (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202211502410.7A CN115840640A (en) 2022-11-28 2022-11-28 Operation acceleration system and method for power edge intelligent algorithm

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202211502410.7A CN115840640A (en) 2022-11-28 2022-11-28 Operation acceleration system and method for power edge intelligent algorithm

Publications (1)

Publication Number Publication Date
CN115840640A true CN115840640A (en) 2023-03-24

Family

ID=85576114

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202211502410.7A Pending CN115840640A (en) 2022-11-28 2022-11-28 Operation acceleration system and method for power edge intelligent algorithm

Country Status (1)

Country Link
CN (1) CN115840640A (en)

Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN107122490A (en) * 2017-05-18 2017-09-01 郑州云海信息技术有限公司 The data processing method and system of aggregate function in a kind of Querying by group
US9864636B1 (en) * 2014-12-10 2018-01-09 Amazon Technologies, Inc. Allocating processor resources based on a service-level agreement
CN109669758A (en) * 2018-09-11 2019-04-23 深圳平安财富宝投资咨询有限公司 Concocting method, device, equipment and the storage medium of server resource
CN113312166A (en) * 2021-07-29 2021-08-27 阿里云计算有限公司 Resource processing method and device
CN115310566A (en) * 2022-10-12 2022-11-08 浪潮电子信息产业股份有限公司 Distributed training system, method, device, equipment and readable storage medium

Patent Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US9864636B1 (en) * 2014-12-10 2018-01-09 Amazon Technologies, Inc. Allocating processor resources based on a service-level agreement
CN107122490A (en) * 2017-05-18 2017-09-01 郑州云海信息技术有限公司 The data processing method and system of aggregate function in a kind of Querying by group
CN109669758A (en) * 2018-09-11 2019-04-23 深圳平安财富宝投资咨询有限公司 Concocting method, device, equipment and the storage medium of server resource
CN113312166A (en) * 2021-07-29 2021-08-27 阿里云计算有限公司 Resource processing method and device
CN115310566A (en) * 2022-10-12 2022-11-08 浪潮电子信息产业股份有限公司 Distributed training system, method, device, equipment and readable storage medium

Similar Documents

Publication Publication Date Title
CN108509276B (en) Video task dynamic migration method in edge computing environment
Marotta et al. A simulated annealing based approach for power efficient virtual machines consolidation
CN107247623B (en) A kind of distributed cluster system and data connecting method based on multi-core CPU
CN107861796B (en) A Virtual Machine Scheduling Method Supporting Energy Consumption Optimization of Cloud Data Centers
US12340248B2 (en) Intelligent dynamic scaling based on internal and external indicators
CN112000703A (en) Data warehousing processing method and device, computer equipment and storage medium
CN112015765B (en) Spark cache elimination method and system based on cache value
CN113419861B (en) GPU card group-oriented graph traversal hybrid load balancing method
Wang et al. Hybrid pulling/pushing for i/o-efficient distributed and iterative graph computing
Wang et al. A stable matching-based virtual machine allocation mechanism for cloud data centers
US20230281157A1 (en) Post-exascale graph computing method, system, storage medium and electronic device thereof
CN117978806B (en) A method for implementing cross-cluster resource scheduling
CN113934525B (en) Hadoop cluster task scheduling method based on positive and negative feedback load scheduling algorithm
CN115840640A (en) Operation acceleration system and method for power edge intelligent algorithm
CN105824737B (en) Memory data set exchange system and method for replacing for big data processing system
CN118689397A (en) A method and system for processing massive data
Ismaeel et al. Real-time energy-conserving vm-provisioning framework for cloud-data centers
CN117149795A (en) Adaptive graph calculation updating method and system based on hybrid memory
CN114020782B (en) Aggregate calculation optimization method based on Spark SQL
CN116974994A (en) High-efficiency file collaboration system based on clusters
CN107967172A (en) A kind of Spark tasks dynamic migration method and system towards isomery storage
CN114238481A (en) Distributed real-time data importing device
CN112783892A (en) Chained task execution engine realized through event-driven model
CN118394721B (en) Analysis management system based on computer system resource usage data
Liu et al. Edge node data replica management method for distribution Internet of Things

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination
点击 这是indexloc提供的php浏览器服务,不要输入任何密码和下载