CN112769897B - Synchronization method and device of edge calculation message, electronic equipment and storage medium - Google Patents
Synchronization method and device of edge calculation message, electronic equipment and storage mediumDownload PDFInfo
- Publication number
- CN112769897B CN112769897BCN202011520048.7ACN202011520048ACN112769897BCN 112769897 BCN112769897 BCN 112769897BCN 202011520048 ACN202011520048 ACN 202011520048ACN 112769897 BCN112769897 BCN 112769897B
- Authority
- CN
- China
- Prior art keywords
- message
- edge computing
- target address
- target
- consumption value
- 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.)
- Active
Links
Images
Classifications
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/10—Protocols in which an application is distributed across nodes in the network
- H04L67/1095—Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/27—Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
Landscapes
- Engineering & Computer Science (AREA)
- Databases & Information Systems (AREA)
- Theoretical Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Computing Systems (AREA)
- Data Mining & Analysis (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Information Transfer Between Computers (AREA)
- Computer And Data Communications (AREA)
Abstract
Description
Translated fromChinese技术领域technical field
本申请涉及计算机技术领域，具体涉及云计算、云存储、大数据处理等人工智能技术领域，尤其涉及边缘计算消息的同步方法、装置、电子设备及存储介质。This application relates to the field of computer technology, specifically to the field of artificial intelligence technology such as cloud computing, cloud storage, and big data processing, and in particular to a synchronization method, device, electronic equipment, and storage medium for edge computing messages.
背景技术Background technique
人工智能是研究使计算机来模拟人的某些思维过程和智能行为(如学习、推理、思考、规划等)的学科，既有硬件层面的技术也有软件层面的技术。人工智能硬件技术一般包括如传感器、专用人工智能芯片、云计算、分布式存储、大数据处理等技术；人工智能软件技术主要包括计算机视觉技术、语音识别技术、自然语言处理技术以及机器学习/深度学习、大数据处理技术、知识图谱技术等几大方向。Artificial intelligence is a discipline that studies the use of computers to simulate certain human thinking processes and intelligent behaviors (such as learning, reasoning, thinking, planning, etc.), both at the hardware level and at the software level. Artificial intelligence hardware technologies generally include technologies such as sensors, dedicated artificial intelligence chips, cloud computing, distributed storage, and big data processing; artificial intelligence software technologies mainly include computer vision technology, speech recognition technology, natural language processing technology, and machine learning/depth Learning, big data processing technology, knowledge map technology and other major directions.
在物联网、边缘计算场景下，具有边缘计算功能的设备通常会采集到大量的设备参数以及自身的运行状态信息，这些消息可以被称为边缘计算消息，通常是将边缘计算消息通过消息队列遥测传输(Message Queuing Telemetry Transport，MQTT)同步到云服务器。In the Internet of Things and edge computing scenarios, devices with edge computing functions usually collect a large number of device parameters and their own operating status information. These messages can be called edge computing messages, which are usually sent through message queue telemetry The transmission (Message Queuing Telemetry Transport, MQTT) is synchronized to the cloud server.
发明内容Contents of the invention
提供了一种边缘计算消息的同步方法、装置、电子设备、存储介质及计算机程序产品。Provided are an edge computing message synchronization method, device, electronic equipment, storage medium and computer program product.
根据第一方面，提供了一种边缘计算消息的同步方法，包括：获取目标终端设备所采集的边缘计算消息；确定与所述边缘计算消息对应的目标地址，所述目标地址与流处理平台中的服务器相对应；根据所述流处理平台的数据传输协议，对所述边缘计算消息进行协议转换；以及采用所述数据传输协议，将协议转换后的边缘计算消息同步至与所述目标地址对应的服务器。According to the first aspect, a method for synchronizing edge computing messages is provided, including: acquiring edge computing messages collected by target terminal devices; determining a target address corresponding to the edge computing message, the target address being the same as the corresponding to the server; according to the data transmission protocol of the stream processing platform, perform protocol conversion on the edge computing message; and use the data transmission protocol to synchronize the edge computing message after the protocol conversion to the target address server.
根据第二方面，提供了一种边缘计算消息的同步装置，包括：第一获取模块，用于获取目标终端设备所采集的边缘计算消息；确定模块，用于确定与所述边缘计算消息对应的目标地址，所述目标地址与流处理平台中的服务器相对应；处理模块，用于根据所述流处理平台的数据传输协议，对所述边缘计算消息进行协议转换；以及传输模块，用于采用所述数据传输协议，将协议转换后的边缘计算消息同步至与所述目标地址对应的服务器。According to the second aspect, an apparatus for synchronizing edge computing messages is provided, including: a first acquiring module, configured to acquire edge computing messages collected by a target terminal device; a determining module, configured to determine an edge computing message corresponding to the edge computing message The target address, the target address corresponds to the server in the stream processing platform; the processing module is used to perform protocol conversion on the edge computing message according to the data transmission protocol of the stream processing platform; and the transmission module is used to adopt The data transmission protocol synchronizes the edge computing message after protocol conversion to the server corresponding to the target address.
根据第三方面，提供了一种电子设备，包括：至少一个处理器；以及与所述至少一个处理器通信连接的存储器；其中，所述存储器存储有可被所述至少一个处理器执行的指令，所述指令被所述至少一个处理器执行，以使所述至少一个处理器能够执行本申请实施例的边缘计算消息的同步方法。According to a third aspect, there is provided an electronic device, comprising: at least one processor; and a memory communicatively connected to the at least one processor; wherein, the memory stores instructions executable by the at least one processor , the instructions are executed by the at least one processor, so that the at least one processor can execute the edge computing message synchronization method of the embodiment of the present application.
根据第四方面，提出了一种存储有计算机指令的非瞬时计算机可读存储介质，所述计算机指令用于使所述计算机执行本申请实施例公开的边缘计算消息的同步方法。According to a fourth aspect, a non-transitory computer-readable storage medium storing computer instructions is proposed, and the computer instructions are used to make the computer execute the method for synchronizing edge computing messages disclosed in the embodiments of the present application.
根据第五方面，提出了一种计算机程序产品，包括计算机程序，当所述计算机程序由处理器执行时实现本申请实施例公开的边缘计算消息的同步方法。According to a fifth aspect, a computer program product is provided, including a computer program, and when the computer program is executed by a processor, the method for synchronizing edge computing messages disclosed in the embodiments of the present application is implemented.
应当理解，本部分所描述的内容并非旨在标识本申请的实施例的关键或重要特征，也不用于限制本申请的范围。本申请的其它特征将通过以下的说明书而变得容易理解。It should be understood that what is described in this section is not intended to identify key or important features of the embodiments of the application, nor is it intended to limit the scope of the application. Other features of the present application will be easily understood from the following description.
附图说明Description of drawings
附图用于更好地理解本方案，不构成对本申请的限定。其中：The accompanying drawings are used to better understand the solution, and do not constitute a limitation to the application. in:
图1是根据本申请第一实施例的示意图；Fig. 1 is a schematic diagram according to the first embodiment of the present application;
图2是根据本申请第二实施例的示意图；Fig. 2 is a schematic diagram according to the second embodiment of the present application;
图3是本申请实施例中边缘计算消息的同步装置的架构示意图；FIG. 3 is a schematic diagram of an architecture of a device for synchronizing edge computing messages in an embodiment of the present application;
图4是根据本申请第三实施例的示意图；Fig. 4 is a schematic diagram according to a third embodiment of the present application;
图5是根据本申请第四实施例的示意图；Fig. 5 is a schematic diagram according to a fourth embodiment of the present application;
图6是用来实现本申请实施例的边缘计算消息的同步方法的电子设备的框图。Fig. 6 is a block diagram of an electronic device used to implement the method for synchronizing edge computing messages according to the embodiment of the present application.
具体实施方式Detailed ways
以下结合附图对本申请的示范性实施例做出说明，其中包括本申请实施例的各种细节以助于理解，应当将它们认为仅仅是示范性的。因此，本领域普通技术人员应当认识到，可以对这里描述的实施例做出各种改变和修改，而不会背离本申请的范围和精神。同样，为了清楚和简明，以下的描述中省略了对公知功能和结构的描述。Exemplary embodiments of the present application are described below in conjunction with the accompanying drawings, which include various details of the embodiments of the present application to facilitate understanding, and they should be regarded as exemplary only. Accordingly, those of ordinary skill in the art will recognize that various changes and modifications of the embodiments described herein can be made without departing from the scope and spirit of the application. Also, descriptions of well-known functions and constructions are omitted in the following description for clarity and conciseness.
图1是根据本申请第一实施例的示意图。Fig. 1 is a schematic diagram according to the first embodiment of the present application.
其中，需要说明的是，本实施例的边缘计算消息的同步方法的执行主体为边缘计算消息的同步装置，该装置可以由软件和/或硬件的方式实现，该装置可以配置在电子设备中，电子设备可以包括但不限于终端、服务器端等。Wherein, it should be noted that the execution subject of the edge computing message synchronization method in this embodiment is an edge computing message synchronization device, which can be implemented by software and/or hardware, and which can be configured in an electronic device. Electronic devices may include, but are not limited to, terminals, servers, and the like.
本申请实施例涉及云计算、云存储、大数据处理等人工智能技术领域。The embodiments of the present application relate to the technical fields of artificial intelligence such as cloud computing, cloud storage, and big data processing.
其中，人工智能(Artificial Intelligence)，英文缩写为AI。它是研究、开发用于模拟、延伸和扩展人的智能的理论、方法、技术及应用系统的一门新的技术科学。Among them, artificial intelligence (Artificial Intelligence), the English abbreviation is AI. It is a new technical science that studies and develops theories, methods, technologies and application systems for simulating, extending and expanding human intelligence.
云计算(cloudcomputing)，指的是通过网络接入弹性可扩展的共享物理或虚拟资源池，资源可以包括服务器、操作系统、网络、软件、应用和存储设备等，并可以以按需、自服务的方式对资源进行部署和管理的技术体系。通过云计算技术，可以为人工智能、区块链等技术应用、模型训练提供高效强大的数据处理能力。Cloud computing refers to accessing elastic and scalable shared physical or virtual resource pools through the network. Resources can include servers, operating systems, networks, software, applications, and storage devices, etc., and can be used on-demand and self-service A technical system that deploys and manages resources in a unique way. Through cloud computing technology, it can provide efficient and powerful data processing capabilities for artificial intelligence, blockchain and other technical applications and model training.
云存储，是一种网上在线存储的模式，即把数据存放在通常由第三方托管的多台虚拟服务器，而非专属的服务器上。Cloud storage is a mode of online online storage, that is, data is stored on multiple virtual servers usually hosted by a third party, rather than on a dedicated server.
而大数据处理，是指采用人工智能的方式对规模巨大的数据进行分析以及处理的过程，而大数据可以概括为5个V，数据量大(Volume)、速度快(Velocity)、类型多(Variety)、价值(Value)、真实性(Veracity)。And big data processing refers to the process of using artificial intelligence to analyze and process huge-scale data, and big data can be summarized as 5 Vs, large data volume (Volume), fast speed (Velocity), and many types ( Variety), Value, and Veracity.
如图1所示，该边缘计算消息的同步方法包括：As shown in Figure 1, the synchronization method of the edge computing message includes:
S101：获取目标终端设备所采集的边缘计算消息。S101: Acquire edge computing messages collected by a target terminal device.
其中，当前需要对其所采集的边缘计算消息进行同步处理的终端设备，可以被称为目标终端设备，目标终端设备可以是物联网、边缘计算场景下，具有边缘计算功能的设备，比如具有边缘计算功能的计算机设备等。Among them, the terminal device that currently needs to synchronize the collected edge computing messages can be called the target terminal device, and the target terminal device can be a device with edge computing function in the Internet of Things and edge computing scenarios, such as a device with edge computing equipment, etc.
其中的边缘计算消息，例如具有边缘计算功能的设备所采集的设备参数以及自身的运行状态信息等，对此不做限制。The edge computing messages, such as device parameters collected by devices with edge computing functions and their own operating status information, are not limited.
本申请实施例中的流处理平台可以例如开源流处理平台Kafka，或者也可以为其他具有流数据处理功能的大数据计算、存储平台，对此不做限制。The stream processing platform in the embodiment of the present application may be, for example, the open source stream processing platform Kafka, or other big data computing and storage platforms capable of processing stream data, without limitation.
本申请实施例中以流处理平台是开源流处理平台Kafka进行示例。In the embodiment of this application, the stream processing platform is an open source stream processing platform Kafka as an example.
一些实施例中，在获取目标终端设备所采集的边缘计算消息之后，还可以根据加密证书，对协议转换后的边缘计算消息进行加密处理，则将协议转换后的边缘计算消息同步至与目标地址对应的服务器，包括：将加密处理后的边缘计算消息同步至与目标地址对应的服务器。In some embodiments, after obtaining the edge computing message collected by the target terminal device, the edge computing message after the protocol conversion can also be encrypted according to the encryption certificate, and then the edge computing message after the protocol conversion is synchronized to the target address The corresponding server includes: synchronizing the encrypted edge computing message to the server corresponding to the target address.
上述的加密证书，是连接流处理平台所需的加密证书，加密证书之中可以包含一些加密算法，从而在根据加密证书，对协议转换后的边缘计算消息进行加密处时，可以是采用该加密算法对协议转换后的边缘计算消息进行加密，在后续对边缘计算消息进行同步时，具体可以是同步加密处理，且协议转换后的边缘计算消息。The encryption certificate mentioned above is the encryption certificate required to connect to the stream processing platform. The encryption certificate can contain some encryption algorithms, so that when encrypting the edge computing message after the protocol conversion according to the encryption certificate, the encryption can be used. The algorithm encrypts the edge computing messages after the protocol conversion, and when the edge computing messages are subsequently synchronized, specifically, the edge computing messages after the protocol conversion can be synchronously encrypted.
由于预先根据加密证书，对协议转换后的边缘计算消息进行加密处理，从而能够有效保证边缘计算消息传输的安全性，避免消息内容泄漏，提升边缘计算消息同步的安全性能。Because the edge computing message after protocol conversion is encrypted in advance according to the encryption certificate, it can effectively ensure the security of edge computing message transmission, avoid message content leakage, and improve the security performance of edge computing message synchronization.
S102：确定与边缘计算消息对应的目标地址，目标地址与流处理平台中的服务器相对应。S102: Determine a target address corresponding to the edge computing message, where the target address corresponds to a server in the stream processing platform.
上述的开源流处理平台Kafka可以是集群服务器架构，则集群服务器中不同的服务器节点对应了一个地址，其中，预先订阅的用于处理目标终端设备的边缘计算消息的服务器节点对应的地址，可以被称为目标地址。The above-mentioned open source stream processing platform Kafka can be a cluster server architecture, and different server nodes in the cluster server correspond to an address, wherein, the address corresponding to the server node subscribed in advance to process the edge computing message of the target terminal device can be called the target address.
该预先订阅的用于处理目标终端设备的边缘计算消息的服务器节点，可以理解为其内部的数据存储结构，与该目标终端设备的边缘计算消息的数据存储结构是一致的，则预先可以是基于需求的数据存储结构来预先订阅服务器节点，从而在获取目标终端设备所采集的边缘计算消息之后，直接根据预先订阅的关系来确定与边缘计算消息对应的目标地址，目标地址与流处理平台中的服务器相对应，对此不做限制。The pre-subscribed server node for processing the edge computing message of the target terminal device can be understood as its internal data storage structure, which is consistent with the data storage structure of the edge computing message of the target terminal device, so it can be pre-subscribed based on The required data storage structure is used to pre-subscribe the server node, so that after obtaining the edge computing message collected by the target terminal device, the target address corresponding to the edge computing message is directly determined according to the pre-subscription relationship, and the target address is consistent with the stream processing platform. Corresponding to the server, there is no limit to this.
一些实施例中，在确定与边缘计算消息对应的目标地址之后，还可以获取连接流处理平台所需的加密证书；根据加密证书，对目标地址的连通性进行检验；则将协议转换后的边缘计算消息同步至与目标地址对应的服务器，可以是在确定连通性检验通过，则将协议转换后的边缘计算消息同步至与目标地址对应的服务器。In some embodiments, after determining the target address corresponding to the edge computing message, the encryption certificate required to connect to the stream processing platform can also be obtained; according to the encryption certificate, the connectivity of the target address is checked; The computing message is synchronized to the server corresponding to the target address, which may be to synchronize the protocol-converted edge computing message to the server corresponding to the target address after it is determined that the connectivity check is passed.
也即是说，本申请实施例中提供对目标地址的连通性进行验证的方法，在将边缘计算消息传输至目标地址之前，首先检验目标地址的连通性，在连通性检验通过之后，才对边缘计算消息进行同步，而若检验不通过，可以采取一些重连方式，对不可用的目标地址进行更新，从而能够有效确保目的地址的可用性，有效降低传输规则创建后目的地址不可用的概率。That is to say, the embodiment of this application provides a method for verifying the connectivity of the target address. Before the edge computing message is transmitted to the target address, the connectivity of the target address is first checked, and after the connectivity check is passed, the Edge computing messages are synchronized, and if the verification fails, some reconnection methods can be adopted to update the unavailable destination address, so as to effectively ensure the availability of the destination address and effectively reduce the probability of the destination address being unavailable after the transmission rule is created.
S103：根据流处理平台的数据传输协议，对边缘计算消息进行协议转换。S103: Perform protocol conversion on the edge computing message according to the data transmission protocol of the stream processing platform.
上述在获取目标终端设备所采集的边缘计算消息，并确定与边缘计算消息对应的目标地址之后，可以根据流处理平台的数据传输协议，对边缘计算消息进行协议转换。After obtaining the edge computing message collected by the target terminal device and determining the target address corresponding to the edge computing message, protocol conversion can be performed on the edge computing message according to the data transmission protocol of the stream processing platform.
举例而言，开源流处理平台Kafka支持一种数据传输协议，则可以将边缘计算消息的初始格式的协议，转换为开源流处理平台Kafka所支持的数据传输协议，而后，触发后续步骤。For example, if the open source stream processing platform Kafka supports a data transmission protocol, the protocol of the initial format of the edge computing message can be converted into the data transmission protocol supported by the open source stream processing platform Kafka, and then trigger the subsequent steps.
S104：采用数据传输协议，将协议转换后的边缘计算消息同步至与目标地址对应的服务器。S104: Using a data transmission protocol, synchronizing the edge computing message after the protocol conversion to the server corresponding to the target address.
上述在将边缘计算消息的初始格式的协议，转换为开源流处理平台Kafka所支持的数据传输协议之后，可以直接采用开源流处理平台Kafka所支持的数据传输协议将协议转换后的边缘计算消息同步至与目标地址对应的服务器，从而实现将边缘计算消息上传到外部的流处理平台中，拓展边缘计算消息同步的应用场景，满足用户的个性化使用需求。After converting the protocol of the initial format of the edge computing message into the data transmission protocol supported by the open source stream processing platform Kafka, the data transmission protocol supported by the open source stream processing platform Kafka can be directly used to synchronize the edge computing message after the protocol conversion To the server corresponding to the target address, so as to upload edge computing messages to the external stream processing platform, expand the application scenarios of edge computing message synchronization, and meet the personalized needs of users.
本实施例中，通过获取目标终端设备所采集的边缘计算消息，并确定与边缘计算消息对应的目标地址，目标地址与流处理平台中的服务器相对应，根据流处理平台的数据传输协议，对边缘计算消息进行协议转换，以及采用数据传输协议，将协议转换后的边缘计算消息同步至与目标地址对应的服务器，能够实现将边缘计算消息上传到外部的流处理平台中，拓展边缘计算消息同步的应用场景，满足用户的个性化使用需求。In this embodiment, by obtaining the edge computing message collected by the target terminal device, and determining the target address corresponding to the edge computing message, the target address corresponds to the server in the stream processing platform, and according to the data transmission protocol of the stream processing platform, the The edge computing message is converted to protocol, and the data transmission protocol is used to synchronize the edge computing message after the protocol conversion to the server corresponding to the target address, which can upload the edge computing message to the external stream processing platform and expand the edge computing message synchronization application scenarios to meet the individual needs of users.
图2是根据本申请第二实施例的示意图。Fig. 2 is a schematic diagram according to the second embodiment of the present application.
如图2所示，该边缘计算消息的同步方法包括：As shown in Figure 2, the synchronization method of the edge computing message includes:
S201：从多个终端设备之中确定目标终端设备。S201: Determine a target terminal device from among multiple terminal devices.
S202：确定目标主题类别。S202: Determine the target topic category.
S203：将目标主题类别与目标终端设备的标识关联保存。S203: Associating and storing the target subject category and the target terminal device identifier.
也即是说，预先可以是基于需求的数据存储结构来预先订阅服务器节点，并将该订阅的服务器节点支持的数据存储结构对应的主题类别，作为目标主题类别(该目标主题类别指示该服务器节点支持的数据存储结构)，则上述的目标主题类别，可以是与待同步的边缘计算消息的数据存储结构对应的主题类别，即，待同步的边缘计算消息的数据存储结构被划分至一个主题类别，该主题类别用于标识将边缘计算消息同步至的服务器的数据存储结构，则边缘计算消息和需要将其同步至的服务器的数据存储结构是具有对应关系的，为了保障边缘计算消息的高效存储，通常是将边缘计算消息同步至主题类别对应的服务器节点当中。That is to say, it is possible to pre-subscribe the server node based on the data storage structure of the demand in advance, and use the topic category corresponding to the data storage structure supported by the subscribed server node as the target topic category (the target topic category indicates that the server node Supported data storage structure), then the above target topic category can be the topic category corresponding to the data storage structure of the edge computing message to be synchronized, that is, the data storage structure of the edge computing message to be synchronized is divided into a topic category , this topic category is used to identify the data storage structure of the server to which the edge computing message is synchronized, and there is a corresponding relationship between the edge computing message and the data storage structure of the server to which it needs to be synchronized, in order to ensure the efficient storage of the edge computing message , usually to synchronize edge computing messages to the server nodes corresponding to the topic category.
则本申请实施例中，可以首先确定出执行边缘计算功能的终端设备并作为目标终端设备，而后确定该目标终端设备获得的边缘计算消息的数据存储结构，并确定该数据存储结构对应的目标主题类别，而后，将目标主题类别与目标终端设备的标识关联保存。Then, in the embodiment of the present application, the terminal device that performs the edge computing function can be determined first as the target terminal device, and then the data storage structure of the edge computing message obtained by the target terminal device can be determined, and the target topic corresponding to the data storage structure can be determined category, and then store the target subject category in association with the identifier of the target terminal device.
S204：根据标识，获取目标终端设备所采集的属于目标主题类别的边缘计算消息。S204: Obtain edge computing messages belonging to the target topic category collected by the target terminal device according to the identifier.
上述在将目标主题类别与目标终端设备的标识关联保存，可以直接根据标识，获取目标终端设备所采集的初始的边缘计算消息，而后，采用目标主题类别对应的数据存储结构，调整初始的边缘计算消息在基于端侧的消息规则引擎当中的数据存储结构，以形成目标主题类别的边缘计算消息，能够有效保障边缘计算消息的高效采集和存储，提升边缘计算消息的同步性能。As mentioned above, when the target topic category is associated with the target terminal device’s identifier, the initial edge computing message collected by the target terminal device can be obtained directly according to the identifier, and then the initial edge computing message can be adjusted by using the data storage structure corresponding to the target topic category. The data storage structure of the message in the message rule engine based on the terminal side forms the edge computing message of the target topic category, which can effectively guarantee the efficient collection and storage of the edge computing message and improve the synchronization performance of the edge computing message.
S205：确定与边缘计算消息对应的目标地址，目标地址与流处理平台中的服务器相对应。S205: Determine a target address corresponding to the edge computing message, where the target address corresponds to a server in the stream processing platform.
S206：根据流处理平台的数据传输协议，对边缘计算消息进行协议转换。S206: Perform protocol conversion on the edge computing message according to the data transmission protocol of the stream processing platform.
S205和S206可以具体参见上述实施例，在此不再赘述。For S205 and S206, reference may be made to the foregoing embodiments for details, and details are not repeated here.
S207：获取同步边缘计算消息所需的运算资源消耗值。S207: Obtain a computing resource consumption value required for synchronizing edge computing messages.
本实施例中，为了实现解决边缘计算设备硬件能力较弱，资源有限等技术问题，可以执行资源弹性调度算法，以实现根据运算资源消耗值，动态地对消息传输模块的实例数量进行扩容或者缩容处理，从而可以按需调整消息传输模块所占用的系统资源，降低边缘侧设备的运行压力。In this embodiment, in order to solve technical problems such as weak hardware capabilities and limited resources of edge computing devices, a resource elastic scheduling algorithm can be implemented to dynamically expand or shrink the number of instances of the message transmission module according to the calculation resource consumption value Capacity processing, so that the system resources occupied by the message transmission module can be adjusted as needed, and the operating pressure of the edge device can be reduced.
S208：根据运算资源消耗值，动态地对消息传输模块的实例数量进行扩容或者缩容处理，其中，消息传输模块，用于采用实例将协议转换后的边缘计算消息同步至与目标地址对应的服务器。S208: According to the calculation resource consumption value, dynamically expand or shrink the number of instances of the message transmission module, wherein the message transmission module is used to use the instance to synchronize the edge computing message after the protocol conversion to the server corresponding to the target address .
举例而言，可以实时地获取同步边缘计算消息所需的运算资源消耗值(中央处理器(CPU，Central Processing Unit)使用率、内存使用率、数据并发数量)，从而根据CPU使用率、内存使用率、数据并发数量等，动态地对消息传输模块的实例数量进行扩容或者缩容处理。For example, the computing resource consumption value (Central Processing Unit (CPU, Central Processing Unit) usage rate, memory usage rate, data concurrent number) required for synchronizing edge computing messages can be obtained in real time, so that according to the CPU usage rate, memory usage Rate, concurrent data, etc., dynamically expand or shrink the number of instances of the message transmission module.
可选地，一些实施例中，可以将运算资源消耗值与设定阈值范围进行对比，设定阈值范围包括最大消耗值和最小消耗值；如果运算资源消耗值小于最小消耗值，则对消息传输模块的实例数量进行扩容处理；如果运算资源消耗值大于最大消耗值，则对消息传输模块的实例数量进行缩容处理，实现简便，具有较好的资源管理效果。Optionally, in some embodiments, the calculation resource consumption value can be compared with the set threshold range, and the set threshold range includes the maximum consumption value and the minimum consumption value; if the calculation resource consumption value is less than the minimum consumption value, the message transmission The number of instances of the module is expanded; if the computing resource consumption value is greater than the maximum consumption value, the number of instances of the message transmission module is reduced, which is easy to implement and has a better resource management effect.
上述的设定阈值范围可以是预先根据消息传输模块的传输性能设定的，该设定阈值范围可以自适应调整，该设定阈值范围包括了在最大消耗值和最小消耗值之间的一个值范围，最大消耗值表明该数据传输模块所能承受的最大的CPU使用率、内存使用率、数据并发数量等，最小消耗值表明该数据传输模块所能承受的最小的CPU使用率、内存使用率、数据并发数量等。The above-mentioned set threshold range can be set in advance according to the transmission performance of the message transmission module, and the set threshold range can be adaptively adjusted, and the set threshold range includes a value between the maximum consumption value and the minimum consumption value Range, the maximum consumption value indicates the maximum CPU usage, memory usage, data concurrency, etc. that the data transmission module can bear, and the minimum consumption value indicates the minimum CPU usage and memory usage that the data transmission module can bear , the number of concurrent data, etc.
而由于消息传输模块，用于采用实例将协议转换后的边缘计算消息同步至与目标地址对应的服务器，消息传输模快之中配置多个实例，则本实施例中支持在运算资源消耗值小于最小消耗值(表明传输边缘计算消息所耗的运算资源消耗值不会过多占用资源)时，对消息传输模块的实例数量进行扩容处理，在运算资源消耗值大于最大消耗值(表明传输边缘计算消息所耗的运算资源消耗值较为占用资源)时，对消息传输模块的实例数量进行缩容处理。Since the message transmission module is used to use instances to synchronize edge computing messages after protocol conversion to the server corresponding to the target address, multiple instances are configured in the message transmission module, and this embodiment supports computing resource consumption values less than When the minimum consumption value (indicating that the computing resource consumption value consumed by transmitting edge computing messages will not occupy too much resources), expand the number of instances of the message transmission module, and when the computing resource consumption value is greater than the maximum consumption value (indicating that transmission edge computing When the calculation resource consumption value consumed by the message is relatively resource-occupied), the number of instances of the message transmission module is reduced.
S209：采用数据传输协议，将协议转换后的边缘计算消息同步至与目标地址对应的服务器。S209: Using a data transmission protocol, synchronizing the edge computing message after the protocol conversion to the server corresponding to the target address.
S209的描述可以具体参见上述实施例，在此不再赘述。For the description of S209, reference may be made to the foregoing embodiments for details, and details are not repeated here.
本实施例中，通过获取目标终端设备所采集的边缘计算消息，并确定与边缘计算消息对应的目标地址，目标地址与流处理平台中的服务器相对应，根据流处理平台的数据传输协议，对边缘计算消息进行协议转换，以及采用数据传输协议，将协议转换后的边缘计算消息同步至与目标地址对应的服务器，能够实现将边缘计算消息上传到外部的流处理平台中，拓展边缘计算消息同步的应用场景，满足用户的个性化使用需求。在将目标主题类别与目标终端设备的标识关联保存，可以直接根据标识，获取目标终端设备所采集的初始的边缘计算消息，而后，采用目标主题类别对应的数据存储结构，调整初始的边缘计算消息在基于端侧的消息规则引擎当中的数据存储结构，以形成目标主题类别的边缘计算消息，能够有效保障边缘计算消息的高效采集和存储，提升边缘计算消息的同步性能。为了实现解决边缘计算设备硬件能力较弱，资源有限等技术问题，可以执行资源弹性调度算法，以实现根据运算资源消耗值，动态地对消息传输模块的实例数量进行扩容或者缩容处理，从而可以按需调整消息传输模块所占用的系统资源，降低边缘侧设备的运行压力。In this embodiment, by obtaining the edge computing message collected by the target terminal device, and determining the target address corresponding to the edge computing message, the target address corresponds to the server in the stream processing platform, and according to the data transmission protocol of the stream processing platform, the The edge computing message is converted to protocol, and the data transmission protocol is used to synchronize the edge computing message after the protocol conversion to the server corresponding to the target address, which can upload the edge computing message to the external stream processing platform and expand the edge computing message synchronization application scenarios to meet the individual needs of users. After associating and saving the target topic category with the target terminal device’s identifier, the initial edge computing message collected by the target terminal device can be obtained directly according to the identifier, and then the initial edge computing message can be adjusted using the data storage structure corresponding to the target topic category The data storage structure in the terminal-based message rule engine forms edge computing messages of the target topic category, which can effectively guarantee the efficient collection and storage of edge computing messages and improve the synchronization performance of edge computing messages. In order to solve technical problems such as weak hardware capabilities and limited resources of edge computing devices, a resource elastic scheduling algorithm can be implemented to dynamically expand or shrink the number of instances of the message transmission module according to the computing resource consumption value, so that Adjust the system resources occupied by the message transmission module as needed to reduce the operating pressure on edge devices.
下面给出一个更具体的示例：A more concrete example is given below:
参见图3，图3是本申请实施例中边缘计算消息的同步装置的架构示意图，本申请实施例中以流处理平台是开源流处理平台Kafka进行示例，则本实施例的边缘计算消息的同步装置的硬件架构可以包括：消息总线模块、基于端侧的消息规则引擎、安全连接模块、Kafka目的地配置模块、协议转换模块、外部Kafka连通性测试模块、外部Kafka数据上传模块、资源弹性调度模块，从而支持以数据加密的方式将边缘计算消息同步到外部Kafka的目标地址对应的服务器。Referring to Fig. 3, Fig. 3 is a schematic diagram of the architecture of an edge computing message synchronization device in the embodiment of the present application. In the embodiment of the present application, the stream processing platform is an open source stream processing platform Kafka as an example, then the synchronization of the edge computing messages in this embodiment The hardware architecture of the device may include: a message bus module, an end-side-based message rule engine, a secure connection module, a Kafka destination configuration module, a protocol conversion module, an external Kafka connectivity test module, an external Kafka data upload module, and a flexible resource scheduling module , so as to support the synchronization of edge computing messages to the server corresponding to the target address of the external Kafka in a data encrypted manner.
另外，也可以在硬件架构当中配置数据采集模块，由数据采集模块获取目标终端设备(目标终端设备的数量可以是一个或者多个)所采集的边缘计算消息，并基于消息总线模块将边缘计算消息传输至基于端侧的消息规则引擎之中，由基于端侧的消息规则引擎触发后续对边缘计算消息的传输。In addition, the data acquisition module can also be configured in the hardware architecture, and the data acquisition module can obtain the edge computing messages collected by the target terminal device (the number of target terminal devices can be one or more), and based on the message bus module, the edge computing message It is transmitted to the device-based message rule engine, and the device-based message rule engine triggers the subsequent transmission of edge computing messages.
针对上述说明的硬件架构的说明可以如下：A description of the hardware architecture for the above description can be as follows:
可以预先配置数据采集模块，采集的消息源以及发送到本地消息中心模块的目标主题类别，配置消息总线模块，对接消息采集模块，同时转发到端侧的规则引擎模块，端侧规则引擎模块，安全连接模块，支持配置连接外部Kafka所需的加密证书，外部Kafka目的地配置模块，支持加载安全连接模块中的加密证书进行外部Kafka连通性测试，协议转换模块，支持将消息队列遥测传输(Message Queuing Telemetry Transport，MQTT)转换成开源流处理平台Kafka所支持的Kafka消息，外部Kafka数据上传模块，可以接收规则引擎模块发送的边缘计算消息，并将边缘计算消息上传至外部的开源流处理平台Kafka，以及资源弹性调度模块研发。You can pre-configure the data collection module, the source of the collected messages and the target topic category sent to the local message center module, configure the message bus module, connect with the message collection module, and forward it to the end-side rule engine module, end-side rule engine module, security The connection module supports configuring the encryption certificate required to connect to external Kafka, the external Kafka destination configuration module supports loading the encryption certificate in the secure connection module for external Kafka connectivity testing, and the protocol conversion module supports message queue telemetry transmission (Message Queuing Telemetry Transport, MQTT) into Kafka messages supported by the open source stream processing platform Kafka, the external Kafka data upload module can receive the edge computing messages sent by the rule engine module, and upload the edge computing messages to the external open source stream processing platform Kafka, And the development of resource flexible scheduling module.
上述的数据采集模块可以根据配置定期采集消息源，然后将消息发送到本地消息中心模块的约定主题，消息传输协议包括，但不限于标准消息队列遥测传输(MessageQueuing Telemetry Transport，MQTT)协议等。The above-mentioned data collection module can regularly collect message sources according to the configuration, and then send the message to the agreed topic of the local message center module. The message transmission protocol includes, but is not limited to, the standard Message Queuing Telemetry Transport (MQTT) protocol and the like.
上述的消息总线模块负责端侧的边缘计算消息的传输。The above-mentioned message bus module is responsible for the transmission of edge computing messages on the end side.
上述的端侧的规则引擎模块，用于订阅本地消息总线的主题，并转发到外部Kafka数据上传模块。The above-mentioned end-side rule engine module is used to subscribe to the topic of the local message bus and forward it to the external Kafka data upload module.
上述的安全连接模块，支持基于SSL(Secure Sockets Layer，安全套接字协议)证书(加密证书)与外部Kafka建立连接，保证连接与数据传输过程的安全性，并预先对加密证书合法性进行验证。The above-mentioned secure connection module supports establishing a connection with external Kafka based on an SSL (Secure Sockets Layer, secure socket protocol) certificate (encryption certificate), ensuring the security of the connection and data transmission process, and verifying the legitimacy of the encryption certificate in advance .
上述的加密证书，使用者添加外部Kafka连接地址、分组信息、主题类别等内容，提供连接外部Kafka所需信息。For the encryption certificate mentioned above, the user adds the external Kafka connection address, group information, topic category, etc. to provide the information required to connect to the external Kafka.
上述的进行外部Kafka连通性测试，可以使得用户及时获取相应的目的地址的连通性，确保目的地址的可用性，降低规则创建后目的地址不可用的概率。The above-mentioned external Kafka connectivity test can enable the user to obtain the connectivity of the corresponding destination address in a timely manner, ensure the availability of the destination address, and reduce the probability of the destination address being unavailable after the rule is created.
上述的协议转换模块，支持将MQTT消息转换成开源流处理平台Kafka支持的数据传输协议对应的消息(比如Kafka消息)，消息的有效信息包括但不限于消息编码信息、消息主题、消息质量、消息载荷等。The above-mentioned protocol conversion module supports converting MQTT messages into messages corresponding to data transmission protocols supported by the open source stream processing platform Kafka (such as Kafka messages). The effective information of the messages includes but is not limited to message encoding information, message topics, message quality, message load etc.
上述的外部Kafka数据上传模块接收规则引擎模块的消息，并调用消息转换模块将MQTT消息转化成Kafka消息，而后将Kafka消息上传至外部Kafka。The above-mentioned external Kafka data upload module receives the message of the rule engine module, and calls the message conversion module to convert the MQTT message into a Kafka message, and then uploads the Kafka message to the external Kafka.
上述的配置资源弹性调度模块，设置外部Kafka数据上传模块的最大实例数以及最小实例数以及参考指标(运算资源消耗值)上下限阈值(最大值和最小值)，从而在运行中资源弹性调度模块会收集、统计外部Kafka数据上传模块的CPU使用率、内存使用率、数据并发数量，如果超过/低于设置的阈值时，对流式计算引擎模块(即外部Kafka数据上传模块，也即上述的消息传输模块)的实例的数量进行扩容处理或者缩容处理，最小实例数支持设置为0，以最大程度地降低系统资源消耗。The above-mentioned configuration resource flexible scheduling module sets the maximum number of instances and the minimum number of instances of the external Kafka data upload module and the upper and lower limit thresholds (maximum and minimum values) of the reference index (computing resource consumption value), so that the resource flexible scheduling module is running It will collect and count the CPU usage, memory usage, and data concurrency of the external Kafka data upload module. If it exceeds/below the set threshold, the streaming computing engine module (that is, the external Kafka data upload module, that is, the above message The number of instances of the transmission module) can be expanded or reduced. The minimum number of instances can be set to 0 to minimize system resource consumption.
图4是根据本申请第三实施例的示意图。Fig. 4 is a schematic diagram according to a third embodiment of the present application.
如图4所示，该边缘计算消息的同步装置40，包括：As shown in FIG. 4, the synchronization device 40 of the edge computing message includes:
第一获取模块401，用于获取目标终端设备所采集的边缘计算消息；The first acquiring
确定模块402，用于确定与边缘计算消息对应的目标地址，目标地址与流处理平台中的服务器相对应；A determining
处理模块403，用于根据流处理平台的数据传输协议，对边缘计算消息进行协议转换；The
传输模块404，用于采用数据传输协议，将协议转换后的边缘计算消息同步至与目标地址对应的服务器。The
在本申请的一些实施例中，如图5所示，图5是根据本申请第四实施例的示意图，该边缘计算消息的同步装置50，第一获取模块501，确定模块502，处理模块503，传输模块504，还包括：In some embodiments of the present application, as shown in FIG. 5, which is a schematic diagram according to the fourth embodiment of the present application, the edge computing message synchronization device 50, the
检验模块505，用于在确定与边缘计算消息对应的目标地址之后，获取连接流处理平台所需的加密证书；根据加密证书，对目标地址的连通性进行检验；The
其中，传输模块504，具体用于：Among them, the
如果连通性检验通过，则将协议转换后的边缘计算消息同步至与目标地址对应的服务器。If the connectivity check passes, the edge computing message after the protocol conversion is synchronized to the server corresponding to the target address.
在本申请的一些实施例中，如图5所示，还包括：In some embodiments of the present application, as shown in Figure 5, further comprising:
第二获取模块506，用于在将协议转换后的边缘计算消息同步至与目标地址对应的服务器之前，获取同步边缘计算消息所需的运算资源消耗值；The second obtaining
管理模块507，用于根据运算资源消耗值，动态地对消息传输模块的实例数量进行扩容或者缩容处理，其中，消息传输模块，用于采用实例将协议转换后的边缘计算消息同步至与目标地址对应的服务器。The
在本申请的一些实施例中，其中，管理模块507，具体用于：In some embodiments of the present application, the
将运算资源消耗值与设定阈值范围进行对比，设定阈值范围包括最大消耗值和最小消耗值；Comparing the computing resource consumption value with the set threshold range, the set threshold range includes the maximum consumption value and the minimum consumption value;
如果运算资源消耗值小于最小消耗值，则对消息传输模块的实例数量进行扩容处理；If the computing resource consumption value is less than the minimum consumption value, expand the number of instances of the message transmission module;
如果运算资源消耗值大于最大消耗值，则对消息传输模块的实例数量进行缩容处理。If the computing resource consumption value is greater than the maximum consumption value, shrink the number of instances of the message transmission module.
在本申请的一些实施例中，如图5所示，其中，还包括：In some embodiments of the present application, as shown in FIG. 5, it also includes:
加密模块508，用于在获取目标终端设备所采集的边缘计算消息之后，根据加密证书，对协议转换后的边缘计算消息进行加密处理；The
其中，传输模块504，具体用于：Among them, the
将加密处理后的边缘计算消息同步至与目标地址对应的服务器。Synchronize the encrypted edge computing message to the server corresponding to the target address.
在本申请的一些实施例中，如图5所示，还包括：In some embodiments of the present application, as shown in Figure 5, further comprising:
关联模块509，用于从多个终端设备之中确定目标终端设备，并确定目标主题类别；以及将目标主题类别与目标终端设备的标识关联保存；An associating
其中，第一获取模块501，具体用于：Wherein, the
根据标识，获取目标终端设备所采集的属于目标主题类别的边缘计算消息。According to the identification, the edge computing messages collected by the target terminal device and belonging to the target topic category are obtained.
可以理解的是，本实施例附图5中的边缘计算消息的同步装置50与上述实施例中的边缘计算消息的同步装置40，第一获取模块501与上述实施例中的第一获取模块401，确定模块502与上述实施例中的确定模块402，处理模块503与上述实施例中的处理模块403，传输模块504与上述实施例中的传输模块404，可以具有相同的功能和结构。It can be understood that the edge computing message synchronization device 50 in Fig. 5 of this embodiment is the same as the edge computing message synchronization device 40 in the above embodiment, and the
需要说明的是，前述对边缘计算消息的同步方法的解释说明也适用于本实施例的边缘计算消息的同步装置，此处不再赘述。It should be noted that the foregoing explanations on the method for synchronizing edge computing messages are also applicable to the device for synchronizing edge computing messages in this embodiment, and will not be repeated here.
本实施例中，通过获取目标终端设备所采集的边缘计算消息，并确定与边缘计算消息对应的目标地址，目标地址与流处理平台中的服务器相对应，根据流处理平台的数据传输协议，对边缘计算消息进行协议转换，以及采用数据传输协议，将协议转换后的边缘计算消息同步至与目标地址对应的服务器，能够实现将边缘计算消息上传到外部的流处理平台中，拓展边缘计算消息同步的应用场景，满足用户的个性化使用需求。In this embodiment, by obtaining the edge computing message collected by the target terminal device, and determining the target address corresponding to the edge computing message, the target address corresponds to the server in the stream processing platform, and according to the data transmission protocol of the stream processing platform, the The edge computing message is converted to protocol, and the data transmission protocol is used to synchronize the edge computing message after the protocol conversion to the server corresponding to the target address, which can upload the edge computing message to the external stream processing platform and expand the edge computing message synchronization application scenarios to meet the individual needs of users.
根据本申请的实施例，本申请还提供了一种电子设备、一种可读存储介质和一种计算机程序产品。According to the embodiments of the present application, the present application also provides an electronic device, a readable storage medium, and a computer program product.
图6是用来实现本申请实施例的边缘计算消息的同步方法的电子设备的框图。电子设备旨在表示各种形式的数字计算机，诸如，膝上型计算机、台式计算机、工作台、个人数字助理、服务器、刀片式服务器、大型计算机、和其它适合的计算机。电子设备还可以表示各种形式的移动装置，诸如，个人数字处理、蜂窝电话、智能电话、可穿戴设备和其它类似的计算装置。本文所示的部件、它们的连接和关系、以及它们的功能仅仅作为示例，并且不意在限制本文中描述的和/或者要求的本申请的实现。Fig. 6 is a block diagram of an electronic device used to implement the method for synchronizing edge computing messages according to the embodiment of the present application. Electronic device is intended to represent various forms of digital computers, such as laptops, desktops, workstations, personal digital assistants, servers, blade servers, mainframes, and other suitable computers. Electronic devices may also represent various forms of mobile devices, such as personal digital processing, cellular telephones, smart phones, wearable devices, and other similar computing devices. The components shown herein, their connections and relationships, and their functions, are by way of example only, and are not intended to limit implementations of the applications described and/or claimed herein.
如图6所示，设备600包括计算单元601，其可以根据存储在只读存储器(ROM)602中的计算机程序或者从存储单元608加载到随机访问存储器(RAM)603中的计算机程序，来执行各种适当的动作和处理。在RAM 603中，还可存储设备600操作所需的各种程序和数据。计算单元601、ROM 602以及RAM 603通过总线604彼此相连。输入/输出(I/O)接口605也连接至总线604。As shown in FIG. 6, the
设备600中的多个部件连接至I/O接口605，包括：输入单元606，例如键盘、鼠标等；输出单元607，例如各种类型的显示器、扬声器等；存储单元608，例如磁盘、光盘等；以及通信单元609，例如网卡、调制解调器、无线通信收发机等。通信单元609允许设备600通过诸如因特网的计算机网络和/或各种电信网络与其他设备交换信息/数据。Multiple components in the
计算单元601可以是各种具有处理和计算能力的通用和/或专用处理组件。计算单元601的一些示例包括但不限于中央处理单元(CPU)、图形处理单元(GPU)、各种专用的人工智能(AI)计算芯片、各种运行机器学习模型算法的计算单元、数字信号处理器(DSP)、以及任何适当的处理器、控制器、微控制器等。计算单元601执行上文所描述的各个方法和处理，例如，边缘计算消息的同步方法。The
例如，在一些实施例中，边缘计算消息的同步方法可被实现为计算机软件程序，其被有形地包含于机器可读介质，例如存储单元608。在一些实施例中，计算机程序的部分或者全部可以经由ROM 602和/或通信单元609而被载入和/或安装到设备600上。当计算机程序加载到RAM 603并由计算单元601执行时，可以执行上文描述的边缘计算消息的同步方法的一个或多个步骤。备选地，在其他实施例中，计算单元601可以通过其他任何适当的方式(例如，借助于固件)而被配置为执行边缘计算消息的同步方法。For example, in some embodiments, the method for synchronizing edge computing messages may be implemented as a computer software program tangibly embodied on a machine-readable medium, such as
本文中以上描述的系统和技术的各种实施方式可以在数字电子电路系统、集成电路系统、场可编程门阵列(FPGA)、专用集成电路(ASIC)、专用标准产品(ASSP)、芯片上系统的系统(SOC)、负载可编程逻辑设备(CPLD)、计算机硬件、固件、软件、和/或它们的组合中实现。这些各种实施方式可以包括：实施在一个或者多个计算机程序中，该一个或者多个计算机程序可在包括至少一个可编程处理器的可编程系统上执行和/或解释，该可编程处理器可以是专用或者通用可编程处理器，可以从存储系统、至少一个输入装置、和至少一个输出装置接收数据和指令，并且将数据和指令传输至该存储系统、该至少一个输入装置、和该至少一个输出装置。Various implementations of the systems and techniques described above herein can be implemented in digital electronic circuit systems, integrated circuit systems, field programmable gate arrays (FPGAs), application specific integrated circuits (ASICs), application specific standard products (ASSPs), systems on chips Implemented in a system of systems (SOC), load programmable logic device (CPLD), computer hardware, firmware, software, and/or combinations thereof. These various embodiments may include being implemented in one or more computer programs executable and/or interpreted on a programmable system including at least one programmable processor, the programmable processor Can be special-purpose or general-purpose programmable processor, can receive data and instruction from storage system, at least one input device, and at least one output device, and transmit data and instruction to this storage system, this at least one input device, and this at least one output device an output device.
用于实施本申请的边缘计算消息的同步方法的程序代码可以采用一个或多个编程语言的任何组合来编写。这些程序代码可以提供给通用计算机、专用计算机或其他可编程数据处理装置的处理器或控制器，使得程序代码当由处理器或控制器执行时使流程图和/或框图中所规定的功能/操作被实施。程序代码可以完全在机器上执行、部分地在机器上执行，作为独立软件包部分地在机器上执行且部分地在远程机器上执行或完全在远程机器或服务器上执行。The program code for implementing the method for synchronizing edge computing messages of this application can be written in any combination of one or more programming languages. These program codes may be provided to a processor or controller of a general-purpose computer, a special purpose computer, or other programmable data processing devices, so that the program codes, when executed by the processor or controller, make the functions/functions specified in the flow diagrams and/or block diagrams Action is implemented. The program code may execute entirely on the machine, partly on the machine, as a stand-alone software package partly on the machine and partly on a remote machine or entirely on the remote machine or server.
在本申请的上下文中，机器可读介质可以是有形的介质，其可以包含或存储以供指令执行系统、装置或设备使用或与指令执行系统、装置或设备结合地使用的程序。机器可读介质可以是机器可读信号介质或机器可读储存介质。机器可读介质可以包括但不限于电子的、磁性的、光学的、电磁的、红外的、或半导体系统、装置或设备，或者上述内容的任何合适组合。机器可读存储介质的更具体示例会包括基于一个或多个线的电气连接、便携式计算机盘、硬盘、随机存取存储器(RAM)、只读存储器(ROM)、可擦除可编程只读存储器(EPROM或快闪存储器)、光纤、便捷式紧凑盘只读存储器(CD-ROM)、光学储存设备、磁储存设备、或上述内容的任何合适组合。In the context of the present application, a machine-readable medium may be a tangible medium that may contain or store a program for use by or in conjunction with an instruction execution system, apparatus, or device. A machine-readable medium may be a machine-readable signal medium or a machine-readable storage medium. A machine-readable medium may include, but is not limited to, electronic, magnetic, optical, electromagnetic, infrared, or semiconductor systems, apparatus, or devices, or any suitable combination of the foregoing. More specific examples of machine-readable storage media would include one or more wire-based electrical connections, portable computer discs, hard drives, random access memory (RAM), read only memory (ROM), erasable programmable read only memory (EPROM or flash memory), optical fiber, compact disk read only memory (CD-ROM), optical storage, magnetic storage, or any suitable combination of the foregoing.
为了提供与用户的交互，可以在计算机上实施此处描述的系统和技术，该计算机具有：用于向用户显示信息的显示装置(例如，CRT(阴极射线管)或者LCD(液晶显示器)监视器)；以及键盘和指向装置(例如，鼠标或者轨迹球)，用户可以通过该键盘和该指向装置来将输入提供给计算机。其它种类的装置还可以用于提供与用户的交互；例如，提供给用户的反馈可以是任何形式的传感反馈(例如，视觉反馈、听觉反馈、或者触觉反馈)；并且可以用任何形式(包括声输入、语音输入或者、触觉输入)来接收来自用户的输入。To provide for interaction with the user, the systems and techniques described herein can be implemented on a computer having a display device (e.g., a CRT (cathode ray tube) or LCD (liquid crystal display) monitor) for displaying information to the user. ); and a keyboard and pointing device (eg, a mouse or a trackball) through which a user can provide input to the computer. Other kinds of devices can also be used to provide interaction with the user; for example, the feedback provided to the user can be any form of sensory feedback (e.g., visual feedback, auditory feedback, or tactile feedback); and can be in any form (including Acoustic input, speech input or, tactile input) to receive input from the user.
可以将此处描述的系统和技术实施在包括后台部件的计算系统(例如，作为数据服务器)、或者包括中间件部件的计算系统(例如，应用服务器)、或者包括前端部件的计算系统(例如，具有图形用户界面或者网络浏览器的用户计算机，用户可以通过该图形用户界面或者该网络浏览器来与此处描述的系统和技术的实施方式交互)、或者包括这种后台部件、中间件部件、或者前端部件的任何组合的计算系统中。可以通过任何形式或者介质的数字数据通信(例如，通信网络)来将系统的部件相互连接。通信网络的示例包括：局域网(LAN)、广域网(WAN)、互联网及区块链网络。The systems and techniques described herein can be implemented in a computing system that includes back-end components (e.g., as a data server), or a computing system that includes middleware components (e.g., an application server), or a computing system that includes front-end components (e.g., as a a user computer having a graphical user interface or web browser through which a user can interact with embodiments of the systems and techniques described herein), or including such backend components, middleware components, Or any combination of front-end components in a computing system. The components of the system can be interconnected by any form or medium of digital data communication, eg, a communication network. Examples of communication networks include: local area networks (LANs), wide area networks (WANs), the Internet, and blockchain networks.
计算机系统可以包括客户端和服务器。客户端和服务器一般远离彼此并且通常通过通信网络进行交互。通过在相应的计算机上运行并且彼此具有客户端-服务器关系的计算机程序来产生客户端和服务器的关系。服务器可以是云服务器，又称为云计算服务器或云主机，是云计算服务体系中的一项主机产品，以解决了传统物理主机与VPS服务("Virtual Private Server"，或简称"VPS")中，存在的管理难度大，业务扩展性弱的缺陷。服务器也可以为分布式系统的服务器，或者是结合了区块链的服务器。A computer system may include clients and servers. Clients and servers are generally remote from each other and typically interact through a communication network. The relationship of client and server arises by computer programs running on the respective computers and having a client-server relationship to each other. The server can be a cloud server, also known as cloud computing server or cloud host, which is a host product in the cloud computing service system to solve the problem of traditional physical host and VPS service ("Virtual Private Server", or "VPS") Among them, there are defects such as difficult management and weak business scalability. The server can also be a server of a distributed system, or a server combined with a blockchain.
应该理解，可以使用上面所示的各种形式的流程，重新排序、增加或删除步骤。例如，本发公开中记载的各步骤可以并行地执行也可以顺序地执行也可以不同的次序执行，只要能够实现本申请公开的技术方案所期望的结果，本文在此不进行限制。It should be understood that steps may be reordered, added or deleted using the various forms of flow shown above. For example, the steps described in the present disclosure may be executed in parallel, sequentially, or in a different order, as long as the desired result of the technical solution disclosed in the present application can be achieved, no limitation is imposed herein.
上述具体实施方式，并不构成对本申请保护范围的限制。本领域技术人员应该明白的是，根据设计要求和其他因素，可以进行各种修改、组合、子组合和替代。任何在本申请的精神和原则之内所作的修改、等同替换和改进等，均应包含在本申请保护范围之内。The above specific implementation methods are not intended to limit the protection scope of the present application. It should be apparent to those skilled in the art that various modifications, combinations, sub-combinations and substitutions may be made depending on design requirements and other factors. Any modifications, equivalent replacements and improvements made within the spirit and principles of this application shall be included within the protection scope of this application.
Claims (12)
Translated fromChinesePriority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011520048.7ACN112769897B (en) | 2020-12-21 | 2020-12-21 | Synchronization method and device of edge calculation message, electronic equipment and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011520048.7ACN112769897B (en) | 2020-12-21 | 2020-12-21 | Synchronization method and device of edge calculation message, electronic equipment and storage medium |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN112769897A CN112769897A (en) | 2021-05-07 |
| CN112769897Btrue CN112769897B (en) | 2023-04-18 |
Family
ID=75695164
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202011520048.7AActiveCN112769897B (en) | 2020-12-21 | 2020-12-21 | Synchronization method and device of edge calculation message, electronic equipment and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN112769897B (en) |
Families Citing this family (12)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113420048A (en)* | 2021-05-19 | 2021-09-21 | 中交公规土木大数据信息技术（北京）有限公司 | Data aggregation method and device, electronic equipment and storage medium |
| CN113423088A (en)* | 2021-06-18 | 2021-09-21 | 安徽星云互联科技有限责任公司 | Information distribution method, device, equipment, system and storage medium |
| CN113438318B (en)* | 2021-07-13 | 2023-04-07 | 阿波罗智联(北京)科技有限公司 | Performance test system and method of cloud control platform, electronic equipment and storage medium |
| CN113515237B (en)* | 2021-07-22 | 2024-09-20 | 中移（杭州）信息技术有限公司 | Edge node capacity expansion method and device, edge node and program product |
| CN113630465B (en)* | 2021-08-10 | 2024-03-12 | 北京百度网讯科技有限公司 | Message processing method, device, equipment and storage medium |
| CN113783954B (en)* | 2021-09-07 | 2024-10-18 | 中控创新(北京)能源技术有限公司 | Oil and gas pipeline component data transmission system and method |
| CN113986401A (en)* | 2021-10-25 | 2022-01-28 | 北京百度网讯科技有限公司 | Data processing method and device, electronic equipment and storage medium |
| CN114253710A (en)* | 2021-11-22 | 2022-03-29 | 北京百度网讯科技有限公司 | Computing request processing method, intelligent terminal, cloud server, device and medium |
| CN114726871B (en)* | 2022-03-22 | 2024-06-11 | 阿里巴巴（中国）有限公司 | Data synchronization method, device and network system |
| CN115297093B (en)* | 2022-08-02 | 2024-06-25 | 北京至为恒通企业管理有限公司 | Edge device data access method, related device and computer program product |
| CN116016716B (en)* | 2022-12-08 | 2024-10-11 | 江苏开拓信息与系统有限公司 | Virtual intelligent box processing system and processing method for edge computing of Internet of things |
| CN116737482A (en)* | 2023-08-10 | 2023-09-12 | 上海孤波科技有限公司 | Method and device for collecting chip test data in real time and electronic equipment |
Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110430281A (en)* | 2019-08-15 | 2019-11-08 | 深圳市般若大数据技术有限公司 | Method, apparatus, equipment and the storage medium of public cloud acquisition private clound data |
| CN110460521A (en)* | 2019-09-19 | 2019-11-15 | 北京中电普华信息技术有限公司 | An edge computing soft gateway |
| WO2020216038A1 (en)* | 2019-04-22 | 2020-10-29 | 华为技术有限公司 | Data management method, lepm, and mepm |
Family Cites Families (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US10659526B2 (en)* | 2018-01-03 | 2020-05-19 | Verizon Patent And Licensing Inc. | Edge compute systems and methods |
| CN116170316B (en)* | 2019-04-08 | 2025-09-26 | 阿里巴巴集团控股有限公司 | Network system, instance management method, device and storage medium |
| CN110266776A (en)* | 2019-06-05 | 2019-09-20 | 广州云华智慧科技有限公司 | Cloud layer communication system |
| CN110545307B (en)* | 2019-07-19 | 2022-09-27 | 中移（杭州）信息技术有限公司 | Edge computing platform, calling method and computer readable storage medium |
| CN110557387A (en)* | 2019-08-29 | 2019-12-10 | 浙江大搜车软件技术有限公司 | cross-network equipment communication method, device, system, server and readable storage medium |
| CN110769039B (en)* | 2019-10-09 | 2021-12-10 | 腾讯科技（深圳）有限公司 | Resource scheduling method and device, electronic equipment and computer readable storage medium |
| CN111314339B (en)* | 2020-02-12 | 2021-09-10 | 腾讯科技（深圳）有限公司 | Data transmission method and device |
- 2020
- 2020-12-21CNCN202011520048.7Apatent/CN112769897B/enactiveActive
Patent Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| WO2020216038A1 (en)* | 2019-04-22 | 2020-10-29 | 华为技术有限公司 | Data management method, lepm, and mepm |
| CN110430281A (en)* | 2019-08-15 | 2019-11-08 | 深圳市般若大数据技术有限公司 | Method, apparatus, equipment and the storage medium of public cloud acquisition private clound data |
| CN110460521A (en)* | 2019-09-19 | 2019-11-15 | 北京中电普华信息技术有限公司 | An edge computing soft gateway |
Non-Patent Citations (4)
| Title |
|---|
| .Delivering Functions over Networks: Traffic and Performance Optimization for Edge Computing using ALTO.IETF .2020,全文.* |
| S. Yang ; L. Cui ; Shenzhen University ; M. Xu ; Tsinghua University ; Y. Yang ; Tongji/Yale ; R. Huang ; Research Institute of Tsinghua University in Shenzhen* |
| 王旭亮 ; 武宇亭 ; 任宏丹 ; .基于5G+MEC的数字化PaaS赋能平台在智慧安防的应用研究.电子技术应用.2020,(第06期),全文.* |
| 陆璐 ; .面向5G网络的边缘计算技术研究.信息通信技术与政策.2018,(第11期),全文.* |
Also Published As
| Publication number | Publication date |
|---|---|
| CN112769897A (en) | 2021-05-07 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN112769897B (en) | Synchronization method and device of edge calculation message, electronic equipment and storage medium | |
| CN113742031A (en) | Node state information acquisition method and device, electronic equipment and readable storage medium | |
| CN113766487B (en) | Cloud mobile phone information acquisition methods, devices, equipment and media | |
| CN113556584A (en) | Screenshot transmission method, device, electronic device and storage medium of cloud mobile phone | |
| CN114185641A (en) | Virtual machine cold migration method, device, electronic device and storage medium | |
| CN115150063A (en) | Model encryption method and device and electronic equipment | |
| CN114374703B (en) | Methods, devices, equipment and storage media for obtaining cloud mobile phone information | |
| WO2023066183A1 (en) | Data processing method and apparatus, device, and storage medium | |
| CN109788251B (en) | Video processing method, device and storage medium | |
| CN109710502B (en) | Log transmission method, device and storage medium | |
| CN114070889B (en) | Configuration methods, traffic forwarding methods, equipment, storage media and program products | |
| CN115987509A (en) | Vehicle-mounted network security management method, device and storage medium | |
| CN113824689B (en) | Edge computing network, data transmission method, device, equipment and storage medium | |
| CN115865974A (en) | Edge device, cloud device, edge computing system and method, and storage medium | |
| CN115297093A (en) | Data access method for edge device, related device and computer program product | |
| CN115658290A (en) | Message processing method, device, device and storage medium | |
| CN115883676A (en) | A data packet transmission method, device, electronic equipment and storage medium | |
| CN115410580A (en) | Speech recognition method, device, equipment and medium for command and dispatch system | |
| CN114553548A (en) | Communication method, apparatus, device and storage medium | |
| CN114793234B (en) | Message processing method, device, equipment and storage medium | |
| CN113014656B (en) | Private cloud information synchronization method and device | |
| CN117112576A (en) | Data synchronization method and device, server and storage medium | |
| CN117221127A (en) | Method and device for using artificial intelligence service at communication network end side | |
| CN116647450A (en) | A method, device, equipment and medium for modifying Nginx configuration information | |
| CN116016484A (en) | Data transmission method, device, device and storage medium |
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 | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |