CN119561821A - Internet of Things data management method, device, server and storage medium - Google Patents
Internet of Things data management method, device, server and storage medium Download PDFInfo
- Publication number
- CN119561821A CN119561821A CN202411734452.2A CN202411734452A CN119561821A CN 119561821 A CN119561821 A CN 119561821A CN 202411734452 A CN202411734452 A CN 202411734452A CN 119561821 A CN119561821 A CN 119561821A
- Authority
- CN
- China
- Prior art keywords
- data
- internet
- things
- gateway
- object model
- 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.)
- Granted
Links
Classifications
-
- 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/22—Indexing; Data structures therefor; Storage structures
- G06F16/2282—Tablespace storage structures; Management thereof
-
- 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/24—Querying
- G06F16/245—Query processing
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/04—Network management architectures or arrangements
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/12—Discovery or management of network topologies
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/14—Network analysis or design
- H04L41/145—Network analysis or design involving simulating, designing, planning or modelling of a network
-
- 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
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
- H04L69/22—Parsing or analysis of headers
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L2212/00—Encapsulation of packets
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Theoretical Computer Science (AREA)
- Data Mining & Analysis (AREA)
- General Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- Physics & Mathematics (AREA)
- Databases & Information Systems (AREA)
- Health & Medical Sciences (AREA)
- Computational Linguistics (AREA)
- Medical Informatics (AREA)
- General Health & Medical Sciences (AREA)
- Computing Systems (AREA)
- Computer Security & Cryptography (AREA)
- Software Systems (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
The application provides a method, a device, a server and a storage medium for managing data of the Internet of things, relates to the technical field of the Internet of things, and solves the technical problem that the Internet of things cloud platform is difficult to effectively maintain and manage the data of the Internet of things equipment in the related art.
Description
Technical Field
The present application relates to the field of internet of things, and in particular, to a method, an apparatus, a server, and a storage medium for managing data of the internet of things.
Background
In the internet of things, the internet of things equipment is used as a data acquisition terminal, and the internet of things equipment is of a plurality of types (such as equipment types capable of being networked and incapable of being networked, and the like), so that the internet of things equipment is directly or indirectly connected with an internet of things cloud platform built on a server through gateway equipment, and the internet of things cloud platform is a platform which is convenient for a user to provide better management and operation equipment, and further provides a data basis for management and operation of the user by acquiring acquired data uploaded by the internet of things equipment, so that the user can realize the operations of accessing, controlling and the like of the internet of things equipment through the internet of things cloud platform.
When the internet of things devices connected under the same gateway are more and the data types are not uniform, the data stored by the internet of things cloud platform are disordered, so that the processing difficulty of the data is increased, the batch management of the devices is difficult to realize, and the maintenance and management of the internet of things devices are not facilitated. In addition, when the gateway switching situation of the internet of things equipment occurs, the user needs to correspondingly store and configure the data reported by the internet of things equipment again, so that the data of the equipment are more difficult to maintain and manage effectively.
Disclosure of Invention
The application provides a method, a device, a server and a storage medium for managing Internet of things data, which solve the technical problem that an Internet of things cloud platform is difficult to effectively maintain and manage the data of Internet of things equipment in the related technology.
In a first aspect, the present application provides an internet of things data management method, applied to a server, where the server is communicatively connected to a plurality of gateway devices, and each gateway device is communicatively connected to a plurality of internet of things devices, and the internet of things data management method includes:
Based on the gateway type corresponding to the connected gateway equipment, constructing a plurality of gateway object models, associating the gateway equipment corresponding to the same gateway type with the same gateway object model, wherein each gateway object model comprises a plurality of data event items, and each data event item is respectively associated with different data types;
Under the condition that the internet of things data uploaded by any internet of things device through the corresponding gateway device is received, determining a target gateway object model in the constructed gateway object model;
Acquiring field information carried by the data of the Internet of things, and determining the data type of the data of the Internet of things;
Determining whether to store the received internet of things data according to the data event items included in the target gateway object model and the data types of the internet of things data;
Under the condition that the received internet of things data is confirmed to be stored, the received internet of things data is stored in a database according to the mapping relation between field information carried by the internet of things data and data event items in the target gateway object model.
In a second aspect, the present application further provides an internet of things data management apparatus, applied to a server, where the server is communicatively connected to a plurality of gateway devices, and each gateway device is communicatively connected to a plurality of internet of things devices, and the internet of things data management apparatus includes:
The model construction module is configured to construct a plurality of gateway object models based on gateway types corresponding to the connected gateway equipment, and associate the gateway equipment corresponding to the same gateway type with the same gateway object model, wherein each gateway object model comprises a plurality of data event items, and each data event item is respectively associated with different data types;
The model selection module is configured to determine a target gateway object model in the constructed gateway object model under the condition that any one of the Internet of things devices receives Internet of things data uploaded by the corresponding gateway device;
The information acquisition module is configured to acquire field information carried by the data of the Internet of things and determine the data type of the data of the Internet of things;
the storage judging module is configured to determine whether to store the received internet of things data according to the data event items and the data types of the internet of things data included in the target gateway object model;
The data storage module is configured to store the received internet of things data in the database according to the mapping relation between the field information carried by the internet of things data and the data event items in the target gateway object model under the condition that the received internet of things data is determined to be stored.
In a third aspect, the present application also provides a server, the server comprising:
One or more processors;
Storage means for storing one or more programs,
When one or more programs are executed by one or more processors, the one or more processors are caused to implement the data management method of the internet of things of the present application.
In a fourth aspect, the present application also provides a storage medium storing computer-executable instructions that, when executed by a processor, are used to perform the internet of things data management method of the present application.
According to the method and the system for storing and managing the internet of things data, the gateway object model is used for storing and managing the internet of things data of different types, so that various types of internet of things devices in the internet of things cloud platform can be flexibly managed, the batch management of the internet of things devices by the internet of things cloud platform is effectively optimized, and the data of the internet of things devices can be conveniently maintained and the internet of things devices can be conveniently managed.
Drawings
Fig. 1 is a schematic diagram of steps of an internet of things data management method according to an embodiment of the present application;
fig. 2 is a schematic diagram of steps for storing internet of things data according to an embodiment of the present application;
FIG. 3 is a schematic diagram of a gateway object model of the present application;
fig. 4 is a schematic diagram of data interaction of an internet of things network according to an embodiment of the present application;
Fig. 5 is a schematic structural diagram of an internet of things data management device according to an embodiment of the present application;
Fig. 6 is a schematic structural diagram of a server according to an embodiment of the present application.
Detailed Description
Embodiments of the present application will be described in further detail below with reference to the drawings and examples. It should be understood that the particular embodiments described herein are illustrative only and are not limiting of embodiments of the application. It should be further noted that, for convenience of description, only some, but not all structures related to the embodiments of the present application are shown in the drawings, and those skilled in the art will appreciate that any combination of technical features may constitute alternative embodiments as long as the technical features are not contradictory to each other after reading the present specification.
The terms first, second and the like in the description and in the claims, are used for distinguishing between similar objects and not necessarily for describing a particular sequential or chronological order. It will be appreciated that the data so used may be interchanged where appropriate, such that embodiments of the application may be practiced otherwise than as specifically illustrated and described, and that the objects identified by "first," "second," etc. are generally of a type and are not limited to the number of objects, such as the first object may be one or more. Furthermore, in the description and claims, "and/or" means at least one of the connected objects, and the character "/" generally means a relationship in which the associated object is an "or" before and after. In the description of the present application, "a plurality" means two or more, and "a number" means one or more.
In the internet of things, the internet of things equipment is a basic unit in the internet of things, and can sense, collect, process and transmit data, namely the internet of things equipment is used as a data collection terminal, and the internet of things equipment can be directly or indirectly connected with an internet of things cloud platform built on a server through gateway equipment, namely the internet of things equipment uploads collected data, and the data are forwarded to the server through corresponding gateway equipment. The Internet of things cloud platform is a platform which is convenient for a user to provide better management and operation equipment, and further provides a data base for management and operation of the user by acquiring collected data uploaded by all the Internet of things equipment, so that the user can realize the operations such as access and control of the Internet of things equipment through the Internet of things cloud platform.
However, in the practical application process, the inventor finds that the number of the internet of things devices connected under the same gateway is large, and when the data types corresponding to the data collected by the internet of things devices are not uniform, for example, some of the internet of things devices collect data of the type of temperature, and other of the internet of things devices collect data of the type of humidity, the data stored by the internet of things cloud platform is disordered, so that the difficulty in processing the data is increased, batch management of the devices is difficult to realize, and maintenance and management of the internet of things devices are not facilitated. In addition, when the internet of things device switches another gateway device to be connected with the internet of things cloud platform through the gateway device, the internet of things cloud platform needs to store and configure data reported by the internet of things device again, and maintenance and management of the internet of things device are not facilitated.
In this regard, the application provides a data management method of the internet of things, which is applied to a server, and a corresponding cloud platform of the internet of things can be built on the server so as to provide functions of managing and operating equipment for users. In the internet of things network, the server is in communication connection with a plurality of gateway devices, and each gateway device is in communication connection with a plurality of internet of things devices, so that internet of things data collected by each internet of things device can be forwarded to the server through the gateway device connected with the internet of things device.
Fig. 1 is a schematic step diagram of an internet of things data management method according to an embodiment of the present application, where as shown in the drawing, the internet of things data uploaded by gateway devices of different gateway types are corresponding by constructing corresponding gateway object models in a server, and the internet of things data is classified and stored according to data event items constructed according to the data types, so that the internet of things data management is facilitated. The specific steps include steps S110-S150:
Step S110, based on the gateway type corresponding to the connected gateway equipment, constructing a plurality of gateway object models, associating the gateway equipment corresponding to the same gateway type with the same gateway object model, wherein each gateway object model comprises a plurality of data event items, and each data event item is respectively associated with different data types.
The object model is a data model used for describing product functions in an internet of things platform, and digitizes entities in a physical space and builds the data model at a cloud end. In the application, a plurality of gateway object models are built in the internet of things cloud platform built at the cloud (i.e. at the server side), the server builds the gateway object models based on the gateway types corresponding to the connected gateway equipment, i.e. the gateway types corresponding to the current connected gateway equipment are several, and correspondingly, a corresponding number of gateway object models are built, and it is conceivable that the server can determine the gateway equipment connected with the server and the gateway types thereof through the routing table thereon.
The gateway object model comprises a plurality of data event items, and each data event item is respectively associated with different data types, so that the internet of things data of one data type can be stored by the internet of things cloud platform through the data event item corresponding to the gateway object model. Based on this, gateway devices corresponding to the same gateway type are also associated with the same gateway object model, so as to store data uploaded by the gateway devices of the same gateway type through the same gateway object model. It should be appreciated that the above data types are parameter types corresponding to data, such as temperature, humidity, pressure, etc., and are not meant to refer to types on integer type, floating point type, etc. data.
Step S120, under the condition that the Internet of things data uploaded by any Internet of things device through the corresponding gateway device is received, determining a target gateway object model in the constructed gateway object model.
It can be understood that in a scenario that data transmission is completed between a server and an internet of things device through a gateway device in the internet of things network, when any internet of things device uploads internet of things data collected by the internet of things device, the internet of things device uploads the internet of things data to the server through the connected gateway device. Optionally, in an embodiment, the server and the internet of things device may communicate according to a preset communication protocol before uploading the internet of things data, for example, a format, a data type, etc. of the uploaded data are defined, so that the internet of things device can upload the corresponding internet of things data.
When the server receives the internet of things data, the server can determine a target gateway object model in the constructed gateway object model according to gateway equipment for forwarding the internet of things data, wherein the target gateway object model is associated with the gateway equipment for uploading the internet of things data.
In one embodiment, the server may determine, according to the routing table, the selection of the target gateway object model, and the specific steps include steps 121-S122:
Step S121, determining a target gateway device for forwarding the data of the Internet of things according to the routing table of the server.
Step S122, selecting a gateway object model associated with the target gateway equipment from the constructed gateway object models as a target gateway object model.
It will be appreciated that the gateway device acts as a device connecting different networks. In the process that a data packet carrying internet of things data is sent from a source device (i.e., an internet of things device) to a server, the data packet is forwarded through one or more gateway devices. Although the data packet itself does not directly record the field "from which gateway device", the server can determine it by the routing information in its routing table.
When the data packet arrives at the local area network where the server is located, it is forwarded in through the specific gateway device. The server can determine which network-wide data packets are forwarded through the gateway device by looking up its own routing table, thereby determining the corresponding gateway device. Optionally, in an embodiment, if the network where the server is located has a plurality of gateway devices for connecting to different network areas, the server may determine the gateway device according to the network range to which the source IP address of the data packet belongs, in combination with the routing table. Based on the above, the server may determine, as the target gateway object model, the gateway object model corresponding to the gateway device based on the association relationship between the gateway object model and the gateway device.
Therefore, the server can rapidly judge the gateway equipment forwarding the data of the Internet of things by utilizing the routing information in the routing table, so that the corresponding gateway object model can be rapidly locked, and the efficiency of storing the data of the Internet of things is improved.
Step S130, field information carried by the data of the Internet of things is obtained, and the data type of the data of the Internet of things is determined.
It is conceivable that in network transmission, for example, in a network layer, the internet of things data is transmitted in a packet encapsulation form, and in the process of encapsulating the internet of things data according to a communication protocol, the internet of things device may encapsulate the corresponding field information in the packet or the internet of things data, for example, encapsulate the field information in a position such as a head or a tail of a data portion. Optionally, in an embodiment, the information included in the field information may also be encapsulated separately, such as a form of encapsulating a part in the header and another part in the trailer.
The field information comprises data types, after the server receives the internet of things data, the server can acquire the internet of things data and the carried field information after analyzing the received data packet, and then the data types corresponding to the internet of things data can be determined.
Step S140, determining whether to store the received data of the Internet of things according to the data event items and the data types of the data of the Internet of things included in the target gateway object model.
In the gateway object model, each of the data event items is associated with a different data type. Therefore, after determining the data type corresponding to the internet of things data, the server can determine whether to store the internet of things data according to the data event item included in the target gateway object model and the data type of the internet of things data. It is conceivable that the internet of things data may be determined to be stored by comparing the data type corresponding to the internet of things data with the data type associated with each data event item in the target gateway object model, when the same data type exists.
Optionally, in an embodiment, the server may create a corresponding file (such as a document, a table, etc.) for the data types associated with the data event items included in each gateway object model, so as to record the data types associated with the data event items. After the internet of things data is received, whether the currently received internet of things data belongs to one of the data types recorded in the file is determined by inquiring the file, and further, when the same data type exists, the internet of things data is determined to be stored.
Step S150, under the condition that the received internet of things data is confirmed to be stored, storing the received internet of things data in a database according to the mapping relation between field information carried by the internet of things data and the data event items in the target gateway object model.
For this, when it is determined that the received data of the internet of things can be stored, the server needs to select a corresponding data event to store the data, for example, according to mapping relationships between field information carried by the data of the internet of things and data event items in the target gateway object model, it is conceivable that each data event item is respectively associated with a different data type in the gateway object model, for this purpose, a data event item corresponding to the data of the internet of things can be determined according to the data type, that is, the data type associated with the selected data event item is the same as the data type corresponding to the data of the internet of things, and further, the data of the internet of things is stored in the database according to the corresponding data event item.
According to the scheme, the server stores and manages different types of Internet of things data through the gateway object model, so that various types of Internet of things equipment in the Internet of things cloud platform can be flexibly managed, batch management of the Internet of things equipment by the Internet of things cloud platform is effectively optimized, and data of the Internet of things equipment can be conveniently maintained and the Internet of things equipment can be conveniently managed.
In an embodiment, for storing internet of things data, a server generates corresponding node data in a database to store the internet of things data, as shown in fig. 2, fig. 2 is a schematic diagram of steps for storing the internet of things data according to an embodiment of the present application, and specific steps are as follows:
Step S210, analyzing field information carried by the Internet of things data to determine the data type and the event name of the Internet of things data.
Step S220, determining a corresponding target data event item based on the association information of the data type and the data event item in the mapping relation.
Step S230, taking the Internet of things data as node data of the target data event item, and storing according to the event name.
It may be appreciated that the field information includes a data type and an event name, and after the server receives the data of the internet of things, by analyzing the field information carried by the data, it is conceivable that the server and the device of the internet of things may determine, through a communication protocol, a storage position, a format, etc. of the field information in the data packet, so that the server may obtain the corresponding field information when analyzing the data, and further determine the data type and the event name of the data of the internet of things from the corresponding field information.
And the server searches the data event item corresponding to the data type of the data of the Internet of things according to the association information of the data type and the data event item recorded in the mapping relation, and takes the data event item as a target data event item. And when the data is stored, the data of the Internet of things is used as node data of the target data event item, and the data is stored according to the event name. It is conceivable that there may be multiple node data under the same data event item, where each node data corresponds to one piece of data of the internet of things, and each node data is stored in the database according to an event name, for example, each piece of data may store an event_name field, where the event_name field is corresponding to the event name, and when the node data of the data event item is queried, the event_name field is queried to obtain a data list under the data event item.
The server determines that the data belongs to a temperature type after receiving the data of the internet of things, and further establishes node data under a data Event item of the data type associated with the temperature to store the temperature data uploaded by the internet of things device, and correspondingly, records a corresponding Event name in an event_name field of the data, for example, an event_temp_01 is identified.
Therefore, the server can select the data event item corresponding to the data in the gateway object model through analyzing the field information, so that batch management of the Internet of things cloud platform to the Internet of things equipment is optimized, and maintenance and management of the Internet of things equipment and the data thereof are more convenient.
In some embodiments, for the case that the internet of things device switches the content of the collected data, for example, the data type of the data collected by the internet of things device changes, for example, the internet of things device is a temperature and humidity detector, the temperature and humidity detector is used for acquiring data of two data types, if the internet of things device only uploads data of the temperature type at first, then the reported data is changed, for example, the data of the temperature type initially uploaded is changed into data of the humidity type uploaded. For this, the server needs to restore it in the database.
It is conceivable that, in an embodiment, when the server stores data uploaded by one internet of things device, the server may record relevant information of the internet of things device, such as a device ID (Identity document, account number), an IP (Internet Protocol ) address, a data type, etc., so that after receiving the internet of things data, the server may determine whether the data type of the data uploaded by the internet of things device is changed according to the record.
When the server determines that the data type corresponding to the Internet of things data uploaded by the same Internet of things device changes, the server analyzes the currently received Internet of things data to obtain corresponding field information, and further determines the data type corresponding to the Internet of things data after the data type changes and the event name according to the field information. In this regard, the server also re-searches for another target data event item, which is associated with the changed data type of the internet of things data, and further adds a new node data to the target data event item, and stores the internet of things data according to the re-determined event name. It may be conceivable that in some embodiments, if node data corresponding to the type-changed internet of things data exists in the target gateway object model, the received internet of things data is stored with the node data.
Therefore, when the Internet of things equipment switches the content of the acquired data, a user does not need to operate on the Internet of things cloud platform, and the server can perform configuration storage on the acquired Internet of things data again, so that batch management of the Internet of things cloud platform on the Internet of things equipment is facilitated to be optimized.
In an embodiment, when the network has the problems of fluctuation, failure and the like, the internet of things device may switch another gateway device to upload the internet of things data, and in this case, after receiving the internet of things data uploaded by the internet of things device, the server needs to query the gateway device forwarding the internet of things data, for example, by adopting the scheme of querying the routing table in the embodiment, so as to determine whether the gateway device forwarding the data changes this time. Further, under the condition that the gateway equipment is switched by the Internet of things equipment, the server searches a gateway object model corresponding to the gateway type in the constructed gateway object model according to the gateway type corresponding to the switched gateway equipment so as to redetermine the target gateway object model.
If the target gateway object model related to the switched gateway equipment does not exist in the constructed gateway object model, the internet of things data is temporarily stored, the server can discard the internet of things data, and the server automatically takes the previously uploaded data as historical data. If the constructed gateway object model has the target gateway object model associated with the switched gateway equipment, node data are newly added under the corresponding data event item in the target gateway object model so as to store the data of the Internet of things.
Therefore, when the condition that the gateway is switched by the Internet of things equipment occurs, the Internet of things cloud platform can automatically process the data without a user for storage configuration, so that the data of the Internet of things equipment can be conveniently maintained and the Internet of things equipment can be conveniently managed.
It should be noted that, in some embodiments, for the case that the gateway device is switched by the internet of things device, the server searches for a gateway object model corresponding to the gateway type in the constructed gateway object model according to the gateway type corresponding to the switched gateway device. It is conceivable that, in the case that the two gateway devices before and after the switching belong to the same gateway type, the target gateway object model selected by the server is unchanged, and the target gateway object model is determined again as the gateway object model adopted before the switching.
In some embodiments, when data management is performed through the internet of things cloud platform, the server may respond to a query request of a user, for example, a query request for internet of things data, and after receiving the query request, the server parses the query request to obtain a corresponding event name. Optionally, in an embodiment, when the terminal device queries the internet of things data of an internet of things device, for example, queries the temperature data collected by the device, for this reason, the server may parse the query request to obtain corresponding keywords, such as temperature, device ID, etc., so that the server correspondingly determines the Event name according to the keywords, for example, the corresponding Event name is event_temp_01, where TEMP corresponds to the temperature, and 01 corresponds to the internet of things device.
After the event name is obtained, the server adds the event name in the query condition, so that the target field corresponding to the stored node data can be conveniently searched in the database according to the query condition. It is conceivable that the target field is used to record an event name corresponding to the internet of things data in the stored node data. Further, the server extracts the node data matched with the query condition and feeds the node data back to the initiating terminal of the query request. In this way, the server can respond to the query request initiated by the user, so that the node data matched with the query request is fed back, and a convenient data management scheme of the Internet of things equipment is provided.
Fig. 3 is a schematic diagram of a model topology of a gateway object model according to the present application, where corresponding data event items in the gateway object model are divided into DataEvent01, dataEvent02, and DataEvent03, and each data event item is configured with corresponding node data (such as data1 and data2 in the figure). Fig. 4 is a schematic diagram of data interaction of an internet of things network according to an embodiment of the present application, where as shown in the drawing, an internet of things device E1 transmits internet of things data to a server S1 through a gateway device G1, and the internet of things device E1 transmits the internet of things data to the server S1 through the gateway device G1.
For example, referring to fig. 3 and fig. 4, an internet of things cloud platform is built in the server, and the internet of things cloud platform is provided with corresponding gateway object models corresponding to gateway devices of different gateway types. When the internet of things device E1 reports internet of things data, the internet of things data is transmitted to a server through the gateway device E1, for example, the internet of things device E1 is a device for collecting temperature data, the uploaded internet of things data is a collected temperature value, if a data event item DataEvent01 is a data event item of a type corresponding to temperature, correspondingly, node data (such as data1 and data2 in the figure) is added under the data event item, and the added node data is reported temperature data. Also, when data is stored, a corresponding Event name is recorded in an event_name field of the data, for example, the Event name identifying the data is performed with event_temp_01 to indicate that the data is data of a type corresponding to temperature.
Fig. 5 is a schematic structural diagram of an internet of things data management device according to an embodiment of the present application, where the device is configured to execute the internet of things data management method according to the foregoing embodiment, and has functional modules and beneficial effects corresponding to the execution method. The device is applied to a server, the server is in communication connection with a plurality of gateway devices, and each gateway device is in communication connection with a plurality of Internet of things devices. As shown in the figure, the data management device of the internet of things comprises a model construction module 501, a model selection module 502, an information acquisition module 503, a storage determination module 504 and a data storage module 505.
The model building module 501 is configured to build a plurality of gateway object models based on gateway types corresponding to the connected gateway devices, and associate the gateway devices corresponding to the same gateway type with the same gateway object model, where each gateway object model includes a plurality of data event items, and each data event item is respectively associated with a different data type;
the model selection module 502 is configured to determine a target gateway object model in the constructed gateway object model under the condition that any one of the internet of things devices receives internet of things data uploaded by the corresponding gateway device;
The information obtaining module 503 is configured to obtain field information carried by the data of the internet of things, and determine a data type of the data of the internet of things;
the storage determination module 504 is configured to determine whether to store the received internet of things data according to the data event item included in the target gateway object model and the data type of the internet of things data;
the data storage module 505 is configured to store the received internet of things data in the database according to the mapping relationship between the field information carried by the internet of things data and the data event item in the target gateway object model, under the condition that the received internet of things data is determined to be stored.
Based on the above embodiment, the model selection module 502 is specifically configured to:
Determining target gateway equipment for forwarding the data of the Internet of things according to a routing table of the server;
And selecting a gateway object model associated with the target gateway equipment from the constructed gateway object models as a target gateway object model.
On the basis of the above embodiment, the field information includes a data type and an event name, and the data storage module 505 is specifically configured to:
analyzing field information carried by the data of the Internet of things to determine the data type and the event name of the data of the Internet of things;
determining a corresponding target data event item based on the association information of the data type and the data event item in the mapping relation;
And taking the data of the Internet of things as node data of the target data event item, and storing according to the event name.
On the basis of the above embodiment, the data storage module 505 is further configured to:
When determining that the data type corresponding to the Internet of things data uploaded by the same Internet of things device changes, re-determining the data type and event name corresponding to the Internet of things data based on field information carried by the Internet of things data after the data type changes;
and taking the Internet of things data as newly added node data in another target data event item of the target gateway object model, and storing the Internet of things data according to the redetermined event name.
On the basis of the above embodiment, the data management device of the internet of things further includes a model reselection module configured to:
under the condition that the gateway equipment is switched by the Internet of things equipment, a target gateway object model is redetermined according to the gateway type corresponding to the switched gateway equipment;
if the constructed gateway object model does not have the target gateway object model associated with the gateway equipment after switching, temporarily storing the Internet of things data, and taking the Internet of things data uploaded before the gateway equipment is switched by the Internet of things equipment as historical data;
If the constructed gateway object model has the target gateway object model associated with the switched gateway equipment, node data are newly added under the corresponding data event item in the target gateway object model so as to store the data of the Internet of things.
On the basis of the above embodiment, the model reselection module is further configured to:
if the two gateway devices before and after the switching of the Internet of things device belong to the same gateway type, the target gateway object model is determined again to be the gateway object model adopted before the switching.
On the basis of the above embodiment, the data management device of the internet of things further includes a data query module configured to:
responding to a query request of the data of the Internet of things, analyzing the query request to obtain event names, and adding the event names in query conditions;
Searching a target field corresponding to the stored node data according to the query condition, so as to feed the node data matched with the query condition back to the initiating terminal of the query request, wherein the target field is used for recording an event name corresponding to the data of the Internet of things.
It should be noted that, in the embodiment of the apparatus, the included modules are only divided according to the functional logic, but not limited to the above-mentioned division, as long as the corresponding functions can be implemented, and the specific names of the modules are only for convenience of distinguishing each other, and are not used for limiting the protection scope of the embodiment of the present application.
Fig. 6 is a schematic structural diagram of a server according to an embodiment of the present application, where the device is configured to execute the data management method of the internet of things according to the foregoing embodiment, and has corresponding functional modules and beneficial effects of the execution method. As shown, the server includes a processor 601, a memory 602, an input device 603, and an output device 604. The number of processors 601 may be one or more, one processor 601 being illustrated in the figures, and the processors 601, memory 602, input devices 603 and output devices 604 may be connected by a bus or other means, illustrated in the figures as a bus connection. The memory 602 is used as a computer readable storage medium, and may be used to store a software program, a computer executable program, and modules, such as program instructions/modules corresponding to the data management method of the internet of things in the embodiment of the present application. The processor 601 executes corresponding various functional applications and data processing by running software programs, instructions and modules stored in the memory 602, i.e. implements the data management method of the internet of things described above.
The memory 602 may mainly include a storage program area that may store an operating system, an application program required for at least one function, and a storage data area that may store data recorded or created according to a use process, etc. In addition, the memory 602 may include high-speed random access memory, and may also include non-volatile memory, such as at least one magnetic disk storage device, flash memory device, or other non-volatile solid-state storage device. In some embodiments, the memory 602 may further include remotely located memory relative to the processor 601, which may be connected to the device via a network. Examples of such networks include, but are not limited to, the internet, intranets, local area networks, mobile communication networks, and combinations thereof.
The input means 603 may be used for inputting corresponding numerical or character information to the processor 601 and generating key signal inputs related to user settings and function controls of the device, and the output means 604 may be used for transmitting or displaying key signal outputs related to user settings and function controls of the device.
The embodiment of the application also provides a storage medium storing computer executable instructions which, when executed by a processor, are used for executing relevant operations in the data management method of the internet of things provided by any embodiment of the application.
Computer-readable storage media, including both permanent and non-permanent, removable and non-removable media, may be implemented in any method or technology for storage of information. 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 Disks (DVD) or other optical storage, magnetic cassettes, 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.
It should also be noted that the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or apparatus that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or apparatus. Without further limitation, an element defined by the phrase "comprising one does not exclude the presence of other like elements in a process, method, article, or apparatus that comprises an element.
Note that the above is only a preferred embodiment of the present application and the technical principle applied. It will be understood by those skilled in the art that the present application is not limited to the particular embodiments described herein, but is capable of various obvious changes, rearrangements and substitutions as will now become apparent to those skilled in the art without departing from the scope of the application. Therefore, while the application has been described in connection with the above embodiments, the application is not limited to the embodiments, but may be embodied in many other equivalent forms without departing from the spirit or scope of the application, which is set forth in the following claims.
Claims (10)
1. The data management method of the Internet of things is characterized by being applied to a server, wherein the server is in communication connection with a plurality of gateway devices, each gateway device is in communication connection with a plurality of Internet of things devices, and the data management method of the Internet of things comprises the following steps:
constructing a plurality of gateway object models based on gateway types corresponding to connected gateway equipment, associating the gateway equipment corresponding to the same gateway type with the same gateway object model, wherein each gateway object model comprises a plurality of data event items, and each data event item is respectively associated with different data types;
Under the condition that any Internet of things data uploaded by the Internet of things equipment through the corresponding gateway equipment is received, determining a target gateway object model in the constructed gateway object model;
Acquiring field information carried by the data of the Internet of things, and determining the data type of the data of the Internet of things;
determining whether to store the received internet of things data according to the data event items included in the target gateway object model and the data types of the internet of things data;
and under the condition that the received internet of things data is confirmed to be stored, storing the received internet of things data in a database according to the mapping relation between the field information carried by the internet of things data and the data event items in the target gateway object model.
2. The method for managing internet of things data according to claim 1, wherein determining the target gateway object model in the constructed gateway object model when receiving the internet of things data uploaded by any one of the internet of things devices through the corresponding gateway device comprises:
Determining a target gateway device for forwarding the data of the Internet of things according to the routing table of the server;
And selecting a gateway object model associated with the target gateway equipment from the constructed gateway object models as the target gateway object model.
3. The internet of things data management method according to claim 1, wherein the field information includes a data type and an event name;
Under the condition that the received internet of things data is confirmed to be stored, storing the received internet of things data in a database according to the field information carried by the internet of things data and the mapping relation of the data event items in the target gateway object model, wherein the method comprises the following steps:
Analyzing field information carried by the data of the Internet of things to determine the data type and the event name of the data of the Internet of things;
Determining a corresponding target data event item based on the association information of the data type and the data event item in the mapping relation;
and taking the Internet of things data as node data of the target data event item, and storing according to the event name.
4. The method for managing data of internet of things according to claim 3, wherein in the case of determining to store the received data of internet of things, storing the received data of internet of things in a database according to the mapping relationship between the field information carried by the data of internet of things and the data event item in the object gateway object model, further comprising:
When determining that the data type corresponding to the Internet of things data uploaded by the same Internet of things device changes, re-determining the data type and event name corresponding to the Internet of things data based on field information carried by the Internet of things data after the data type changes;
and taking the Internet of things data as newly added node data in another target data event item of the target gateway object model, and storing the Internet of things data according to the redetermined event name.
5. The method for managing internet of things data according to claim 1, wherein before determining whether to store the received internet of things data according to the data event item included in the target gateway object model and the data type of the internet of things data, the method further comprises:
under the condition that the gateway equipment is switched by the Internet of things equipment, a target gateway object model is redetermined according to the gateway type corresponding to the switched gateway equipment;
If the constructed gateway object model does not have the target gateway object model associated with the gateway equipment after switching, temporarily storing the internet of things data, and taking the internet of things data uploaded before the gateway equipment is switched by the internet of things equipment as historical data;
If the constructed gateway object model has a target gateway object model associated with the switched gateway equipment, node data are newly added under a corresponding data event item in the target gateway object model to store the data of the Internet of things.
6. The method for managing data of internet of things according to claim 5, wherein if a target gateway object model associated with the switched gateway device exists in the constructed gateway object model, adding node data under a data event item corresponding to the target gateway object model to store the data of internet of things, comprises:
If the two gateway devices before and after the switching of the Internet of things device belong to the same gateway type, the target gateway object model is determined again to be the gateway object model adopted before the switching.
7. The method for managing data of the internet of things according to claim 1, 3 or 4, wherein in the case of determining to store the received data of the internet of things, according to the mapping relationship between the field information carried by the data of the internet of things and the data event item in the object gateway object model, after storing the received data of the internet of things in the database, the method further comprises:
responding to a query request of the internet of things data, analyzing the query request to obtain an event name, and adding the event name into a query condition;
Searching a target field corresponding to the stored node data according to the query condition, so as to feed the node data matched with the query condition back to the initiating terminal of the query request, wherein the target field is used for recording an event name corresponding to the data of the Internet of things.
8. The utility model provides an thing networking data management device, its characterized in that is applied to the server, the server is connected with a plurality of gateway equipment communication, and every gateway equipment is connected with a plurality of thing networking equipment communication, thing networking data management device includes:
The model construction module is configured to construct a plurality of gateway object models based on gateway types corresponding to the connected gateway equipment, and associate the gateway equipment corresponding to the same gateway type with the same gateway object model, wherein each gateway object model comprises a plurality of data event items, and each data event item is respectively associated with different data types;
the model selection module is configured to determine a target gateway object model in the constructed gateway object model under the condition that any one of the Internet of things devices receives Internet of things data uploaded by the corresponding gateway device;
the information acquisition module is configured to acquire field information carried by the Internet of things data and determine the data type of the Internet of things data;
The storage judging module is configured to determine whether to store the received internet of things data according to the data event items included in the target gateway object model and the data types of the internet of things data;
And the data storage module is configured to store the received internet of things data in a database according to the mapping relation between the field information carried by the internet of things data and the data event items in the target gateway object model under the condition of determining to store the received internet of things data.
9. A server for a server, which comprises a server and a server, characterized by comprising the following steps:
One or more processors;
storage means for storing one or more programs that, when executed by the one or more processors, cause the one or more processors to implement the internet of things data management method of any of claims 1-7.
10. A storage medium storing computer executable instructions which, when executed by a processor, are for performing the internet of things data management method of any one of claims 1-7.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202411734452.2A CN119561821B (en) | 2024-11-29 | 2024-11-29 | Internet of Things (IoT) data management methods, devices, servers, and storage media |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202411734452.2A CN119561821B (en) | 2024-11-29 | 2024-11-29 | Internet of Things (IoT) data management methods, devices, servers, and storage media |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN119561821A true CN119561821A (en) | 2025-03-04 |
| CN119561821B CN119561821B (en) | 2025-11-14 |
Family
ID=94766085
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202411734452.2A Active CN119561821B (en) | 2024-11-29 | 2024-11-29 | Internet of Things (IoT) data management methods, devices, servers, and storage media |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN119561821B (en) |
Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20020035574A1 (en) * | 2000-09-04 | 2002-03-21 | Jean-Baptiste Dumas | Apparatus and method for exporting data from a database to a data processing terminal |
| CN113609130A (en) * | 2021-07-30 | 2021-11-05 | 中电金信软件有限公司 | Method and device for acquiring gateway access data, electronic equipment and storage medium |
| CN114448802A (en) * | 2022-01-28 | 2022-05-06 | 北京百度网讯科技有限公司 | Gateway configuration method and device, electronic equipment and storage medium |
| CN117950591A (en) * | 2024-01-18 | 2024-04-30 | 北京微控工业网关技术有限公司 | Gateway storage management method and device, electronic device, and storage medium |
-
2024
- 2024-11-29 CN CN202411734452.2A patent/CN119561821B/en active Active
Patent Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20020035574A1 (en) * | 2000-09-04 | 2002-03-21 | Jean-Baptiste Dumas | Apparatus and method for exporting data from a database to a data processing terminal |
| CN113609130A (en) * | 2021-07-30 | 2021-11-05 | 中电金信软件有限公司 | Method and device for acquiring gateway access data, electronic equipment and storage medium |
| CN114448802A (en) * | 2022-01-28 | 2022-05-06 | 北京百度网讯科技有限公司 | Gateway configuration method and device, electronic equipment and storage medium |
| CN117950591A (en) * | 2024-01-18 | 2024-04-30 | 北京微控工业网关技术有限公司 | Gateway storage management method and device, electronic device, and storage medium |
Also Published As
| Publication number | Publication date |
|---|---|
| CN119561821B (en) | 2025-11-14 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN101902505B (en) | A real-time statistical device and method for distributed DNS query logs | |
| US12261741B2 (en) | Server to support client data models from heterogeneous data sources | |
| CN107231262B (en) | A message routing method based on MQTT multi-layer concatenation | |
| CN112436964B (en) | Equipment adaptation method and network management device | |
| US20110099226A1 (en) | Method of requesting for location information of resources on network, user node and server for the same | |
| CN107844274B (en) | Hardware resource management method, device and terminal based on super-fusion storage system | |
| CN110032602A (en) | A kind of storage of product information, inquiry and management system and method | |
| CN108322393B (en) | Routing link management method and system, virtual routing gateway and host machine gateway | |
| JP2016518641A (en) | Access to multiple converged infrastructure systems | |
| CN104378233B (en) | Equipment Explore of Unified Management Ideas, include method and related device | |
| CN108574627B (en) | A kind of SDN network multi-control domain collaborative management method and system | |
| CN108206788B (en) | A kind of traffic identification method and related equipment | |
| CN119561821B (en) | Internet of Things (IoT) data management methods, devices, servers, and storage media | |
| JP5091217B2 (en) | Home device information collecting apparatus and home device information collecting method | |
| CN118316816B (en) | Network device management method, device, computer device and storage medium | |
| CN113301173A (en) | Domain name updating system and method, message forwarding method and server | |
| KR20140125223A (en) | Method for collecting information with management interface in contents network based on information centric networking, content network management system, and node apparatus | |
| JP2006020157A (en) | Node information collection device | |
| CN115865844B (en) | Dynamic traffic scheduling method and device based on virtual and real combination based on SDN and NDN | |
| KR20130042446A (en) | Method and apparatus for providing information for sensor network | |
| CN116436749A (en) | Simple network management protocol data analysis method, device, equipment and medium | |
| JP7107047B2 (en) | Control system, search device and search program | |
| CN102394946A (en) | Addressing method for sensing service application oriented wireless sensor network | |
| WO2019123832A1 (en) | Terminal management device and terminal device | |
| WO2017206634A1 (en) | Method and device for querying semantics |
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 |