CN113850288B - Internet of things cooperative data processing and storing method and system - Google Patents
Internet of things cooperative data processing and storing method and system Download PDFInfo
- Publication number
- CN113850288B CN113850288B CN202110903089.2A CN202110903089A CN113850288B CN 113850288 B CN113850288 B CN 113850288B CN 202110903089 A CN202110903089 A CN 202110903089A CN 113850288 B CN113850288 B CN 113850288B
- Authority
- CN
- China
- Prior art keywords
- data
- stored
- internet
- storage
- things
- 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
- 238000000034 method Methods 0.000 title claims abstract description 28
- 230000006835 compression Effects 0.000 claims abstract description 42
- 238000007906 compression Methods 0.000 claims abstract description 42
- 230000029058 respiratory gaseous exchange Effects 0.000 claims description 26
- 229910002056 binary alloy Inorganic materials 0.000 claims description 7
- 238000000605 extraction Methods 0.000 claims description 6
- 239000011159 matrix material Substances 0.000 claims description 6
- 230000006855 networking Effects 0.000 claims 1
- 230000006870 function Effects 0.000 description 26
- 238000010586 diagram Methods 0.000 description 9
- 238000004590 computer program Methods 0.000 description 5
- 238000012986 modification Methods 0.000 description 3
- 230000004048 modification Effects 0.000 description 3
- 238000004364 calculation method Methods 0.000 description 2
- 230000000694 effects Effects 0.000 description 2
- 238000012544 monitoring process Methods 0.000 description 2
- 230000003044 adaptive effect Effects 0.000 description 1
- 238000013500 data storage Methods 0.000 description 1
- 238000007726 management method Methods 0.000 description 1
- 238000004519 manufacturing process Methods 0.000 description 1
- 239000012466 permeate Substances 0.000 description 1
- 238000003672 processing method Methods 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F18/00—Pattern recognition
- G06F18/20—Analysing
- G06F18/24—Classification techniques
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F18/00—Pattern recognition
- G06F18/20—Analysing
- G06F18/23—Clustering techniques
-
- H—ELECTRICITY
- H03—ELECTRONIC CIRCUITRY
- H03M—CODING; DECODING; CODE CONVERSION IN GENERAL
- H03M7/00—Conversion of a code where information is represented by a given sequence or number of digits to a code where the same, similar or subset of information is represented by a different sequence or number of digits
- H03M7/30—Compression; Expansion; Suppression of unnecessary data, e.g. redundancy reduction
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/10—Protocols in which an application is distributed across nodes in the network
- H04L67/1097—Protocols in which an application is distributed across nodes in the network for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS]
-
- 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)
- Data Mining & Analysis (AREA)
- Theoretical Computer Science (AREA)
- General Engineering & Computer Science (AREA)
- Life Sciences & Earth Sciences (AREA)
- Bioinformatics & Computational Biology (AREA)
- Computer Vision & Pattern Recognition (AREA)
- Evolutionary Biology (AREA)
- Evolutionary Computation (AREA)
- Physics & Mathematics (AREA)
- Artificial Intelligence (AREA)
- General Physics & Mathematics (AREA)
- Bioinformatics & Cheminformatics (AREA)
- Signal Processing (AREA)
- Computer Networks & Wireless Communication (AREA)
- General Health & Medical Sciences (AREA)
- Medical Informatics (AREA)
- Computing Systems (AREA)
- Health & Medical Sciences (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
The embodiment of the invention discloses a cooperative data processing and storing method and system for the Internet of things, and belongs to the technical field of the Internet of things. The method comprises the following steps: classifying the received data to be stored according to the data frame header of the data to be stored to obtain the classification of the data to be stored; acquiring the residual size of storage space corresponding to various classifications in a database of the Internet of things; the database of the Internet of things comprises pre-divided storage spaces corresponding to various classifications; obtaining a first compression multiple according to the residual size of a storage space corresponding to the classification of the data to be stored and the total residual size of the database of the Internet of things; and compressing the data to be stored according to a first compression multiple and then storing the data to be stored in a storage space corresponding to the classification to which the data to be stored belongs. The invention can effectively improve the data processing and storing performance of the Internet of things.
Description
Technical Field
The invention belongs to the technical field of Internet of things, and particularly relates to a method and a system for processing and storing cooperative data of the Internet of things.
Background
The Internet of Things (Internet of Things, IOT) connects all articles with the Internet through information sensing equipment to exchange information, that is, the articles have interest, so as to realize intelligent identification and management and help people to advance to more intelligent and convenient future society. At present, the internet of things is widely applied to various fields, the internet of things is slowly changed into the internet of everything in the world, and the internet of things equipment gradually permeates into a plurality of daily equipment such as refrigerators and vending machines from early mobile phones, desktop computers and notebook computers.
With the rapid increase of the number of the devices of the internet of things and the increasing diversification of the devices of the internet of things, the data required to be stored in the internet of things becomes huge, the data types are more and more, and huge challenges are created on the data processing and storage performance of the internet of things. In order to meet the challenge, the existing data processing and storing scheme of the internet of things only increases the computing and storing capacity of the internet of things, but the increasing of the computing and storing capacity of the internet of things is ceiling-mounted, and brings a huge increase of the operation cost, and the existing data processing and storing scheme of the internet of things cannot effectively process data in a coordinated manner, so that the data processing and storing performance cannot be effectively improved, and even the data processing and storing performance is reduced.
Disclosure of Invention
In view of this, embodiments of the present invention provide a method and a system for processing and storing cooperative data of the internet of things, so as to solve the problem that the data processing and storing performance of the internet of things cannot be efficiently improved in the current data processing and storing scheme of the internet of things. The data processing method and the data processing device can classify the data received by the Internet of things, then compress different types of data to different degrees and store the data, and effectively improve the data processing and storing performance of the Internet of things.
In a first aspect, an embodiment of the present invention provides an internet of things collaborative data processing and storage method, including the following steps:
classifying the received data to be stored according to the data frame header of the data to be stored to obtain the classification of the data to be stored;
acquiring the residual size of storage space corresponding to various classifications in a database of the Internet of things; the database of the Internet of things comprises pre-divided storage spaces corresponding to various classifications;
obtaining a first compression multiple according to the residual size of a storage space corresponding to the classification of the data to be stored and the total residual size of the database of the Internet of things;
and compressing the data to be stored according to a first compression multiple and then storing the data to be stored in a storage space corresponding to the classification to which the data to be stored belongs.
In an optional embodiment, the compressing the data to be stored according to the first compression multiple and then storing the compressed data in the storage space corresponding to the classification to which the data to be stored belongs further includes:
timing storage time from the beginning of storage;
judging whether the storage time exceeds a preset time threshold in real time;
and if the storage time exceeds a preset time threshold, prompting a user to upload the data to be stored again.
In an optional embodiment, the classifying the received data to be stored according to a data frame header of the data to be stored includes:
classifying the data to be stored according to the following formula:
b represents that the category of the data to be stored is a category B; (W) 1 W 2 … W n ) Representing a binary number group corresponding to the data to be stored; n is the total number of binary numbers in the binary number group corresponding to the data to be stored;
representing a preset frame header extraction matrix; SUM [ alpha ]]For a summation function, the pair of brackets [ alpha ], [ alpha ] is]Summing all binary numbers of the inner array; δ () is a unit impulse function, the function value being 1 when the value in the unit impulse function bracket is equal to 0, and the function value being 0 when the value in the unit impulse function bracket is not equal to 0; r a A binary summation value of the data frame header corresponding to the preset a-th classification is obtained; a is 1,2, …, a; a is the total number of data classification in the database of the Internet of things.
In an optional embodiment, in the frame header extraction matrix, C 1 ＝C 2 ＝C 3 ＝C 4 1, and the remaining elements have values of 0.
In an optional embodiment, the obtaining a first compression multiple according to the remaining size of the storage space corresponding to the class to which the data to be stored belongs and the total remaining size of the database of the internet of things includes:
calculating a first compression factor according to the following formula:
wherein k represents a first compression multiple corresponding to the data to be stored; m is B Representing the number of the binary systems which can be stored in the residual space of the storage space corresponding to the classification to which the data to be stored belongs; m is a Representing the number of the binary systems which can be stored in the residual space of the storage space corresponding to the a-th classification;
and representing the number of the binary systems which can be stored in the total residual space of the database of the Internet of things.
In an optional embodiment, the counting the storage time from the beginning of the storage includes: timing the storage time of the data to be stored through the flashing times of a breathing lamp with known initial flashing frequency;
if the storage time exceeds a preset time threshold, prompting a user to upload the data to be stored again, wherein the steps comprise: and if the storage time exceeds a preset time threshold, prompting the user to upload the data to be stored again by controlling the flashing frequency of the breathing lamp.
In an alternative embodiment, the flashing frequency of the breathing light is controlled according to the following formula:
wherein f represents a flicker control frequency of the breathing lamp; f. of 0 Representing an initial flashing frequency of the breathing light; t represents the predetermined time threshold; d represents the flash times of the breathing lamp from the storage of the data to be stored; u () is a step function, and when the value in the step function bracket is 0 or more, the function value is 1, and when the value in the step function bracket is less than 0, the function value is 0.
In a second aspect, an embodiment of the present invention provides an internet of things collaborative data processing and storage system, including:
the classification module is used for classifying the received data to be stored according to the data frame header of the data to be stored to obtain the classification of the data to be stored;
the obtaining module is used for obtaining the residual size of the storage space corresponding to each classification in the database of the Internet of things; the database of the Internet of things comprises pre-divided storage spaces corresponding to various classifications;
the computing module is used for obtaining a first compression multiple according to the residual size of the storage space corresponding to the classification of the data to be stored and the total residual size of the database of the Internet of things;
and the compression storage module is used for compressing the data to be stored according to a first compression multiple and then storing the compressed data in the classified corresponding storage space to which the data to be stored belongs.
In an optional embodiment, the compressed storage module includes:
the compression unit is used for compressing the data to be stored according to a first compression multiple;
the storage unit is used for storing the compressed data to be stored in the storage space corresponding to the classification to which the data to be stored belongs;
the timing unit is used for timing storage time from the beginning of storage in the storage unit;
the judging unit is used for judging whether the storage time exceeds a preset time threshold value in real time;
and the prompting unit is used for prompting the user to upload the data to be stored again when the judgment result of the judging unit is yes.
In an optional embodiment, the prompting unit is specifically configured to prompt the user to upload the data to be stored again by controlling a flashing frequency of the breathing lamp.
The invention provides a novel Internet of things collaborative data processing and storage scheme, which comprises the steps of classifying data to be stored according to data frame headers of the data to be stored, then obtaining the residual sizes of storage spaces corresponding to various classifications in a database of the Internet of things, then obtaining compression multiples according to the residual sizes of the storage spaces corresponding to the classifications of the data to be stored and the total residual size of the database of the Internet of things, finally compressing the data to be stored according to the compression multiples and storing the compressed data in the storage spaces corresponding to the classifications of the data to be stored, processing and storing the data in a collaborative mode, and effectively improving the data processing and storage performance of the Internet of things.
Drawings
In order to more clearly illustrate the embodiments of the present invention or the technical solutions in the prior art, the drawings used in the description of the embodiments or the prior art will be briefly described below, it is obvious that the drawings in the following description are only some embodiments of the present invention, and for those skilled in the art, other drawings can be obtained according to the drawings without creative efforts.
Fig. 1 is a flowchart of a cooperative data processing and storing method for the internet of things according to an embodiment of the present invention;
FIG. 2 is a flow chart of a method of monitoring and prompting storage time;
fig. 3 is a schematic structural diagram of a cooperative data processing and storage system of the internet of things according to an embodiment of the present invention.
Detailed Description
Embodiments of the present invention will be described in detail below with reference to the accompanying drawings.
It should be understood that the described embodiments are only some embodiments of the invention, and not all embodiments. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present invention.
Fig. 1 is a flowchart of a cooperative data processing and storing method for the internet of things according to an embodiment of the present invention. Referring to fig. 1, the method comprises the steps of:
s101: and classifying the received data to be stored according to the data frame header of the data to be stored to obtain the classification of the data to be stored.
Preferably, the data to be stored can be classified according to the following formula (1):
b represents that the data to be stored belongs to the category of the category B; (W) 1 W 2 … W n ) Representing a binary array corresponding to the data to be stored; n is the total number of binary numbers in the binary number array corresponding to the data to be stored;
representing a preset frame header extraction matrix; SUM [ alpha ]]For a summation function, the pair of brackets [ alpha ], [ alpha ] is]Summing all binary numbers of the inner array; δ () is a unit impulse function, the function value being 1 when the value in the unit impulse function bracket is equal to 0, and the function value being 0 when the value in the unit impulse function bracket is not equal to 0; r a A binary summation value of a data frame header corresponding to a preset a-th classification is obtained; a is 1,2, …, a; a is the total number of data classification in the database of the Internet of things.
Preferably, in the frame header extraction matrix, C 1 ＝C 2 ＝C 3 ＝C 4 And if the value of the other elements is 1, extracting a head of a first four-digit binary number in the binary number group corresponding to the data to be stored. For example: assuming that the binary array corresponding to the data to be stored is (101100), n is 6, and if a is 4, the binary summation values of the data frame headers corresponding to the preset classifications are: r is 1 ＝1，R 2 ＝2，R 3 ＝3，R 4 4; then it is possible to obtain from equation (1),
and obtaining the classification of the data to be stored as the 3 rd classification.
Obviously, other numbers of frame headers may be used as required, for example, the first 5 bits or the first 6 bits of the binary array corresponding to the stored data are extracted, as long as it is ensured that R is preset a Are also based on the sameThe method is calculated, and is not described herein again.
S102: acquiring the residual size of storage space corresponding to various classifications in a database of the Internet of things;
in this embodiment, before S101 is implemented, data classification types are predefined, and the database of the internet of things is pre-divided into storage spaces corresponding to various classifications, the sizes of the storage spaces corresponding to different classifications may be the same or different, and the sizes of the corresponding storage spaces are specifically set according to the data types, so as to facilitate adaptive storage of different types of data with different sizes.
In this embodiment, the remaining size of the storage space corresponding to each category in the database needs to be obtained, which is convenient for the subsequent calculation of what degree of compression should be performed on the data to be stored, so as to ensure that the data can be normally stored.
S103: and obtaining a first compression multiple according to the residual size of the storage space corresponding to the classification of the data to be stored and the total residual size of the database of the Internet of things.
In this embodiment, according to the result of the classification to which the data to be stored belongs, the data is compressed in different degrees according to the size of the current corresponding storage space, so that the compression quality of different data is improved according to the storage space, when the storage space is sufficient, the data can be considered not to be compressed, and when the storage space is insufficient, a higher compression ratio is adopted, and the data is stored with the highest quality.
Preferably, the first compression factor may be calculated according to the following equation (2):
wherein k represents a first compression multiple corresponding to the data to be stored; m is a unit of B Representing the storable binary number of the residual space of the storage space corresponding to the classification of the data to be stored; m is a Representing the number of the binary systems which can be stored in the residual space of the storage space corresponding to the a-th classification;
and representing the storable binary number of the total residual space of the database of the Internet of things.
For example: let B be 3, n be 6, m 1 ＝100，m 2 ＝200，m 3 ＝300，m 4 400, then
Therefore, if the value is greater than 6, k is 1.
S104: and compressing the data to be stored according to a first compression multiple and then storing the data to be stored in a storage space corresponding to the classification to which the data to be stored belongs.
In an optional embodiment, as shown in fig. 2, step S104 may further include a step of monitoring and prompting the storage time, which specifically includes steps S201 to S203:
s201: the storage time is counted from the beginning of the storage.
In this embodiment, after the data to be stored is compressed according to the first compression multiple, the compressed data to be stored starts to be stored in the storage space corresponding to the classification to which the data to be stored belongs in the database, and timing starts from the time of starting storage until the time of finishing storage, so as to obtain the storage time consumed for storing the data this time.
Preferably, the storage time of the data to be stored may be timed by the number of blinks of a breathing light of a known initial blink frequency.
S202: and judging whether the storage time exceeds a preset time threshold in real time, if so, executing the step S203.
In this embodiment, in the data storage process, it is determined in real time and in real time whether the currently timed storage time exceeds the predetermined time threshold, if yes, step S230 is executed, otherwise, the storage, timing and determination are continued.
S203: and prompting the user to upload the data to be stored again.
In this embodiment, when the storage time exceeds a predetermined time threshold, that is, the storage time is out, the user may be prompted to upload the data to be stored again. In an optional embodiment, the user may be prompted to upload the data to be stored again by controlling the flashing frequency of the breathing lamp.
Preferably, the flashing frequency of the breathing lamp is controlled according to the following equation (3):
wherein f represents a flicker control frequency of the breathing lamp; f. of 0 Representing an initial flashing frequency of the breathing light; t represents the predetermined time threshold; d represents the flash times of the breathing lamp from the storage of the data to be stored; u () is a step function, and when the value in the step function bracket is 0 or more, the function value is 1, and when the value in the step function bracket is less than 0, the function value is 0.
Suppose, the initial flicker frequency f of the breathing lamp 0 5 times/s, the number of blinks D of the breathing lamp up to now is 20 from the storage of the data to be stored, the predetermined time threshold T is 3s, which is then available according to equation (3),
at the moment, the data to be stored is stored overtime, the breathing lamp does not flicker any more, the user is reminded of the storage failure in a normally-on mode, and the data to be stored needs to be uploaded again.
The method for processing and storing the collaborative data of the Internet of things comprises the steps of classifying data to be stored according to data frame headers of the data, then obtaining residual sizes of storage spaces corresponding to various classifications in a database of the Internet of things, then obtaining compression multiples according to the residual sizes of the storage spaces corresponding to the classifications to which the data to be stored belong and the total residual size of the database of the Internet of things, finally compressing the data to be stored according to the compression multiples, storing the compressed data in the storage spaces corresponding to the classifications to which the data to be stored belong, and controlling a breathing lamp to normally light to remind a user of storage failure when the data to be stored fails to be stored, wherein the data to be stored needs to be uploaded again. The data processing and storage method has the advantages that the data are processed and stored by selecting a proper processing mode according to the data classification result, so that multi-channel data processing is realized, the efficiency of storing different types of data by a user through the Internet of things is improved, and the data are rapidly processed and stored.
Corresponding to the method for processing and storing the cooperative data of the internet of things provided by the embodiment of the present invention, the embodiment of the present invention further provides a system for processing and storing the cooperative data of the internet of things, as shown in fig. 3, the system includes:
the classification module 1 is configured to classify the received data to be stored according to a data frame header of the data to be stored, so as to obtain a classification to which the data to be stored belongs;
the obtaining module 2 is used for obtaining the residual size of the storage space corresponding to each classification in the database of the Internet of things; the database of the Internet of things comprises storage spaces which are divided in advance and correspond to various classifications;
the calculation module 3 is used for obtaining a first compression multiple according to the residual size of the storage space corresponding to the classification to which the data to be stored belongs and the total residual size of the database of the internet of things;
and the compression storage module 4 is used for compressing the data to be stored according to a first compression multiple and then storing the data to be stored in the storage space corresponding to the classification to which the data to be stored belongs.
The system provided in this embodiment may be used to implement the technical solution of the method embodiment shown in fig. 1, and the implementation principle and the technical effect are similar, which are not described herein again.
In an optional embodiment, the classification module 1 is specifically configured to obtain a classification to which the data to be stored belongs according to the foregoing formula (1).
In an optional embodiment, the calculating module 3 is specifically configured to calculate to obtain the first compression multiple according to the remaining size of the storage space corresponding to the class to which the data to be stored belongs, the total remaining size of the database of the internet of things, and the foregoing formula (2).
In an alternative embodiment, the compressed storage module 4 may include:
the compression unit is used for compressing the data to be stored according to a first compression multiple;
the storage unit is used for storing the compressed data to be stored into the classified corresponding storage space of the data to be stored;
a timing unit for timing the storage time from the start of the storage in the storage unit;
the judging unit is used for judging whether the storage time exceeds a preset time threshold value in real time;
and the prompting unit is used for prompting the user to upload the data to be stored again when the judgment result of the judging unit is yes.
In an optional embodiment, the prompting unit is specifically configured to prompt the user to upload the data to be stored again by controlling a flashing frequency of the breathing lamp. Preferably, the prompting unit can control the flashing frequency of the breathing lamp according to the above formula (3).
The implementation principle and technical effect of the internet of things cooperative data processing and storing system provided by the embodiment of the invention are similar to those of the internet of things cooperative data processing and storing method in the foregoing embodiment, and are not described herein again.
The present invention has been described with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems), and computer program products according to embodiments of the invention. It will be understood that each flow and/or block of the flow diagrams and/or block diagrams, and combinations of flows and/or blocks in the flow diagrams and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to a processor of a general purpose computer, special purpose computer, embedded processor, or other programmable data processing apparatus to produce a machine, such that the instructions, which execute via the processor of the computer or other programmable data processing apparatus, create means for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be stored in a computer-readable memory that can direct a computer or other programmable data processing apparatus to function in a particular manner, such that the instructions stored in the computer-readable memory produce an article of manufacture including instruction means which implement the function specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions 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 flow or flows and/or block diagram block or blocks.
It will be apparent to those skilled in the art that various changes and modifications may be made in the present invention without departing from the spirit and scope of the invention. Thus, if such modifications and variations of the present invention fall within the scope of the claims of the present invention and their equivalents, the present invention is also intended to include such modifications and variations. The above description is only for the specific embodiment of the present invention, but the scope of the present invention is not limited thereto, and any changes or substitutions that can be easily conceived by those skilled in the art within the technical scope of the present invention are included in the scope of the present invention. Therefore, the protection scope of the present invention shall be subject to the protection scope of the claims.
Claims (10)
1. The cooperative data processing and storing method for the Internet of things is characterized by comprising the following steps:
classifying the received data to be stored according to the data frame header of the data to be stored to obtain the classification of the data to be stored;
acquiring the residual size of storage space corresponding to various classifications in a database of the Internet of things; the database of the Internet of things comprises pre-divided storage spaces corresponding to various classifications;
obtaining a first compression multiple according to the residual size of the storage space corresponding to the classification of the data to be stored and the total residual size of the database of the Internet of things;
and compressing the data to be stored according to a first compression multiple and then storing the data to be stored in a storage space corresponding to the classification to which the data to be stored belongs.
2. The internet-of-things cooperative data processing and storing method as claimed in claim 1, wherein the step of compressing the data to be stored according to a first compression multiple and then storing the compressed data in a storage space corresponding to the class to which the data to be stored belongs further comprises the steps of:
timing storage time from the beginning of storage;
judging whether the storage time exceeds a preset time threshold in real time;
and if the storage time exceeds a preset time threshold, prompting a user to upload the data to be stored again.
3. The internet of things cooperative data processing and storing method as claimed in claim 1, wherein the classifying the received data to be stored according to the data frame header of the data to be stored comprises:
classifying the data to be stored according to the following formula:
wherein,
indicates that the data to be stored belongs to the classification of the firstBClassifying the seeds;
representing a binary number group corresponding to the data to be stored;nthe total number of binary numbers in the binary number group corresponding to the data to be stored is obtained;
representing a preset frame header extraction matrix;SUM[ ]for a summation function, the pair of brackets]Inner array of columnsThere are binary numbers to sum;
is a unit impulse function, the function value is 1 when the value in the unit impulse function bracket is equal to 0, and the function value is 0 when the value in the unit impulse function bracket is not equal to 0;R a is a preset secondaThe binary summation value of the data frame header corresponding to the classification is classified;a=1,2,…,A；Aand classifying and counting the total number of the data in the database of the Internet of things.
4. The Internet of things cooperative data processing and storage method according to claim 3, wherein the frame header extraction matrix,C 1 =C 2 =C 3 =C 4 =1, and the remaining element values are 0.
5. The method for processing and storing cooperative data of the internet of things according to claim 3, wherein the obtaining a first compression multiple according to the remaining size of the storage space corresponding to the class to which the data to be stored belongs and the total remaining size of the database of the internet of things comprises:
calculating a first compression factor according to the following formula:
wherein,krepresenting a first compression multiple corresponding to the data to be stored;m B representing the number of the binary systems which can be stored in the residual space of the storage space corresponding to the classification to which the data to be stored belongs;m a is shown asaClassifying the number of the binary systems which can be stored in the residual space of the corresponding storage space;
binary system capable of storing total residual space of database representing Internet of thingsAnd (4) the number.
6. The internet of things cooperative data processing and storage method as claimed in claim 2, wherein the timing of storage time from the beginning of storage comprises: timing the storage time of the data to be stored through the flashing times of a breathing lamp with known initial flashing frequency;
if the storage time exceeds a preset time threshold, prompting a user to upload the data to be stored again, wherein the steps comprise: and if the storage time exceeds a preset time threshold, prompting the user to upload the data to be stored again by controlling the flashing frequency of the breathing lamp.
7. The internet of things cooperative data processing and storage method according to claim 6, wherein the flashing frequency of the breathing lamp is controlled according to the following formula:
wherein,findicating a flicker control frequency of the breathing light;f 0 representing an initial flashing frequency of the breathing light;Trepresenting the predetermined time threshold;Drepresenting the number of flashes of the breathing light since the storing of the data to be stored;u() The function value is 1 when the value in the step function bracket is more than or equal to 0, and the function value is 0 when the value in the step function bracket is less than 0.
8. Thing networking cooperative data processing and storage system, its characterized in that includes:
the classification module is used for classifying the received data to be stored according to the data frame header of the data to be stored to obtain the classification of the data to be stored;
the obtaining module is used for obtaining the residual size of the storage space corresponding to each category in the database of the Internet of things; the database of the Internet of things comprises storage spaces which are divided in advance and correspond to various classifications;
the computing module is used for obtaining a first compression multiple according to the residual size of the storage space corresponding to the classification of the data to be stored and the total residual size of the database of the Internet of things;
and the compression storage module is used for compressing the data to be stored according to a first compression multiple and then storing the compressed data in the classified corresponding storage space to which the data to be stored belongs.
9. The internet-of-things cooperative data processing and storage system of claim 8, wherein the compressed storage module comprises:
the compression unit is used for compressing the data to be stored according to a first compression multiple;
the storage unit is used for storing the compressed data to be stored in the storage space corresponding to the classification to which the data to be stored belongs;
the timing unit is used for timing storage time from the beginning of storage in the storage unit;
the judging unit is used for judging whether the storage time exceeds a preset time threshold value in real time;
and the prompting unit is used for prompting the user to upload the data to be stored again when the judgment result of the judging unit is yes.
10. The internet-of-things collaborative data processing and storage system according to claim 9, wherein the prompting unit is specifically configured to prompt the user to re-upload the post by controlling a flashing frequency of a breathing light
And the data to be stored.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110903089.2A CN113850288B (en) | 2021-08-06 | 2021-08-06 | Internet of things cooperative data processing and storing method and system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110903089.2A CN113850288B (en) | 2021-08-06 | 2021-08-06 | Internet of things cooperative data processing and storing method and system |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN113850288A CN113850288A (en) | 2021-12-28 |
| CN113850288B true CN113850288B (en) | 2022-08-19 |
Family
ID=78975610
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202110903089.2A Active CN113850288B (en) | 2021-08-06 | 2021-08-06 | Internet of things cooperative data processing and storing method and system |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN113850288B (en) |
Family Cites Families (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102929783B (en) * | 2012-10-25 | 2015-12-02 | 华为技术有限公司 | The methods, devices and systems that a kind of data store |
| GB2512276A (en) * | 2013-02-15 | 2014-10-01 | Univ Warwick | Multisensory data compression |
| US10303402B2 (en) * | 2016-08-02 | 2019-05-28 | Seagate Technology Llc | Data compression using partial statistics |
| CN111078755B (en) * | 2019-12-19 | 2023-07-28 | 远景智能国际私人投资有限公司 | Time sequence data storage query method and device, server and storage medium |
-
2021
- 2021-08-06 CN CN202110903089.2A patent/CN113850288B/en active Active
Also Published As
| Publication number | Publication date |
|---|---|
| CN113850288A (en) | 2021-12-28 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN109948669B (en) | Abnormal data detection method and device | |
| US20210125639A1 (en) | Method and system of clipping a video, computing device, and computer storage medium | |
| CN110620905A (en) | Video monitoring method and device, computer equipment and storage medium | |
| CN108711161A (en) | A kind of image partition method, image segmentation device and electronic equipment | |
| CN104144431B (en) | A kind of method, apparatus of mobile network's status predication and mobile network | |
| CN107491674A (en) | Feature based information carries out the method and device of user's checking | |
| CN111813624A (en) | Robot execution time length estimation method based on time length analysis and related equipment thereof | |
| CN112288025B (en) | Abnormal case identification method, device, equipment and storage medium based on tree structure | |
| CN110515951A (en) | A kind of BOM standardized method, system and electronic equipment and storage medium | |
| CN110109899B (en) | Internet of things data filling method, device and system | |
| CN103701934A (en) | Resource optimal scheduling method and virtual machine host machine optimal selection method | |
| CN109271957B (en) | Face gender identification method and device | |
| WO2022134828A1 (en) | Intelligent warehousing method and system based on picture recognition, and device and storage medium | |
| CN112835682B (en) | Data processing method, device, computer equipment and readable storage medium | |
| CN107437012A (en) | The guard method of data and device | |
| CN111651454B (en) | Data processing method and device and computer equipment | |
| CN106558305A (en) | voice data processing method and device | |
| CN110245696A (en) | Illegal incidents monitoring method, equipment and readable storage medium storing program for executing based on video | |
| CN106897282B (en) | User group classification method and device | |
| CN113850288B (en) | Internet of things cooperative data processing and storing method and system | |
| CN114612011A (en) | Risk prevention and control decision method and device | |
| CN117271100B (en) | Algorithm chip cluster scheduling method, device, computer equipment and storage medium | |
| CN105050103B (en) | A kind of recognition methods of signaling process and device | |
| CN111860287A (en) | Target detection method and device and storage medium | |
| CN110634018A (en) | Feature depiction method, recognition method and related device for lost user |
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 |