技术领域Technical Field
本申请涉及计算机技术领域，尤其涉及一种数据处理方法、业务系统及电子设备。The present application relates to the field of computer technology, and in particular to a data processing method, a business system and an electronic device.
背景技术Background Art
边缘网关是连接终端设备和云端服务器之间的设备，在物联网系统中扮演着至关重要的角色。它充当终端设备与云端服务器之间的中间层，并负责从终端设备采集数据，对其进行处理和存储，并向云端服务器发送经过处理和封装后的数据。通过与物联网设备相连，边缘网关可以实现对设备的实时控制和监测，并对数据进行分析和决策。同时，边缘网关还可以协调终端设备之间的通信，从而实现对整个物联网环境的有效管理和控制。The edge gateway is a device that connects terminal devices and cloud servers, and plays a vital role in the IoT system. It acts as an intermediate layer between terminal devices and cloud servers, and is responsible for collecting data from terminal devices, processing and storing it, and sending processed and packaged data to the cloud server. By connecting to IoT devices, the edge gateway can achieve real-time control and monitoring of devices, and analyze and make decisions on data. At the same time, the edge gateway can also coordinate communications between terminal devices, thereby achieving effective management and control of the entire IoT environment.
当前边缘智能网关上的业务系统对业务数据的读取与展示通常仅局限于本机设备数据内容，这就造成业务数据会集中存储在一个设备上。一旦设备数据量达到一定规模，则导致业务数据的请求和展示耗时较久，用户体验差。Currently, the reading and display of business data by the business system on the edge intelligent gateway is usually limited to the data content of the local device, which causes the business data to be stored in one device. Once the amount of device data reaches a certain scale, the request and display of business data will take a long time, resulting in a poor user experience.
发明内容Summary of the invention
本申请目的是提供一种数据处理方法、业务系统及电子设备，能够解决现有边缘智能网关的业务系统对业务数据请求和展示耗时过久的问题。The purpose of this application is to provide a data processing method, a business system and an electronic device, which can solve the problem that the business system of the existing edge intelligent gateway takes too long to request and display business data.
为了实现上述目的，本申请实施例是这样实现的：In order to achieve the above purpose, the embodiment of the present application is implemented as follows:
第一方面，提供一种数据处理方法，应用于业务系统，所述业务系统包括提供用户访问的边缘网关中心节点和用于分散存储业务数据的至少两个边缘网关数据节点，方法包括：In a first aspect, a data processing method is provided, which is applied to a business system, wherein the business system includes an edge gateway central node providing user access and at least two edge gateway data nodes for decentralized storage of business data, the method comprising:
所述边缘网关数据节点对所述业务系统产生的业务数据进行存储；其中，所述边缘网关数据节点配置并运行有至少一个计算任务，且接收到的业务数据包括对应的所述计算任务运行所需的数据；The edge gateway data node stores the business data generated by the business system; wherein the edge gateway data node is configured with and runs at least one computing task, and the received business data includes data required for the corresponding computing task to run;
所述边缘网关中心节点响应于用户访问操作，基于内网穿透服务向用户指定的所述边缘网关数据节点获取业务数据；The edge gateway central node responds to the user access operation and obtains business data from the edge gateway data node specified by the user based on the intranet penetration service;
所述边缘网关中心节点对获取得到的业务数据进行屏幕展示。The edge gateway central node displays the acquired business data on the screen.
第二方面，提供一种业务系统，包括：提供用户访问的边缘网关中心节点和用于分散存储业务数据的至少两个边缘网关数据节点，其中：In a second aspect, a business system is provided, comprising: an edge gateway central node providing user access and at least two edge gateway data nodes for decentralized storage of business data, wherein:
所述边缘网关数据节点对所述业务系统产生的业务数据进行存储；The edge gateway data node stores the business data generated by the business system;
所述边缘网关中心节点响应于用户访问操作，基于内网穿透服务向用户指定的所述边缘网关数据节点获取业务数据；The edge gateway central node responds to the user access operation and obtains business data from the edge gateway data node specified by the user based on the intranet penetration service;
所述边缘网关中心节点对获取得到的业务数据进行屏幕展示。The edge gateway central node displays the acquired business data on the screen.
第三方面，本申请实施例提供了一种电子设备，包括：处理器；以及，被配置为存储计算机可执行指令的存储器，所述计算机可执行指令在被执行时使所述处理器执行第一方面所述的方法。In a third aspect, an embodiment of the present application provides an electronic device, comprising: a processor; and a memory configured to store computer-executable instructions, wherein the computer-executable instructions, when executed, cause the processor to execute the method described in the first aspect.
第四方面，提供一种计算机可读存储介质，所述计算机可读存储介质用于存储计算机可执行指令，所述计算机可执行指令在被处理器执行时实现第一方面所述的方法。According to a fourth aspect, a computer-readable storage medium is provided, wherein the computer-readable storage medium is used to store computer-executable instructions, and the computer-executable instructions implement the method described in the first aspect when executed by a processor.
本实施例的方案中，业务系统设置有边缘网关中心节点和至少两个边缘网关数据节点。边缘网关中心节点将业务系统所需运行的计算任务分配至各个边缘网关数据节点，从而以计算任务为粒度将业务数据分散存储至各个边缘网关数据节点。相对于集中存储在一个设备上的传统方案，本实施例的方案解决了设备数据量达到一定规模所导致的业务数据请求和展示耗时较久的问题，且业务系统的运行并不依赖云端支持，方案适合应用于没有云资源条件的场景。此外，边缘网关中心节点可响应于用户访问操作，基于内网穿透服务向用户指定的边缘网关数据节点获取业务数据，并获取得到的业务数据进行屏幕展示，以满足用户信息查询需求。In the solution of this embodiment, the business system is provided with an edge gateway central node and at least two edge gateway data nodes. The edge gateway central node distributes the computing tasks required to run the business system to each edge gateway data node, thereby dispersing and storing the business data to each edge gateway data node with computing tasks as the granularity. Compared with the traditional solution of centralized storage on one device, the solution of this embodiment solves the problem of long business data request and display time caused by the amount of device data reaching a certain scale, and the operation of the business system does not rely on cloud support. The solution is suitable for scenarios without cloud resource conditions. In addition, the edge gateway central node can respond to user access operations, obtain business data from the edge gateway data node specified by the user based on the intranet penetration service, and display the obtained business data on the screen to meet the user's information query needs.
附图说明BRIEF DESCRIPTION OF THE DRAWINGS
为了更清楚地说明本申请实施例或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本申请实施例中记载的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。In order to more clearly illustrate the embodiments of the present application or the technical solutions in the prior art, the drawings required for use in the embodiments or the description of the prior art will be briefly introduced below. Obviously, the drawings described below are only some embodiments recorded in the embodiments of the present application. For ordinary technicians in this field, other drawings can be obtained based on these drawings without paying creative work.
图1为本申请实施例的数据处理方法的流程示意图。FIG1 is a schematic flow chart of a data processing method according to an embodiment of the present application.
图2为本申请实施例的数据处理方法的应用架构示意图。FIG. 2 is a schematic diagram of an application architecture of a data processing method according to an embodiment of the present application.
图3为本申请实施例的数据处理方法基于Cannal服务同步内容的示意图。FIG3 is a schematic diagram of a data processing method according to an embodiment of the present application that synchronizes content based on a Cannal service.
图4为本申请实施例的数据处理方法分配算法任务的示意图。FIG4 is a schematic diagram of allocating algorithm tasks for the data processing method according to an embodiment of the present application.
图5为本申请实施例的业务系统的结构示意图。FIG5 is a schematic diagram of the structure of a business system according to an embodiment of the present application.
图6为本申请实施例的电子设备的结构示意图。FIG. 6 is a schematic diagram of the structure of an electronic device according to an embodiment of the present application.
具体实施方式DETAILED DESCRIPTION
如前所述，当前边缘智能网关上的业务系统对业务数据的读取与展示通常仅局限于本机设备数据内容，这就造成业务数据会集中存储在一个设备上。一旦设备数据量达到一定规模，则导致业务数据的请求和展示耗时较久，用户体验差。此外，数据展示与统计维度也比较简单，通常为列表样式，不如图表等方式直观生动，不便于用户直观感受。As mentioned above, the current business system on the edge intelligent gateway usually reads and displays business data only on the local device data content, which causes the business data to be stored on one device. Once the amount of device data reaches a certain scale, it takes a long time to request and display business data, resulting in a poor user experience. In addition, the data display and statistical dimensions are also relatively simple, usually in list style, which is not as intuitive and vivid as charts, and is not easy for users to intuitively experience.
针对上述问题，本申请提出一种数据处理方案，一方面通过至少两个边缘网关数据节点实现业务数据的分散式存储，解决业务数据集中存储所导致的数据请求时间过久的问题。另一方面通过边缘网关中心节点实现对边缘网关数据节点的内网穿透访问，以获取业务数据，并通过数据大屏展示对业务数据进行图表等方式的可视化展示。In response to the above problems, this application proposes a data processing solution. On the one hand, distributed storage of business data is realized through at least two edge gateway data nodes to solve the problem of long data request time caused by centralized storage of business data. On the other hand, intranet penetration access to edge gateway data nodes is realized through edge gateway central nodes to obtain business data, and business data is visualized through large-screen data display in the form of charts and other methods.
为了使本技术领域的人员更好地理解本说明书中的技术方案，下面将结合本申请实施例中的附图，对本申请实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是本说明书一部分实施例，而不是全部的实施例。基于本说明书中的实施例，本领域普通技术人员在没有作出创造性劳动前提下所获得的所有其他实施例，都应当属于本说明书保护的范围。In order to enable those skilled in the art to better understand the technical solutions in this specification, the technical solutions in the embodiments of this application will be clearly and completely described below in conjunction with the drawings in the embodiments of this application. Obviously, the described embodiments are only part of the embodiments of this specification, not all of the embodiments. Based on the embodiments in this specification, all other embodiments obtained by ordinary technicians in this field without creative work should fall within the scope of protection of this specification.
本申请的一个实施例提出一种数据处理方法，应用于业务系统。所述业务系统包括提供用户访问的边缘网关中心节点和用于分散存储业务数据的至少两个边缘网关数据节点。每个边缘网关数据节点均与边缘网关中心节点连接，以构成星型结构。其中，图1是该数据处理方法的流程示意图，包括：One embodiment of the present application proposes a data processing method, which is applied to a business system. The business system includes an edge gateway central node that provides user access and at least two edge gateway data nodes for decentralized storage of business data. Each edge gateway data node is connected to the edge gateway central node to form a star structure. Among them, Figure 1 is a flow chart of the data processing method, including:
S102，边缘网关数据节点对业务系统产生的业务数据进行存储，其中，边缘网关数据节点配置并运行有至少一个计算任务，且接收到业务数据包括用于运行对应的计算任务所需的数据。S102, the edge gateway data node stores the business data generated by the business system, wherein the edge gateway data node is configured with and runs at least one computing task, and the received business data includes data required for running the corresponding computing task.
本实施例中，业务系统通过边缘网关数据节点实现业务数据的分散存储。其中，每个边缘网关数据节点配置的计算任务也视为业务系统需要运行的计算任务。因此，业务系统相当于是将需要运行的计算任务分散给不同的边缘网关数据节点负责运行，并以计算任务为粒度，将业务数据由分配至对应的边缘网关数据节点进行分散存储。In this embodiment, the business system realizes the decentralized storage of business data through the edge gateway data node. Among them, the computing tasks configured by each edge gateway data node are also regarded as computing tasks that the business system needs to run. Therefore, the business system is equivalent to distributing the computing tasks that need to be run to different edge gateway data nodes for operation, and using the computing tasks as the granularity, the business data is distributed to the corresponding edge gateway data nodes for decentralized storage.
在一种可行的实现方式中，边缘网关数据节点对本地存储的业务数据进行统计，并将统计结果同步至所述边缘网关中心节点；对应地，边缘网关中心节点可以基于接收到的边缘网关数据节点的统计结果，生成对应的前端数据报表，并响应于用户访问操作，对用户指定的边缘网关数据节点的前端数据报表进行屏幕展示。即，用户通过边缘网关中心节点可以了解到每个边缘网关数据节点针对业务数据大致统计结果。In a feasible implementation, the edge gateway data node counts the business data stored locally and synchronizes the statistical results to the edge gateway central node; correspondingly, the edge gateway central node can generate a corresponding front-end data report based on the statistical results of the edge gateway data node received, and in response to the user access operation, the front-end data report of the edge gateway data node specified by the user is displayed on the screen. That is, the user can understand the approximate statistical results of each edge gateway data node for business data through the edge gateway central node.
S104，边缘网关中心节点响应于用户访问操作，基于内网穿透服务向用户指定的边缘网关数据节点获取业务数据。S104, the edge gateway central node responds to the user access operation and obtains business data from the edge gateway data node specified by the user based on the intranet penetration service.
网穿透服务（frp）是开源内网穿透工具，可利用处于内网或防火墙后的机器，对外网环境提供 http 或 https 服务，提高设备数据安全性。在本实施例中，边缘网关数据节点安装有frp客户端，并配置frpc.ini文件可与边缘网关中心节点进行连接，从而使得边缘网关中心节点通过frp向各个边缘网关数据节点获取业务数据。The network penetration service (frp) is an open source intranet penetration tool that can use machines in the intranet or behind the firewall to provide http or https services to the external network environment to improve the security of device data. In this embodiment, the edge gateway data node is installed with a frp client, and the frpc.ini file is configured to connect to the edge gateway central node, so that the edge gateway central node obtains business data from each edge gateway data node through frp.
S106，边缘网关中心节点对获取得到的业务数据进行屏幕展示。S106, the edge gateway central node displays the acquired business data on the screen.
本实施例中，边缘网关中心节基于Vue服务构建用户界面，并基于ECharts服务将获取到的业务数据以图表库形式呈现于用户界面。In this embodiment, the edge gateway center node builds a user interface based on the Vue service, and presents the acquired business data in the form of a chart library on the user interface based on the ECharts service.
此外，在上述基础之上，为了保证一些关键业务数据能够更快速地展示给用户。本实施例的边缘网关数据节点还可以对本地存储的业务数据进行分析，确定出关键业务数据；之后，边缘网关数据节点将本地的关键业务数据同步至边缘网关中心节点（边缘网关中心节点针对每个所述边缘网关数据节点设置有专属的数据库，以用于存储对应的关键业务数据）；对应地，后续边缘网关中心节点可在无需访问边缘网关数据节点的情况下，响应于用户访问操作，对用户指定的边缘网关数据节点的关键业务数据实现快速的屏幕展示。In addition, on the basis of the above, in order to ensure that some key business data can be displayed to users more quickly. The edge gateway data node of this embodiment can also analyze the locally stored business data to determine the key business data; then, the edge gateway data node synchronizes the local key business data to the edge gateway central node (the edge gateway central node is equipped with a dedicated database for each edge gateway data node to store the corresponding key business data); correspondingly, the subsequent edge gateway central node can respond to the user's access operation without accessing the edge gateway data node, and realize fast screen display of the key business data of the edge gateway data node specified by the user.
在其中一种可行的实现方式中，本实施例可以基于Canal服务实现关键业务数据的同步。In one feasible implementation, this embodiment can achieve synchronization of key business data based on the Canal service.
即，本实施例的边缘网关数据节点设置有MySQL数据库，并将地的关键业务数据存储至所述MySQL数据库。边缘网关数据节点在本地的所述MySQL数据库产生增量数据后，向边缘网关中心节点发送更新通知；对应地，边缘网关中心节点在接收到更新通知后，基于Canal服务，模拟 MySQL的交互协议，向该更新通知来源的边缘网关数据节点发送dump请求；接收到dump请求的边缘网关数据节点基于MySQL的交互协议，向边缘网关中心节点发送携带本地的关键业务数据的binary log文件，以实现同步。That is, the edge gateway data node of this embodiment is provided with a MySQL database, and the local key business data is stored in the MySQL database. After the edge gateway data node generates incremental data in the local MySQL database, it sends an update notification to the edge gateway central node; correspondingly, after receiving the update notification, the edge gateway central node simulates the MySQL interaction protocol based on the Canal service and sends a dump request to the edge gateway data node from which the update notification is sent; the edge gateway data node that receives the dump request sends a binary log file carrying local key business data to the edge gateway central node based on the MySQL interaction protocol to achieve synchronization.
在实际应用中，本实施例的业务系统不依赖云端支持，方案特别适合应用于没有云资源条件的场景。比如：布设监控的加油站需要借助人工智能的计算任务来识别抽烟行为，但因地处偏远地区无法借助云服务器完成计算任务。为此，可以就近以局域网络配置本实施例的业务系统，包括一个边缘网关中心节点和两个以上的边缘网关数据节点。其中，每个边缘网关数据节负责不同的计算任务（识别抽烟、违法侵入等），并接收其计算任务所需要摄像头通道的监控数据（业务数据）。即，所有摄像头通道的监控数据以计算任务为粒度，由各个边缘网关数据节点分担存储。边缘网关中心节点为均有屏幕的设备，主动可以向各个边缘网关数据节点获取计算任务的识别结果进行展示。此外，如果有需求，边缘网关中心节点在用户操作下，可以在向指定的边缘网关数据节点调取具体的监控数据进行展示。In practical applications, the business system of this embodiment does not rely on cloud support, and the solution is particularly suitable for scenarios without cloud resource conditions. For example: a gas station with monitoring needs to use artificial intelligence computing tasks to identify smoking behavior, but because it is located in a remote area, it cannot use a cloud server to complete the computing task. To this end, the business system of this embodiment can be configured with a local area network nearby, including an edge gateway central node and more than two edge gateway data nodes. Among them, each edge gateway data node is responsible for different computing tasks (identifying smoking, illegal intrusion, etc.), and receives the monitoring data (business data) of the camera channel required for its computing task. That is, the monitoring data of all camera channels is shared and stored by each edge gateway data node at the granularity of the computing task. The edge gateway central node is a device with a screen, and it can actively obtain the recognition results of the computing task from each edge gateway data node for display. In addition, if there is a need, the edge gateway central node can retrieve specific monitoring data from the specified edge gateway data node for display under user operation.
具体地，在上述实际应用中，本实施例的边缘网关中心节点获取各个边缘网关数据节点的监控算法任务列表和摄像头通道列表；边缘网关中心节点从各个边缘网关数据节点的监控算法任务列表中选取一个尚未运行的目标监控算法任务，并确定出运行目标监控算法任务所需的至少一个目标摄像头通道；边缘网关中心节点选取出资源能够支持运行目标监控算法任务的目标缘网关数据节点，并根据目标缘网关数据节点的编解码路数和摄像头通道列表，判断目标缘网关数据节点的编解码路数是否能够支持至少一个目标摄像头通道；若目标缘网关数据节点的编解码路数能够支持至少一个目标摄像头通道，则边缘网关中心节点将至少一个目标摄像头通道配置至边缘网关数据节点的摄像头通道列表中，并将目标监控算法任务分配至目标缘网关数据节点运行。若目标缘网关数据节点的编解码路数不能够支持至少一个目标摄像头通道，则边缘网关中心节点从所有缘网关数据节点中重新选取出内存能够支持运行目标监控算法任务的另一目标缘网关数据节点，以尝试将目标监控算法任务分配至重新选取出的目标缘网关数据节点。Specifically, in the above practical application, the edge gateway central node of this embodiment obtains the monitoring algorithm task list and camera channel list of each edge gateway data node; the edge gateway central node selects a target monitoring algorithm task that has not been run from the monitoring algorithm task list of each edge gateway data node, and determines at least one target camera channel required to run the target monitoring algorithm task; the edge gateway central node selects the target edge gateway data node whose resources can support the running of the target monitoring algorithm task, and judges whether the encoding and decoding number of the target edge gateway data node can support at least one target camera channel according to the encoding and decoding number of the target edge gateway data node and the camera channel list; if the encoding and decoding number of the target edge gateway data node can support at least one target camera channel, the edge gateway central node configures at least one target camera channel to the camera channel list of the edge gateway data node, and assigns the target monitoring algorithm task to the target edge gateway data node for operation. If the encoding and decoding number of the target edge gateway data node cannot support at least one target camera channel, the edge gateway central node re-selects another target edge gateway data node whose memory can support the running of the target monitoring algorithm task from all edge gateway data nodes, so as to try to assign the target monitoring algorithm task to the re-selected target edge gateway data node.
综上所述，本实施例的方法中，业务系统设置有边缘网关中心节点和至少两个边缘网关数据节点。边缘网关中心节点将业务系统所需运行的计算任务分配至各个边缘网关数据节点，从而以计算任务为粒度将业务数据分散存储至各个边缘网关数据节点。相对于集中存储在一个设备上的传统方案，本实施例的方法解决了设备数据量达到一定规模所导致的业务数据请求和展示耗时较久的问题，且业务系统的运行并不依赖云端支持，方案适合应用于没有云资源条件的场景。此外，边缘网关中心节点可响应于用户访问操作，基于内网穿透服务向用户指定的边缘网关数据节点获取业务数据，并获取得到的业务数据进行屏幕展示，以满足用户信息查询需求。To sum up, in the method of this embodiment, the business system is provided with an edge gateway central node and at least two edge gateway data nodes. The edge gateway central node distributes the computing tasks required to run the business system to each edge gateway data node, thereby dispersing and storing the business data to each edge gateway data node with computing tasks as the granularity. Compared with the traditional solution of centralized storage on one device, the method of this embodiment solves the problem of long business data request and display time caused by the amount of device data reaching a certain scale, and the operation of the business system does not rely on cloud support, and the solution is suitable for scenarios without cloud resource conditions. In addition, the edge gateway central node can respond to user access operations, obtain business data from the edge gateway data node specified by the user based on the intranet penetration service, and display the obtained business data on the screen to meet the user's information query needs.
下面结合应用场景对本实施例的方法进行详细介绍。The method of this embodiment is described in detail below in conjunction with application scenarios.
本应用场景用于向用户展示业务系统的业务数据，特别是业务系统的告警数据。参考图2所示，本应用场景的业务系统包括n个边缘网关数据节点和1个边缘网关中心节点。This application scenario is used to display the business data of the business system to the user, especially the alarm data of the business system. Referring to Figure 2, the business system of this application scenario includes n edge gateway data nodes and 1 edge gateway center node.
业务系统的业务数据由所有边缘网关数据节点分散存储。每个边缘网关数据节点设置有MySQL数据库和frp客户端。MySQL数据库用于存储告警数据（特别是关键告警数据）。frp客户端用于支持边缘网关中心节点内网透传的访问。The business data of the business system is stored in a decentralized manner by all edge gateway data nodes. Each edge gateway data node is equipped with a MySQL database and an frp client. The MySQL database is used to store alarm data (especially critical alarm data). The frp client is used to support intranet transparent access to the edge gateway center node.
边缘网关中心节点采用frp内网透传服务+Canal数据同步服务端+业务数据大屏展示的框架结构。此外，边缘网关中心节点设置有与边缘网关数据节点一一对应的用于存储关键告警数据的数据库。The edge gateway center node adopts the framework structure of frp intranet transparent transmission service + Canal data synchronization server + business data large screen display. In addition, the edge gateway center node is equipped with a database for storing key alarm data that corresponds to the edge gateway data node one by one.
Canal是Alibaba开源数据库同步框架，结合mysql作为数据同步中心节点，用户可通过Canal配置接入终端设备mysql信息来进行同步。边端设备无需把所有数据都同步到中心节点，只需按业务需求同步关键数据，可加快统计查询速度。Canal is Alibaba's open source database synchronization framework. It combines MySQL as the data synchronization center node. Users can configure the MySQL information of the access terminal device through Canal for synchronization. Edge devices do not need to synchronize all data to the central node, but only need to synchronize key data according to business needs, which can speed up statistical queries.
frp服务端是开源内网穿透工具，可利用处于内网或防火墙后的机器，对外网环境提供 http 或 https 服务，提高设备数据安全性。相关服务配置通过frps.ini文件进行。边端设备通过安装frp客户端，并配置frpc.ini文件可与服务端进行连接。frp也可作为内网服务根据需求进行部署。The frp server is an open source intranet penetration tool that can use machines in the intranet or behind a firewall to provide http or https services to the external network environment to improve the data security of the device. Related service configuration is performed through the frps.ini file. The edge device can connect to the server by installing the frp client and configuring the frpc.ini file. frp can also be deployed as an intranet service according to needs.
业务数据大屏展示系统主要是根据业务需求进行功能设计，选取Vue+ ECharts作为前端页面框架，springboot作为后端框架。 Vue用于构建用户界面，结合ECharts，基于JavaScript 的图表库，可以创建丰富的交互式数据可视化用户界面。业务上主要包括如下几点：The business data large screen display system is mainly designed based on business needs. Vue+ ECharts is selected as the front-end page framework and springboot is used as the back-end framework. Vue is used to build the user interface. Combined with ECharts, a JavaScript-based chart library, it can create a rich interactive data visualization user interface. The business mainly includes the following points:
1）提供配置负责接入不同边缘网关设备，包括设备名称、地址、端口、内网映射端口、数据库连接地址、端口、用户名、密码、设备SN、设备鉴权等关键内容，并通知Canal服务、frp服务同步配置内容。1) Provide configuration to access different edge gateway devices, including key contents such as device name, address, port, intranet mapping port, database connection address, port, user name, password, device SN, device authentication, etc., and notify Canal service and frp service to synchronize configuration contents.
2）提供大屏页面数据统计前端能力，让用户可用曲线图、柱状图、列表等图形化方式同时查看接入服务端的多边缘网关设备数据统计结果。2) Provides large-screen page data statistics front-end capabilities, allowing users to simultaneously view data statistics results of multiple edge gateway devices connected to the server in graphical forms such as curve charts, bar charts, and lists.
3）、提供大屏页面数据统计后端能力，后台根据数据特点以及业务需求，自动定时统计关键数据输出到库表，加快前端查询速度。3) Provide large-screen page data statistics backend capabilities. The backend automatically and regularly counts key data and outputs them to the database table based on data characteristics and business needs, speeding up front-end query speed.
其中，告警数据整体处理流程包括：The overall alarm data processing flow includes:
A1：边缘网关数据节点对业务系统产生的告警数据入库（mysql），例如智能算法告警、物联网设备告警，并产生数据库日志事件。A1: The edge gateway data node stores the alarm data generated by the business system in the database (MySQL), such as intelligent algorithm alarms and IoT device alarms, and generates database log events.
A2：Canal服务端通过dump协议自动与边缘网关上的mysql服务进行数据交互，并根据服务端配置的关联数据库进行数据入库。并通知有订阅数据变更的业务模块进行逻辑处理，及时更新页面数据。A2: The Canal server automatically interacts with the MySQL service on the edge gateway through the dump protocol, and stores data according to the associated database configured on the server. It also notifies the business module with subscription data changes to perform logical processing and update page data in a timely manner.
A3：边缘网关数据节点后台开启定时任务自动对大量业务数据提前进行统计分析，把统计结果缓存在业务统计表中，并同步到边缘网关中心节点。A3: The edge gateway data node background starts a scheduled task to automatically perform statistical analysis on a large amount of business data in advance, cache the statistical results in the business statistics table, and synchronize them to the edge gateway center node.
A4：用户通过边缘网关中心节点的页面接口查询业务大屏数据时直接从统计缓存表中读取数据，避免数据查询、计算带来的延时，提高用户体验。A4: When users query business large-screen data through the page interface of the edge gateway center node, they directly read data from the statistical cache table, avoiding delays caused by data query and calculation, and improving user experience.
A5：统计结果赋值给图表等大屏页面控件，用户进行查看。A5: The statistical results are assigned to large-screen page controls such as charts, and users view them.
A6：当用户需要点击查看告警图片、告警视频时，因边缘网关中心节点硬盘存储空间有限，需要直接访问分散在不同节点的边端设备告警数据，因此可以通过业务配置的frp端口映射，http直接访问指定设备上的内网数据链接，提高了设备数据的安全性。A6: When users need to click to view alarm pictures and videos, due to the limited hard disk storage space of the edge gateway central node, they need to directly access the alarm data of edge devices scattered on different nodes. Therefore, they can directly access the intranet data link on the specified device through the frp port mapping configured by the business and http, thereby improving the security of device data.
此外，参考图3所示，大屏数据统计业务系统对业务数据的收集处理流程如下：In addition, referring to FIG3 , the collection and processing flow of the business data by the large screen data statistics business system is as follows:
B1：对业务数据进行分库分表，提取核心关键数据内容作为数据同步的来源。不同边缘网关数据节点的关键业务数据在中心节点都有对应数据库名进行存储。B1: Divide the business data into different databases and tables, and extract the core key data content as the source of data synchronization. The key business data of different edge gateway data nodes are stored in the corresponding database name in the central node.
B2：边缘网关数据节点时任务按照设定的统计逻辑自动统计数据，并缓存到统计表，同步给边缘网关中心节点。B2: The edge gateway data node task automatically collects statistical data according to the set statistical logic, caches it in the statistical table, and synchronizes it to the edge gateway central node.
B3：边缘网关中心节点读取不同设备节点的统计数据再进行新的数据加工与提炼分析，作为前端数据报表的数据来源。B3: The edge gateway central node reads the statistical data of different device nodes and then performs new data processing and refinement analysis as the data source for the front-end data report.
B4：当需要及时数据更新反馈时，订阅Canal数据更新服务的业务后端会得到通知，让前端页面及时刷新展示新数据。B4: When timely data update feedback is required, the business backend that subscribes to Canal's data update service will be notified, allowing the front-end page to refresh and display the new data in a timely manner.
本应用场景的业务系统可以是监控系统。业务系统的服务对象可以是加油站、银行、商场等需要监控的场所。The business system of this application scenario can be a monitoring system. The service objects of the business system can be gas stations, banks, shopping malls and other places that need to be monitored.
这里以加油站为示例。现有的加油站需要通过运算力来实现如吸烟识别、非法闯入识别、车辆识别等。但基于应用场景的业务系统，只需要本地部署边缘网关中心节点和几个边缘网关数据节点即可。加油站的每个摄像头可以理解为一个摄像头通道，每个摄像头通道产生出对应摄像头监控区域的监控数据。本应用场景可以由边缘网关中心节点将吸烟识别、非法闯入识别这类的监控算法任务，以及每个监控算法任务所需的摄像头通道部署在边缘网关数据节点。边缘网关数据节点负责接收对应摄像头通道的监控数据，并对运行监控算法任务，比如某个监控算法任务需要摄像头通道1和摄像头通道2的监控数据，则负责运行该监控算法任务的边缘网关数据节点也对应需要接收摄像头通道1和摄像头通道2的监控数据。Here we take gas stations as an example. Existing gas stations need computing power to achieve functions such as smoking recognition, illegal intrusion recognition, and vehicle recognition. However, based on the business system of the application scenario, only the edge gateway central node and several edge gateway data nodes need to be deployed locally. Each camera at the gas station can be understood as a camera channel, and each camera channel generates monitoring data for the corresponding camera monitoring area. In this application scenario, the edge gateway central node can deploy monitoring algorithm tasks such as smoking recognition and illegal intrusion recognition, as well as the camera channels required for each monitoring algorithm task, on the edge gateway data node. The edge gateway data node is responsible for receiving the monitoring data of the corresponding camera channel and running the monitoring algorithm task. For example, if a monitoring algorithm task requires the monitoring data of camera channel 1 and camera channel 2, the edge gateway data node responsible for running the monitoring algorithm task also needs to receive the monitoring data of camera channel 1 and camera channel 2.
具体地，边缘网关中心节点在配置某个目标监控算法任务时，需要根据目标监控算法任务的内存开销和所需的摄像头通道，结合边缘网关数据节点的剩余内存资源和编解码路数，来分配目标监控算法任务。即，获得目标监控算法任务的边缘网关数据节点的剩余内存资源在能够支撑目标监控算法任务的内存开销，且编解码路数也要能够支撑目标监控算法任务所需的摄像头通道。Specifically, when configuring a target monitoring algorithm task, the edge gateway center node needs to allocate the target monitoring algorithm task based on the memory overhead of the target monitoring algorithm task and the required camera channels, combined with the remaining memory resources and codec paths of the edge gateway data node. That is, the remaining memory resources of the edge gateway data node that obtains the target monitoring algorithm task must be able to support the memory overhead of the target monitoring algorithm task, and the codec paths must also be able to support the camera channels required by the target monitoring algorithm task.
在实际应用中，每个边缘网关数据节点可以配置有监控算法任务列表和摄像头通道列表。其中，监控算法任务列表包含边缘网关数据节点当前已分配到监控算法任务，边缘网关数据节点负责运行其监控算法任务列表中的所有监控算法任务；摄像头通道列表包含边缘网关数据节点当前已配置的摄像头通道，边缘网关数据节点负责接收摄像头通道列表中的所有摄像头通道的监控数据。对于边缘网关中心节点而言，还进一步需要动态实时监控边缘网关数据节点的监控算法任务的运行状况，并对无法运行的目标监控算法任务进行及时重新分配。其中，重新分配的流程如图4所示，包括：In actual applications, each edge gateway data node can be configured with a monitoring algorithm task list and a camera channel list. Among them, the monitoring algorithm task list contains the monitoring algorithm tasks currently assigned to the edge gateway data node, and the edge gateway data node is responsible for running all monitoring algorithm tasks in its monitoring algorithm task list; the camera channel list contains the camera channels currently configured by the edge gateway data node, and the edge gateway data node is responsible for receiving the monitoring data of all camera channels in the camera channel list. For the edge gateway central node, it is further necessary to dynamically monitor the running status of the monitoring algorithm tasks of the edge gateway data node in real time, and to promptly reallocate the target monitoring algorithm tasks that cannot be run. Among them, the reallocation process is shown in Figure 4, including:
C1:边缘网关中心节点获取各个边缘网关数据节点的监控算法任务列表和摄像头通道列表。C1: The edge gateway central node obtains the monitoring algorithm task list and camera channel list of each edge gateway data node.
C2:边缘网关中心节点各个边缘网关数据节点的监控算法任务列表中选取一个尚未运行的目标监控算法任务，并确定出运行目标监控算法任务所需的至少一个目标摄像头通道。C2: The edge gateway central node selects a target monitoring algorithm task that has not yet been run from the monitoring algorithm task list of each edge gateway data node, and determines at least one target camera channel required to run the target monitoring algorithm task.
C3: 边缘网关中心节点选取出内存能够支持运行目标监控算法任务的目标缘网关数据节点。C3: The edge gateway central node selects the target edge gateway data node whose memory can support running the target monitoring algorithm task.
在一种可行的实现方式中，边缘网关中心节点可以对所有尚未运行的监控算法任务按照内存开销大小进行排序，并对所有缘网关数据节点按照剩余内存大小进行排序。In a feasible implementation, the edge gateway central node can sort all monitoring algorithm tasks that have not yet been run according to the size of memory overhead, and sort all edge gateway data nodes according to the size of remaining memory.
如果目标监控算法任务是内存开销最大的尚未运行的监控算法任，则从剩余内存能够支持运行目标监控算法任务的所有缘网关数据节点中，选取剩余内存最大的一者作为目标缘网关数据节点。If the target monitoring algorithm task is the monitoring algorithm task with the largest memory overhead that has not yet been run, then from all edge gateway data nodes whose remaining memory can support the running of the target monitoring algorithm task, the one with the largest remaining memory is selected as the target edge gateway data node.
如果目标监控算法任务是内存开销最小的尚未运行的监控算法任，则从剩余内存能够支持运行目标监控算法任务的所有缘网关数据节点中，选取剩余内存最小的一者作为目标缘网关数据节点。If the target monitoring algorithm task is the monitoring algorithm task with the smallest memory overhead that has not yet been run, then from all edge gateway data nodes whose remaining memory can support the running of the target monitoring algorithm task, the one with the smallest remaining memory is selected as the target edge gateway data node.
C4: 边缘网关中心节点根据目标缘网关数据节点的编解码路数和摄像头通道列表，判断目标缘网关数据节点的编解码路数是否能够支持至少一个目标摄像头通道。C4: The edge gateway central node determines whether the codec number of the target edge gateway data node can support at least one target camera channel based on the codec number of the target edge gateway data node and the camera channel list.
比如，目标缘网关数据节点的编解码路数支持4个摄像头通道，其当前的摄像头通道列表已配置了摄像头通道1和摄像头通道3，则还能支持配置两个其他摄像头通道。For example, the target edge gateway data node's codec path supports four camera channels, and its current camera channel list has configured camera channel 1 and camera channel 3, then it can also support the configuration of two other camera channels.
假设目标监控算法任务需要的目标摄像头通道包括：摄像头通道1、摄像头通道2、摄像头通道4和摄像头通道5（需要这些摄像头通道的监控数据完成目标监控算法任务），则目标缘网关数据节点需要在其摄像头通道列表中额外配置摄像头通道2、摄像头通道4和摄像头通道5这三个才能支持目标监控算法任务，但其编解码路数只能再配置两个摄像头通道，则表示不支持目标监控算法任务需要的目标摄像头通道。Assuming that the target camera channels required by the target monitoring algorithm task include: camera channel 1, camera channel 2, camera channel 4 and camera channel 5 (the monitoring data of these camera channels are required to complete the target monitoring algorithm task), the target edge gateway data node needs to additionally configure camera channel 2, camera channel 4 and camera channel 5 in its camera channel list to support the target monitoring algorithm task, but its codec route can only be configured with two more camera channels, which means that the target camera channels required by the target monitoring algorithm task are not supported.
C6:若目标缘网关数据节点的编解码路数能够支持至少一个目标摄像头通道，则边缘网关中心节点将至少一个目标摄像头通道配置至边缘网关数据节点的摄像头通道列表中，并将目标监控算法任务分配至目标缘网关数据节点运行。C6: If the encoding and decoding paths of the target edge gateway data node can support at least one target camera channel, the edge gateway central node configures at least one target camera channel to the camera channel list of the edge gateway data node, and assigns the target monitoring algorithm task to the target edge gateway data node for operation.
C7:若目标缘网关数据节点的编解码路数不能够支持至少一个目标摄像头通道，则边缘网关中心节点可以按照步骤C3从所有缘网关数据节点中重新选取出内存能够支持运行目标监控算法任务的另一目标缘网关数据节点，以尝试将目标监控算法任务分配至重新选取出的目标缘网关数据节点。C7: If the encoding and decoding path of the target edge gateway data node cannot support at least one target camera channel, the edge gateway central node can re-select another target edge gateway data node whose memory can support the running of the target monitoring algorithm task from all edge gateway data nodes in accordance with step C3, and try to assign the target monitoring algorithm task to the re-selected target edge gateway data node.
此外，对应于图1所示的方法，本申请的另一个实施例还提供一种业务系统。其中，图5是该业务系统500的结构示意图，包括：所述业务系统包括提供用户访问的边缘网关中心节点510和用于分散存储业务数据的至少两个边缘网关数据节点520。每个边缘网关数据节点520与边缘网关中心节点510连接，以组成星型结构。In addition, corresponding to the method shown in FIG. 1 , another embodiment of the present application further provides a business system. FIG. 5 is a schematic diagram of the structure of the business system 500, including: the business system includes an edge gateway central node 510 that provides user access and at least two edge gateway data nodes 520 for distributing and storing business data. Each edge gateway data node 520 is connected to the edge gateway central node 510 to form a star structure.
所述边缘网关数据节点520对所述业务系统产生的业务数据进行存储，其中，所述边缘网关数据节点配置并运行有至少一个计算任务，且接收到的业务数据包括对应的所述计算任务运行所需的数据；The edge gateway data node 520 stores the business data generated by the business system, wherein the edge gateway data node is configured and runs at least one computing task, and the received business data includes data required for the corresponding computing task to run;
所述边缘网关中心节点510响应于用户访问操作，基于内网穿透服务向用户指定的所述边缘网关数据节点520获取业务数据。The edge gateway central node 510 responds to the user access operation and obtains business data from the edge gateway data node 520 specified by the user based on the intranet penetration service.
所述边缘网关中心节点510对获取得到的业务数据进行屏幕展示。The edge gateway central node 510 displays the acquired business data on the screen.
本实施例的业务系统设置有边缘网关中心节点和至少两个边缘网关数据节点。边缘网关中心节点将业务系统所需运行的计算任务分配至各个边缘网关数据节点，从而以计算任务为粒度将业务数据分散存储至各个边缘网关数据节点。对于集中存储在一个设备上的传统方案，本实施例的业务系统解决了设备数据量达到一定规模所导致的业务数据请求和展示耗时较久的问题，且不依赖云端支持，适合应用于没有云资源条件的场景。此外，边缘网关中心节点可响应于用户访问操作，基于内网穿透服务向用户指定的边缘网关数据节点获取业务数据，并获取得到的业务数据进行屏幕展示，以满足用户信息查询需求。The business system of this embodiment is provided with an edge gateway central node and at least two edge gateway data nodes. The edge gateway central node distributes the computing tasks required to run the business system to each edge gateway data node, so that the business data is dispersedly stored in each edge gateway data node with computing tasks as the granularity. Compared with the traditional solution of centralized storage on one device, the business system of this embodiment solves the problem of long business data request and display time caused by the amount of device data reaching a certain scale, and does not rely on cloud support, and is suitable for application in scenarios without cloud resource conditions. In addition, the edge gateway central node can respond to user access operations, obtain business data from the edge gateway data node specified by the user based on the intranet penetration service, and display the obtained business data on the screen to meet the user's information query needs.
可选地，所述边缘网关数据节点对本地存储的业务数据进行统计，并将统计结果同步至所述边缘网关中心节点；所述边缘网关中心节点基于接收到的所述边缘网关数据节点的统计结果，生成对应的前端数据报表；所述边缘网关中心节点响应于用户访问操作，对用户指定的所述边缘网关数据节点的前端数据报表进行屏幕展示。Optionally, the edge gateway data node performs statistics on locally stored business data and synchronizes the statistical results to the edge gateway central node; the edge gateway central node generates corresponding front-end data reports based on the statistical results received from the edge gateway data node; the edge gateway central node responds to user access operations and displays the front-end data reports of the edge gateway data nodes specified by the user on the screen.
可选地，所述边缘网关数据节点对本地存储的业务数据进行分析，确定出关键业务数据；所述边缘网关数据节点将本地的关键业务数据同步至所述边缘网关中心节点；所述边缘网关中心节点响应于用户访问操作，对用户指定的所述边缘网关数据节点的关键业务数据进行屏幕展示。Optionally, the edge gateway data node analyzes the locally stored business data to determine the key business data; the edge gateway data node synchronizes the local key business data to the edge gateway central node; the edge gateway central node responds to the user access operation and displays the key business data of the edge gateway data node specified by the user on the screen.
可选地，所述边缘网关数据节点设置有MySQL数据库，并将地的关键业务数据存储至所述MySQL数据库；所述边缘网关数据节点将所述关键业务数据同步至所述边缘网关中心节点，包括：所述边缘网关中心节点基于Canal服务，模拟 MySQL的交互协议，向所述边缘网关数据节点发送dump请求；接收到所述dump请求的所述边缘网关数据节点基于MySQL的交互协议，向所述边缘网关中心节点发送携带本地的关键业务数据的binary log文件。Optionally, the edge gateway data node is provided with a MySQL database, and the local key business data is stored in the MySQL database; the edge gateway data node synchronizes the key business data to the edge gateway central node, including: the edge gateway central node simulates the MySQL interaction protocol based on the Canal service, and sends a dump request to the edge gateway data node; the edge gateway data node that receives the dump request sends a binary log file carrying local key business data to the edge gateway central node based on the MySQL interaction protocol.
可选地，所述边缘网关数据节点在本地的所述MySQL数据库产生增量数据后，向所述边缘网关中心节点发送更新通知；所述dump请求是所述边缘网关中心节点响应于所述更新通知而发送的。Optionally, after the edge gateway data node generates incremental data in the local MySQL database, the edge gateway central node sends an update notification to the edge gateway central node; the dump request is sent by the edge gateway central node in response to the update notification.
可选地，所述边缘网关中心节点针对每个所述边缘网关数据节点设置有专属的数据库，以用于存储对应的关键业务数据。Optionally, the edge gateway central node is provided with an exclusive database for each edge gateway data node to store corresponding key business data.
可选地，所述边缘网关中心节点对获取得到的业务数据进行屏幕展示，包括：所述边缘网关中心节基于Vue服务构建用户界面，并基于ECharts服务将获取到的业务数据以图表库形式呈现于所述用户界面。Optionally, the edge gateway central node displays the acquired business data on the screen, including: the edge gateway central node builds a user interface based on the Vue service, and presents the acquired business data in the form of a chart library on the user interface based on the ECharts service.
可选地，所述业务数据包括监控数据；所述边缘网关中心节点还用于：获取各个所述边缘网关数据节点的监控算法任务列表和摄像头通道列表；从各个所述边缘网关数据节点的监控算法任务列表中选取一个尚未运行的目标监控算法任务，并确定出运行所述目标监控算法任务所需的至少一个目标摄像头通道；选取出内存能够支持运行所述目标监控算法任务的目标缘网关数据节点，并根据所述目标缘网关数据节点的编解码路数和摄像头通道列表，判断所述目标缘网关数据节点的编解码路数是否能够支持所述至少一个目标摄像头通道；若所述目标缘网关数据节点的编解码路数能够支持所述至少一个目标摄像头通道，则将至少一个目标摄像头通道配置至所述边缘网关数据节点的摄像头通道列表中，并将所述目标监控算法任务分配至所述目标缘网关数据节点运行；若所述目标缘网关数据节点的编解码路数不能够支持所述至少一个目标摄像头通道，则所从所有所述缘网关数据节点中重新选取出内存能够支持运行所述目标监控算法任务的另一目标缘网关数据节点，以尝试将所述目标监控算法任务分配至重新选取出的目标缘网关数据节点。Optionally, the business data includes monitoring data; the edge gateway central node is also used to: obtain the monitoring algorithm task list and camera channel list of each of the edge gateway data nodes; select a target monitoring algorithm task that has not yet been run from the monitoring algorithm task list of each of the edge gateway data nodes, and determine at least one target camera channel required to run the target monitoring algorithm task; select a target edge gateway data node whose memory can support the running of the target monitoring algorithm task, and judge whether the codec path of the target edge gateway data node can support the at least one target camera channel based on the codec path and camera channel list of the target edge gateway data node. target camera channel; if the encoding and decoding path of the target edge gateway data node can support at least one target camera channel, then configure at least one target camera channel to the camera channel list of the edge gateway data node, and assign the target monitoring algorithm task to the target edge gateway data node for operation; if the encoding and decoding path of the target edge gateway data node cannot support at least one target camera channel, then reselect another target edge gateway data node whose memory can support the operation of the target monitoring algorithm task from all the edge gateway data nodes, and try to assign the target monitoring algorithm task to the reselected target edge gateway data node.
需要说明的是，本实施例的业务系统可以作为图1所示方法的执行主体，因此能够实现图1所示方法中的步骤以及功能。It should be noted that the business system of this embodiment can serve as the execution subject of the method shown in FIG. 1 , and thus can implement the steps and functions in the method shown in FIG. 1 .
图6是本申请的一个实施例提供的电子设备的结构示意图。请参考图6，在硬件层面，该电子设备包括处理器，可选地还包括内部总线、网络接口、存储器。其中，存储器可能包含内存，例如高速随机存取存储器(Random-Access Memory，RAM)，也可能还包括非易失性存储器（non-volatile memory），例如至少1个磁盘存储器等。当然，该电子设备还可能包括其他业务所需要的硬件。FIG6 is a schematic diagram of the structure of an electronic device provided by an embodiment of the present application. Please refer to FIG6. At the hardware level, the electronic device includes a processor, and optionally also includes an internal bus, a network interface, and a memory. Among them, the memory may include a memory, such as a high-speed random access memory (RAM), and may also include a non-volatile memory (non-volatile memory), such as at least one disk storage, etc. Of course, the electronic device may also include hardware required for other services.
处理器、网络接口和存储器可以通过内部总线相互连接，该内部总线可以是ISA(Industry Standard Architecture，工业标准体系结构）总线、PCI(PeripheralComponent Interconnect，外设部件互连标准)总线或EISA(Extended Industry StandardArchitecture，扩展工业标准结构）总线等。所述总线可以分为地址总线、数据总线、控制总线等。为便于表示，图6中仅用一个双向箭头表示，但并不表示仅有一根总线或一种类型的总线。The processor, the network interface and the memory may be interconnected via an internal bus, which may be an ISA (Industry Standard Architecture) bus, a PCI (Peripheral Component Interconnect) bus or an EISA (Extended Industry Standard Architecture) bus, etc. The bus may be divided into an address bus, a data bus, a control bus, etc. For ease of representation, FIG6 only uses one bidirectional arrow, but does not mean that there is only one bus or one type of bus.
存储器，用于存放程序。具体地，程序可以包括程序代码，所述程序代码包括计算机操作指令。存储器可以包括内存和非易失性存储器，并向处理器提供指令和数据。The memory is used to store the program. Specifically, the program may include a program code, and the program code includes a computer operation instruction. The memory may include a memory and a non-volatile memory, and provides instructions and data to the processor.
其中，处理器从非易失性存储器中读取对应的计算机程序到内存中然后运行，在逻辑层面上形成上述业务系统。处理器，执行存储器所存放的程序，并具体用于执行以下操作：The processor reads the corresponding computer program from the non-volatile memory into the memory and then runs it, forming the above business system at the logical level. The processor executes the program stored in the memory and is specifically used to perform the following operations:
通过边缘网关数据节点对所述业务系统产生的业务数据进行存储。The business data generated by the business system is stored through the edge gateway data node.
通过边缘网关中心节点响应于用户访问操作，以基于内网穿透服务向用户指定的所述边缘网关数据节点获取业务数据。The edge gateway central node responds to the user access operation to obtain business data from the edge gateway data node specified by the user based on the intranet penetration service.
通过边缘网关中心节点对获取得到的业务数据进行屏幕展示。The acquired business data is displayed on the screen through the edge gateway central node.
基于本实施例的电子设备可知，业务系统设置有提供用户访问的边缘网关中心节点和至少两个边缘网关数据节点。边缘网关中心节点将业务系统所需运行的计算任务分配至各个边缘网关数据节点，从而以计算任务为粒度将业务数据分散存储至各个边缘网关数据节点。相对于集中存储在一个设备上的传统方案，本实施例的方案解决了设备数据量达到一定规模所导致的业务数据请求和展示耗时较久的问题，且业务系统的运行并不依赖云端支持，方案适合应用于没有云资源条件的场景。此外，边缘网关中心节点可响应于用户访问操作，基于内网穿透服务向用户指定的边缘网关数据节点获取业务数据，并获取得到的业务数据进行屏幕展示，以满足用户信息查询需求。Based on the electronic device of this embodiment, it can be known that the business system is provided with an edge gateway central node and at least two edge gateway data nodes that provide user access. The edge gateway central node distributes the computing tasks required to run the business system to each edge gateway data node, so that the business data is dispersedly stored in each edge gateway data node with computing tasks as the granularity. Compared with the traditional solution of centralized storage on one device, the solution of this embodiment solves the problem of long business data request and display time caused by the amount of device data reaching a certain scale, and the operation of the business system does not rely on cloud support. The solution is suitable for scenarios without cloud resource conditions. In addition, the edge gateway central node can respond to user access operations, obtain business data from the edge gateway data node specified by the user based on the intranet penetration service, and display the obtained business data on the screen to meet the user's information query needs.
上述如本申请图1所示实施例揭示的方法可以应用于处理器中，或者由处理器实现。处理器可能是一种集成电路芯片，具有信号的处理能力。在实现过程中，上述方法的各步骤可以通过处理器中的硬件的集成逻辑电路或者软件形式的指令完成。上述的处理器可以是通用处理器，包括中央处理器（Central Processing Unit，CPU）、网络处理器（NetworkProcessor，NP）等；还可以是数字信号处理器（Digital Signal Processor，DSP）、专用集成电路（Application Specific Integrated Circuit，ASIC）、现场可编程门阵列（Field－Programmable Gate Array，FPGA）或者其他可编程逻辑器件、分立门或者晶体管逻辑器件、分立硬件组件。可以实现或者执行本申请一个或多个实施例中的公开的各方法、步骤及逻辑框图。通用处理器可以是微处理器或者该处理器也可以是任何常规的处理器等。结合本申请一个或多个实施例所公开的方法的步骤可以直接体现为硬件译码处理器执行完成，或者用译码处理器中的硬件及软件模块组合执行完成。软件模块可以位于随机存储器，闪存、只读存储器，可编程只读存储器或者电可擦写可编程存储器、寄存器等本领域成熟的存储介质中。该存储介质位于存储器，处理器读取存储器中的信息，结合其硬件完成上述方法的步骤。The method disclosed in the embodiment shown in FIG. 1 of the present application can be applied to a processor or implemented by a processor. The processor may be an integrated circuit chip with signal processing capabilities. In the implementation process, each step of the above method can be completed by an integrated logic circuit of hardware in the processor or an instruction in software form. The above processor can be a general-purpose processor, including a central processing unit (CPU), a network processor (NP), etc.; it can also be a digital signal processor (DSP), an application-specific integrated circuit (ASIC), a field-programmable gate array (FPGA) or other programmable logic devices, discrete gates or transistor logic devices, discrete hardware components. The methods, steps and logic block diagrams disclosed in one or more embodiments of the present application can be implemented or executed. The general-purpose processor can be a microprocessor or the processor can also be any conventional processor, etc. The steps of the method disclosed in one or more embodiments of the present application can be directly embodied as a hardware decoding processor for execution, or a combination of hardware and software modules in the decoding processor for execution. The software module can be located in a mature storage medium in the field such as random access memory, flash memory, read-only memory, programmable read-only memory or electrically erasable programmable memory, register, etc. The storage medium is located in the memory, and the processor reads the information in the memory and completes the steps of the above method in combination with its hardware.
当然，除了软件实现方式之外，本申请的电子设备并不排除其他实现方式，比如逻辑器件抑或软硬件结合的方式等等，也就是说以下处理流程的执行主体并不限定于各个逻辑单元，也可以是硬件或逻辑器件。Of course, in addition to software implementation methods, the electronic device of the present application does not exclude other implementation methods, such as logic devices or a combination of software and hardware, etc. That is to say, the execution subject of the following processing flow is not limited to each logic unit, but can also be hardware or logic devices.
本申请实施例还提出了一种计算机程序产品，所述计算机程序产品包括存储了计算机程序的计算机可读存储介质，所述计算机程序可操作来使计算机执行如下操作：The present application also provides a computer program product, which includes a computer-readable storage medium storing a computer program, and the computer program is operable to cause a computer to perform the following operations:
通过边缘网关数据节点对所述业务系统产生的业务数据进行存储。The business data generated by the business system is stored through the edge gateway data node.
通过边缘网关中心节点响应于用户访问操作，以基于内网穿透服务向用户指定的所述边缘网关数据节点获取业务数据。The edge gateway central node responds to the user access operation to obtain business data from the edge gateway data node specified by the user based on the intranet penetration service.
通过边缘网关中心节点对获取得到的业务数据进行屏幕展示。The acquired business data is displayed on the screen through the edge gateway central node.
总之，以上所述仅为本申请的较佳实施例而已，并非用于限定本申请的保护范围。凡在本申请一个或多个实施例的精神和原则之内，所作的任何修改、等同替换、改进等，均应包含在本申请一个或多个实施例的保护范围之内。In short, the above description is only a preferred embodiment of the present application and is not intended to limit the protection scope of the present application. Any modification, equivalent replacement, improvement, etc. made within the spirit and principle of one or more embodiments of the present application shall be included in the protection scope of one or more embodiments of the present application.
上述实施例阐明的系统、装置、模块或单元，具体可以由计算机芯片或实体实现，或者由具有某种功能的产品来实现。一种典型的实现设备为计算机。具体的，计算机例如可以为个人计算机、膝上型计算机、蜂窝电话、相机电话、智能电话、个人数字助理、媒体播放器、导航设备、电子邮件设备、游戏控制台、平板计算机、可穿戴设备或者这些设备中的任何设备的组合。The systems, devices, modules or units described in the above embodiments may be implemented by computer chips or entities, or by products with certain functions. A typical implementation device is a computer. Specifically, the computer may be, for example, a personal computer, a laptop computer, a cellular phone, a camera phone, a smart phone, a personal digital assistant, a media player, a navigation device, an email device, a game console, a tablet computer, a wearable device, or a combination of any of these devices.
计算机可读介质包括永久性和非永久性、可移动和非可移动媒体可以由任何方法或技术来实现信息存储。信息可以是计算机可读指令、数据结构、程序的模块或其他数据。计算机的存储介质的例子包括，但不限于相变内存(PRAM)、静态随机存取存储器(SRAM)、动态随机存取存储器(DRAM)、其他类型的随机存取存储器(RAM)、只读存储器(ROM)、电可擦除可编程只读存储器(EEPROM)、快闪记忆体或其他内存技术、只读光盘只读存储器(CD-ROM)、数字多功能光盘(DVD)或其他光学存储、磁盒式磁带，磁带磁盘存储或其他磁性存储设备或任何其他非传输介质，可用于存储可以被计算设备访问的信息。按照本文中的界定，计算机可读介质不包括暂存电脑可读媒体(transitory media)，如调制的数据信号和载波。Computer readable media include permanent and non-permanent, removable and non-removable media that can be implemented by any method or technology to store information. Information can be computer readable instructions, data structures, program modules or other data. Examples of computer storage media include, but are not limited to, phase change memory (PRAM), static random access memory (SRAM), dynamic random access memory (DRAM), other types of random access memory (RAM), read-only memory (ROM), electrically erasable programmable read-only memory (EEPROM), flash memory or other memory technology, compact disk read-only memory (CD-ROM), digital versatile disk (DVD) or other optical storage, magnetic cassettes, magnetic tape disk storage or other magnetic storage devices or any other non-transmission media that can be used to store information that can be accessed by a computing device. As defined herein, computer readable media does not include temporary computer readable media (transitory media), such as modulated data signals and carrier waves.
还需要说明的是，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、商品或者设备不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、商品或者设备所固有的要素。在没有更多限制的情况下，由语句“包括一个……”限定的要素，并不排除在包括所述要素的过程、方法、商品或者设备中还存在另外的相同要素。It should also be noted that the terms "include", "comprises" or any other variations thereof are intended to cover non-exclusive inclusion, so that a process, method, commodity or device including a series of elements includes not only those elements, but also other elements not explicitly listed, or also includes elements inherent to such process, method, commodity or device. In the absence of more restrictions, the elements defined by the sentence "comprises a ..." do not exclude the existence of other identical elements in the process, method, commodity or device including the elements.
本申请中的各个实施例均采用递进的方式描述，各个实施例之间相同相似的部分互相参见即可，每个实施例重点说明的都是与其他实施例的不同之处。尤其，对于系统实施例而言，由于其基本相似于方法实施例，所以描述的比较简单，相关之处参见方法实施例的部分说明即可。Each embodiment in this application is described in a progressive manner, and the same or similar parts between the embodiments can be referred to each other, and each embodiment focuses on the differences from other embodiments. In particular, for the system embodiment, since it is basically similar to the method embodiment, the description is relatively simple, and the relevant parts can be referred to the partial description of the method embodiment.
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202411046018.5ACN118590537B (en) | 2024-07-31 | 2024-07-31 | Data processing method, business system and electronic equipment |
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202411046018.5ACN118590537B (en) | 2024-07-31 | 2024-07-31 | Data processing method, business system and electronic equipment |
| Publication Number | Publication Date |
|---|---|
| CN118590537A CN118590537A (en) | 2024-09-03 |
| CN118590537Btrue CN118590537B (en) | 2024-10-11 |
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202411046018.5AActiveCN118590537B (en) | 2024-07-31 | 2024-07-31 | Data processing method, business system and electronic equipment |
| Country | Link |
|---|---|
| CN (1) | CN118590537B (en) |
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112532674A (en)* | 2019-09-19 | 2021-03-19 | 贵州白山云科技股份有限公司 | Method, device and medium for establishing network edge computing system |
| CN115113911A (en)* | 2022-07-21 | 2022-09-27 | 北京百度网讯科技有限公司 | Software management system and method |
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112532758B (en)* | 2019-09-19 | 2023-04-18 | 贵州白山云科技股份有限公司 | Method, device and medium for establishing network edge computing system |
| CN115297098B (en)* | 2022-08-04 | 2024-08-16 | 北京沃东天骏信息技术有限公司 | Edge service acquisition method and device, edge computing system, medium and equipment |
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112532674A (en)* | 2019-09-19 | 2021-03-19 | 贵州白山云科技股份有限公司 | Method, device and medium for establishing network edge computing system |
| CN115113911A (en)* | 2022-07-21 | 2022-09-27 | 北京百度网讯科技有限公司 | Software management system and method |
| Publication number | Publication date |
|---|---|
| CN118590537A (en) | 2024-09-03 |
| Publication | Publication Date | Title |
|---|---|---|
| Wang et al. | Adaptive and fault-tolerant data processing in healthcare IoT based on fog computing | |
| Tse et al. | Global zoom/pan estimation and compensation for video compression | |
| CN113010818A (en) | Access current limiting method and device, electronic equipment and storage medium | |
| CN111352800A (en) | Big data cluster monitoring method and related equipment | |
| CN109684052B (en) | Transaction analysis method, apparatus, device and storage medium | |
| US20190238424A1 (en) | Policy enforcement as a service for third party platforms with asynchronous user tracking mechanisms | |
| US20220366066A1 (en) | Display method, display device, and electronic device | |
| US20190238428A1 (en) | OPAQUE INTERFACE FOR ENCLOSED/WRAPPED ASYNCHRONOUS PUSHING AND/OR PULLING DATA BETWEEN POLICY ENFORCEMENT AS A SERVICE (PEaaS) COMPONENTS | |
| US10554701B1 (en) | Real-time call tracing in a service-oriented system | |
| WO2021244473A1 (en) | Frequency control method and apparatus | |
| CN113190625A (en) | Request processing method, device, electronic equipment, medium and program product | |
| US20160269428A1 (en) | Data processing | |
| TW202027003A (en) | Method and system for accepting blockchain evidence storage transaction | |
| US20240427899A1 (en) | Operational characteristic-based container management | |
| CN117892348A (en) | Application program interface asset management method, device and electronic device | |
| WO2024119792A1 (en) | Video data storage method and apparatus, video data analysis method, apparatus and system, and communication device and storage medium | |
| CN110933152B (en) | Preheating method, device and system and electronic equipment | |
| CN113794719B (en) | Network abnormal traffic analysis method and device based on elastic search technology and electronic equipment | |
| CN118590537B (en) | Data processing method, business system and electronic equipment | |
| CN110956349A (en) | Service quality analysis method, system, device, server and electronic equipment | |
| WO2022063125A1 (en) | Secondary content delivery network (cdn), data providing method and storage medium | |
| WO2022057727A1 (en) | Network quality determination method and apparatus, electronic device and readable storage medium | |
| CN112286930A (en) | Method, device, storage medium and electronic equipment for resource sharing of redis business side | |
| CN114448976B (en) | Method, device, equipment, medium and program product for assembling network message | |
| US20230063599A1 (en) | Edge computing network, data transmission method and apparatus, device and storage medium |
| 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 | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant | ||
| TR01 | Transfer of patent right | Effective date of registration:20250319 Address after:101, Floors 1-3, Building 14, North Campus, No. 9 Dongran North Street, Haidian District, Beijing 100089 Patentee after:CHINA TOWER Co.,Ltd. Country or region after:China Patentee after:Tower Zhilian Technology Co.,Ltd. Address before:100195 101, floors 1 to 3, building 14, North District, yard 9, dongran North Street, Haidian District, Beijing Patentee before:CHINA TOWER Co.,Ltd. Country or region before:China | |
| TR01 | Transfer of patent right |