CN113992715B - Online state cloud monitoring and edge computing device and method - Google Patents
Online state cloud monitoring and edge computing device and method Download PDFInfo
- Publication number
- CN113992715B CN113992715B CN202111245154.3A CN202111245154A CN113992715B CN 113992715 B CN113992715 B CN 113992715B CN 202111245154 A CN202111245154 A CN 202111245154A CN 113992715 B CN113992715 B CN 113992715B
- Authority
- CN
- China
- Prior art keywords
- edge node
- server
- network address
- sensor
- data
- 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
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/12—Protocols specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
Landscapes
- Engineering & Computer Science (AREA)
- Health & Medical Sciences (AREA)
- Computing Systems (AREA)
- General Health & Medical Sciences (AREA)
- Medical Informatics (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Computer And Data Communications (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
The application discloses an online state cloud monitoring and edge computing device and method, wherein the method comprises the following steps: an edge node receives data from a sensor, wherein the sensor is an internet of things sensor, and the edge node is connected with a server and the sensor; the edge node acquires a service type corresponding to the data; the edge node processes the data to obtain a response to the data under the condition that the service type is determined to be processed by the edge node; the edge node sends the response to the sensor. The method and the device solve the problem that the server in the Internet of things can not process the sensor data in time in the prior art, thereby improving the processing speed of the sensor data of the Internet of things.
Description
Technical Field
The application relates to the field of cloud computing, in particular to an online state cloud monitoring and edge computing device and method.
Background
Along with the development of the internet of things technology, the data of a plurality of sensors of an application layer need to be monitored online in real time and respond in a related manner, and at present, the data of all the sensors need to be sent to a server for processing.
Disclosure of Invention
The embodiment of the application provides an online state cloud monitoring and edge computing device and method, which are used for at least solving the problem that a server in the Internet of things can not process sensor data in time in the prior art.
According to one aspect of the present application, there is provided a line state cloud monitoring and edge computing method, including: an edge node receives data from a sensor, wherein the sensor is an internet of things sensor, and the edge node is connected with a server and the sensor; the edge node acquires a service type corresponding to the data; the edge node processes the data to obtain a response to the data under the condition that the service type is determined to be processed by the edge node; the edge node sends the response to the sensor.
Further, in the case that the service type is determined not to be processed by the edge node, the edge node further includes: the edge node sends the data to the server.
Further, the edge node sending the data to the server includes: the edge node obtains the network address of the data source; the edge node sends the data and a network address to the server, wherein the network address is used for indicating the server to send the response of the data to a sensor corresponding to the network address.
Further, in the case that the edge node cannot obtain the network address of the data source, the method further includes: the edge node sends the network address of the edge node to the server.
Further, the sensor includes a plurality of types of sensors, wherein each different type of sensor corresponds to a different service type, respectively.
According to another aspect of the present application, there is also provided a line cloud monitoring and edge computing device, located in an edge node, where the edge node connects a server and the sensor, the device includes: the receiving module is used for receiving data from a sensor, wherein the sensor is an Internet of things sensor; the acquisition module is used for acquiring the service type corresponding to the data; the processing module is used for processing the data to obtain a response to the data under the condition that the service type is determined to be processed by the edge node; and the sending module is used for sending the response to the sensor.
Further, in the case that the service type is determined not to be processed by the edge node, the processing module is further configured to: and sending the data to the server.
Further, the sending module is configured to: acquiring a network address of the data source; and sending the data and the network address to the server, wherein the network address is used for indicating the server to send the response of the data to the sensor corresponding to the network address.
Further, in the case that the network address of the data source cannot be obtained, the sending module is further configured to: and sending the network address of the edge node to the server.
Further, the sensor includes a plurality of types of sensors, wherein each different type of sensor corresponds to a different service type, respectively.
In the embodiment of the application, an edge node is adopted to receive data from a sensor, wherein the sensor is an Internet of things sensor, and the edge node is connected with a server and the sensor; the edge node acquires a service type corresponding to the data; the edge node processes the data to obtain a response to the data under the condition that the service type is determined to be processed by the edge node; the edge node sends the response to the sensor. The method and the device solve the problem that the server in the Internet of things can not process the sensor data in time in the prior art, thereby improving the processing speed of the sensor data of the Internet of things.
Drawings
The accompanying drawings, which are included to provide a further understanding of the application and are incorporated in and constitute a part of this specification, illustrate embodiments of the application and together with the description serve to explain the application. In the drawings:
FIG. 1 is a flow chart of a presence cloud monitoring and edge computing method according to an embodiment of the present application.
Detailed Description
It should be noted that, without conflict, the embodiments of the present application and features of the embodiments may be combined with each other. The application will be described in detail below with reference to the drawings in connection with embodiments.
It should be noted that the steps illustrated in the flowcharts of the figures may be performed in a computer system such as a set of computer executable instructions, and that although a logical order is illustrated in the flowcharts, in some cases the steps illustrated or described may be performed in an order other than that illustrated herein.
In this embodiment, a method for monitoring a state cloud and calculating an edge is provided, and fig. 1 is a flowchart of a method for monitoring a state cloud and calculating an edge according to an embodiment of the present application, as shown in fig. 1, where the flowchart includes the following steps:
step S102, an edge node receives data from a sensor, wherein the sensor is an Internet of things sensor, and the edge node is connected with a server and the sensor;
step S104, the edge node obtains the service type corresponding to the data;
optionally, the sensor includes a plurality of types of sensors, wherein each different type of sensor corresponds to a different service type. For example, a camera is used as one of the sensors, and sends picture data, the service type corresponding to the picture data is image processing, and the edge node determines that the image processing is processed by the server. The data sent by the temperature sensor is temperature data, the service type corresponding to the data is control air conditioner, and the edge node determines that the temperature data is processed by the edge node.
Step S106, the edge node processes the data to obtain a response to the data under the condition that the service type is determined to be processed by the edge node;
step S108, the edge node sends the response to the sensor.
The problems caused by the fact that a server in the Internet of things can not process sensor data in time in the prior art are solved through the steps, and therefore the processing speed of the sensor data of the Internet of things is improved.
The edge node further comprises, in case it is determined that the traffic type is not handled by the edge node: the edge node sends the data to the server. Optionally, the edge node obtains a network address of the data source; the edge node sends the data and a network address to the server, wherein the network address is used for indicating the server to send the response of the data to a sensor corresponding to the network address.
And in the case that the edge node cannot acquire the network address of the data source, the edge node sends the network address of the edge node to the server.
As an optional implementation manner, after each edge node is online, the edge node sends a registration message to a server, wherein the registration message carries computing resources of the edge node and a network address of the edge node, and the server determines a service type which can be processed by the edge node according to the computing resources of the edge node and acquires a type of a sensor corresponding to the service type; the server acquires a sensor with a distance smaller than a threshold value from the edge node according to the network address of the edge node, the server sends the service type which can be processed by the edge node to the edge node, and sends the network address of the edge node to the sensor with the distance smaller than the threshold value, and the sensor sends the acquired data to the edge node according to the network address of the edge node.
After authenticating an edge node, the server sends the network address of the edge node to a sensor with a distance smaller than a threshold value. The authentication process is as follows: the server sends the network address of the edge node to an authentication server, all legal network addresses are stored in the authentication server, and if the authentication server determines that the network address of the edge node is in the legal network addresses, a legal confirmation message of the edge node is returned to the server.
After the edge node authenticates the server, the edge node sends the registration message to the server, wherein the authentication process is as follows: and the edge node sends the network address of the server to an authentication server, wherein the authentication server stores all legal network addresses, and if the authentication server determines that the network address of the server is in the legal network addresses, the edge node sends a legal confirmation message of the server.
After the two-way authentication, the method is safer.
And under the condition that the available computing resources are smaller than a preset value, the edge node transmits all received data from the sensors to a server, the server determines that the data which should be processed by the edge node is transmitted to the server according to the received data, the server determines that the edge node is in a busy state, the server transmits the network address of the server to the sensor which stores the network address of the edge node, and the network address of the edge node is replaced by the network address of the server.
When the available computing resources of the edge node are larger than the preset value, the edge node sends a registration message again to the server, wherein the registration message carries the computing resources of the edge node and the network address of the edge node, and the server determines the service type which can be processed by the edge node according to the computing resources of the edge node and acquires the type of a sensor corresponding to the service type; the server acquires a sensor with a distance smaller than a threshold value from the edge node according to the network address of the edge node, the server sends the service type which can be processed by the edge node to the edge node, and sends the network address of the edge node to the sensor with the distance smaller than the threshold value, and the sensor sends the acquired data to the edge node according to the network address of the edge node.
And the edge node stores the processed data and the sent response data in a file according to a preset time length, and the naming of the file is performed by using the file generation time and the unique identification information of the edge node. And the edge node names the file and sends the file to the server for storage. The processing method can retain relevant data so as to facilitate auditing the processing of the edge nodes.
And the server stores the file after receiving the file. The following preservation method can be optionally adopted: obtaining the name of each file, taking the name of the file as the unique identifier of the file, calculating the unique identifier of the file by using the stored first file plus the content of the file to obtain a first verification code, calculating the unique identifier of the second file by using the unique identifier of the second file plus the content of the second file and the first verification code to obtain a second verification code, and the like, and obtaining the N verification code by using the unique identifier of the N file plus the content of the N file and the N-1 verification code. The storage mode can ensure that the file cannot be tampered. And this way of storing a plurality of files constitutes a file chain.
In this embodiment, an online state cloud monitoring device is provided, which may be considered as an edge node, and is composed of a power supply, a processor (CPU), an uplink communication module, a local sensor, a local executing mechanism, and the like. The processor collects the data of the sensor regularly according to the agreed rules (time and method), compares the data with the preset threshold value (edge calculation), performs local actions according to the rules remotely set by the cloud platform and sends the result to the cloud platform server through the uplink communication module.
The edge node calculates and judges the field acquisition data and executes the formulated response operation. The real-time performance of the response is improved, the communication data volume between the remote end and the cloud end is reduced, and the pressure of the cloud end server is relieved. For example, a power distribution room temperature sensor monitors that the indoor temperature exceeds a preset threshold, and the power distribution room temperature sensor uploads the room temperature value to an edge node, receives feedback of the edge node, opens an air conditioner (or opens a fan) in real time to cool down, and when the temperature falls to the threshold, the edge node sends a command to turn off the power supply of the air conditioner (or turns off the fan).
In this embodiment, there is provided an electronic device including a memory in which a computer program is stored, and a processor configured to run the computer program to perform the method in the above embodiment.
The above-described programs may be run on a processor or may also be stored in memory (or referred to as computer-readable media), including both permanent and non-permanent, removable and non-removable media, and information storage may be implemented by any method or technique. The information may be computer readable instructions, data structures, modules of a program, or other data. Examples of storage media for a computer 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 disc read only memory (CD-ROM), digital Versatile Discs (DVD) or other optical storage, magnetic cassettes, magnetic tape magnetic disk storage or other magnetic storage devices, or any other non-transmission medium, which can be used to store information that can be accessed by a computing device. Computer-readable media, as defined herein, does not include transitory computer-readable media (transmission media), such as modulated data signals and carrier waves.
These computer programs may also be loaded onto a computer or other programmable data processing apparatus to cause a series of operational steps to be performed on the computer or other programmable apparatus to produce a computer implemented process such that the instructions which execute on the computer or other programmable apparatus provide steps for implementing the functions specified in the flowchart block or blocks and/or block diagram block or blocks, and corresponding steps may be implemented in different modules.
Such an apparatus or system is provided in this embodiment. This device, known as a line state cloud monitoring and edge computing device, is located in an edge node that connects a server and the sensor, the device comprising: the receiving module is used for receiving data from a sensor, wherein the sensor is an Internet of things sensor; the acquisition module is used for acquiring the service type corresponding to the data; the processing module is used for processing the data to obtain a response to the data under the condition that the service type is determined to be processed by the edge node; and the sending module is used for sending the response to the sensor.
The system or the device is used for realizing the functions of the method in the above embodiment, and each module in the system or the device corresponds to each step in the method, which has been described in the method, and will not be described herein.
For example, in the case that the processing module determines that the service type is not processed by the edge node, the sending module is further configured to: and sending the data to the server. Optionally, the sending module is configured to: acquiring a network address of the data source; and sending the data and the network address to the server, wherein the network address is used for indicating the server to send the response of the data to the sensor corresponding to the network address. Optionally, in the case that the network address of the data source cannot be obtained, the sending module is further configured to: and sending the network address of the edge node to the server.
In this embodiment, the sensor includes a plurality of types of sensors, where each different type of sensor corresponds to a different service type.
The problem that a server in the Internet of things can not process sensor data in time in the prior art is solved through the method, and therefore the processing speed of the sensor data of the Internet of things is improved.
The foregoing is merely exemplary of the present application and is not intended to limit the present application. Various modifications and variations of the present application will be apparent to those skilled in the art. Any modification, equivalent replacement, improvement, etc. which come within the spirit and principles of the application are to be included in the scope of the claims of the present application.
Claims (5)
1. A line cloud monitoring and edge computing method is characterized by comprising the following steps:
an edge node receives data from a sensor, wherein the sensor is an internet of things sensor, and the edge node is connected with a server and the sensor;
the edge node acquires a service type corresponding to the data;
the edge node processes the data to obtain a response to the data under the condition that the service type is determined to be processed by the edge node;
the edge node sending the response to the sensor;
after each edge node is online, the edge node sends a registration message to a server, wherein the registration message carries computing resources of the edge node and a network address of the edge node, and the server determines a service type which can be processed by the edge node according to the computing resources of the edge node and acquires a type of a sensor corresponding to the service type; the server acquires a sensor with a distance smaller than a threshold value from the edge node according to the network address of the edge node, the server sends the service type which can be processed by the edge node to the edge node, and sends the network address of the edge node to the sensor with the distance smaller than the threshold value, and the sensor sends the acquired data to the edge node according to the network address of the edge node;
after authenticating an edge node, the server sends the network address of the edge node to a sensor with the distance smaller than a threshold value; the authentication process of the server for authenticating the edge node is as follows: the server sends the network address of the edge node to an authentication server, the authentication server stores all legal network addresses of the edge node, and the authentication server determines that the network address of the edge node is in the legal network address of the edge node and returns a legal confirmation message of the edge node to the server;
after the edge node authenticates the server, the registration message is sent to the server, wherein the authentication process of the edge node for authenticating the server is as follows: the edge node sends the network address of the server to an authentication server, wherein the authentication server stores all legal network addresses of the server, and if the authentication server determines that the network address of the server is in the legal network address of the server, the edge node sends a legal confirmation message of the server;
the edge node sends all received data from the sensor to a server under the condition that available computing resources are smaller than preset values, the server determines that the data which should be processed by the edge node is sent to the server according to the received data, the server determines that the edge node is in a busy state, the server sends a network address of the server to the sensor which stores the network address of the edge node, and the network address of the edge node is replaced by the network address of the server;
in case the computing resources available to the edge node are larger than the preset value, the edge node re-sends a registration message to the server.
2. The method of claim 1, wherein the edge node, if it is determined that the traffic type is not handled by the edge node, further comprises:
the edge node sends the data to the server.
3. The method of claim 2, wherein the edge node sending the data to the server comprises:
the edge node obtains the network address of the data source;
the edge node sends the data and the network address of the data source to the server, wherein the network address of the data source is used for indicating the server to send the response of the data to the sensor corresponding to the network address of the data source.
4. A method according to claim 3, further comprising, in the event that the edge node cannot obtain the network address of the data source:
the edge node sends the network address of the edge node to the server.
5. The method of any one of claims 1 to 4, wherein the sensors comprise a plurality of types of sensors, wherein each different type of sensor corresponds to a different traffic type, respectively.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111245154.3A CN113992715B (en) | 2021-10-26 | 2021-10-26 | Online state cloud monitoring and edge computing device and method |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111245154.3A CN113992715B (en) | 2021-10-26 | 2021-10-26 | Online state cloud monitoring and edge computing device and method |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN113992715A CN113992715A (en) | 2022-01-28 |
| CN113992715B true CN113992715B (en) | 2023-09-26 |
Family
ID=79741337
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202111245154.3A Active CN113992715B (en) | 2021-10-26 | 2021-10-26 | Online state cloud monitoring and edge computing device and method |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN113992715B (en) |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107295110A (en) * | 2017-08-16 | 2017-10-24 | 网宿科技股份有限公司 | Processing method, fringe node, service server and the system of calculating task |
| CN109495929A (en) * | 2017-09-12 | 2019-03-19 | 华为技术有限公司 | A kind of method for processing business, mobile edge calculations equipment and the network equipment |
| CN109831507A (en) * | 2019-02-14 | 2019-05-31 | 上海联寓智能科技有限公司 | Internet of Things system, load balancing method and storage medium |
| CN112380002A (en) * | 2020-11-02 | 2021-02-19 | 中国联合网络通信集团有限公司 | Online education learning implementation method and platform |
| CN112448992A (en) * | 2019-09-02 | 2021-03-05 | 北京国双科技有限公司 | Edge computing task scheduling method and device |
-
2021
- 2021-10-26 CN CN202111245154.3A patent/CN113992715B/en active Active
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107295110A (en) * | 2017-08-16 | 2017-10-24 | 网宿科技股份有限公司 | Processing method, fringe node, service server and the system of calculating task |
| CN109495929A (en) * | 2017-09-12 | 2019-03-19 | 华为技术有限公司 | A kind of method for processing business, mobile edge calculations equipment and the network equipment |
| CN109831507A (en) * | 2019-02-14 | 2019-05-31 | 上海联寓智能科技有限公司 | Internet of Things system, load balancing method and storage medium |
| CN112448992A (en) * | 2019-09-02 | 2021-03-05 | 北京国双科技有限公司 | Edge computing task scheduling method and device |
| CN112380002A (en) * | 2020-11-02 | 2021-02-19 | 中国联合网络通信集团有限公司 | Online education learning implementation method and platform |
Also Published As
| Publication number | Publication date |
|---|---|
| CN113992715A (en) | 2022-01-28 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN110929880A (en) | Method and device for federated learning and computer readable storage medium | |
| CN111966289B (en) | Partition optimization method and system based on Kafka cluster | |
| CN116915827A (en) | Data transmission method and device of internet of things edge gateway, electronic equipment and medium | |
| CN113992715B (en) | Online state cloud monitoring and edge computing device and method | |
| CN117978888A (en) | Gateway and data transmission method using same | |
| US10802931B1 (en) | Management of shadowing for devices | |
| CN111698287A (en) | Cloud mobile phone active application acquisition method, system and storage medium | |
| CN116860699A (en) | File management method, system, computer device and computer readable storage medium | |
| CN116841645A (en) | Database flow processing method and system for database audit | |
| CN107066373B (en) | Control processing method and device | |
| CN116980495A (en) | Data conversion method, device, computer equipment, medium and product | |
| CN112381492B (en) | Temperature data processing method and device, electronic equipment and storage medium | |
| CN109831335A (en) | A kind of data monitoring method, monitor terminal, storage medium and data monitoring system | |
| CN116132625A (en) | Supervision method and device for transaction flow | |
| CN110213196A (en) | Equipment and its method, electronic equipment and the storage medium for preventing Replay Attack | |
| CN108984614B (en) | Visual image rapid identification method based on big data environment | |
| CN113190347A (en) | Edge cloud system and task management method | |
| CN112866083A (en) | Message sending method, electronic equipment and communication system | |
| CN111049671A (en) | System integration method and device | |
| CN111586069A (en) | Internet of things equipment management and data chaining method based on block chain technology | |
| CN112929361A (en) | Device authentication method, access node and computer readable storage medium | |
| CN112783959B (en) | Data transmission method and device based on heterogeneous storage systems | |
| CN115412588B (en) | Method and device for remotely updating configuration file and electronic equipment | |
| CN112073231B (en) | Local area network linkage protection method, device, computer equipment and storage medium | |
| CN113904953B (en) | Offline detection method, device and equipment for communication equipment |
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 |