Nothing Special   »   [go: up one dir, main page]

CN113660119B - Internet of things terminal state data tracing method and system thereof - Google Patents

Internet of things terminal state data tracing method and system thereof Download PDF

Info

Publication number
CN113660119B
CN113660119B CN202110926442.9A CN202110926442A CN113660119B CN 113660119 B CN113660119 B CN 113660119B CN 202110926442 A CN202110926442 A CN 202110926442A CN 113660119 B CN113660119 B CN 113660119B
Authority
CN
China
Prior art keywords
data
abnormal data
internet
abnormal
storage queue
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
Application number
CN202110926442.9A
Other languages
Chinese (zh)
Other versions
CN113660119A (en
Inventor
徐培龙
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
CHONGQING HEHANG TECHNOLOGY CO LTD
Original Assignee
CHONGQING HEHANG TECHNOLOGY CO LTD
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by CHONGQING HEHANG TECHNOLOGY CO LTD filed Critical CHONGQING HEHANG TECHNOLOGY CO LTD
Priority to CN202110926442.9A priority Critical patent/CN113660119B/en
Publication of CN113660119A publication Critical patent/CN113660119A/en
Application granted granted Critical
Publication of CN113660119B publication Critical patent/CN113660119B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Classifications

    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L41/00Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
    • H04L41/06Management of faults, events, alarms or notifications
    • H04L41/0631Management of faults, events, alarms or notifications using root cause analysis; using analysis of correlation between notifications, alarms or events based on decision criteria, e.g. hierarchy, tree or time analysis
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L43/00Arrangements for monitoring or testing data switching networks
    • H04L43/08Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters
    • H04L43/0805Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters by checking availability
    • H04L43/0817Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters by checking availability by checking functioning
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L43/00Arrangements for monitoring or testing data switching networks
    • H04L43/10Active monitoring, e.g. heartbeat, ping or trace-route
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00Traffic control in data switching networks
    • H04L47/50Queue scheduling
    • H04L47/62Queue scheduling characterised by scheduling criteria
    • H04L47/6245Modifications to standard FIFO or LIFO
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/01Protocols
    • H04L67/12Protocols 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)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Health & Medical Sciences (AREA)
  • General Health & Medical Sciences (AREA)
  • Cardiology (AREA)
  • Environmental & Geological Engineering (AREA)
  • Computing Systems (AREA)
  • Medical Informatics (AREA)
  • Maintenance And Management Of Digital Transmission (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)

Abstract

The method for tracing the state data of the terminal of the Internet of things comprises the steps of obtaining real-time state data of the terminal of the Internet of things, judging whether the real-time state data of the terminal of the Internet of things is abnormal or not, if yes, extracting N real-time state data of the terminal of the Internet of things before and after the abnormal data to form an abnormal data packet and storing the abnormal data packet, extracting mark information when the abnormal data packet is stored, correspondingly storing the mark information and the abnormal data to form a query data packet, inquiring and calling the abnormal data packet according to information contained in the query data packet when the abnormal data packet is called, accurately obtaining the abnormal data of the terminal of the Internet of things and the state data before and after the abnormal data when the abnormal data of the terminal of the Internet of things occurs, providing data support for key data or sensitive data analysis of an Internet of things system, and effectively reducing consumption caused by mass data to network resources and storage resources, and improving efficiency of data transmission and storage and subsequent data tracing.

Description

Internet of things terminal state data tracing method and system thereof
Technical Field
The invention relates to the field of Internet of things, in particular to a method and a system for tracing state data of an Internet of things terminal.
Background
With the rise of the internet of everything, more and more urban infrastructure, factory machine equipment, traffic facilities and household articles are organically connected together through the internet of things system, and remote monitoring and management are realized according to the professional classification. After the controlled object has abnormal state or accident, the user is concerned about the abnormal state data or the monitoring data before and after the accident, and the abnormal state or accident is used as the analysis basis.
In the prior art, for analysis of abnormal states or accidents, all data of the terminal of the internet of things are uploaded to a data center in real time, and after the abnormal states or accidents occur to a controlled object, a user queries the data before and after the time point according to the time point of the abnormal states or accidents to analyze, so that the traceability function of the monitoring data of the internet of things is realized. However, the method has the following defects that huge loss is caused to network resources and storage resources because massive monitoring data of the Internet of things are uploaded to the data center, great burden is caused to storage, arrangement and analysis because a large amount of monitoring data of the Internet of things which is not critical or sensitive is uploaded to the data center, and great inconvenience is caused to the tracing of abnormal state or accident data of a controlled object by a user.
Therefore, in order to solve the above-mentioned technical problems, a new technical means is needed.
Disclosure of Invention
In view of the above, the present invention aims to provide a method and a system for tracing state data of an internet of things terminal, which can accurately obtain abnormal data of the internet of things terminal and state data before and after the abnormal data when the internet of things terminal is abnormal, provide accurate data support for key data or sensitive data analysis of the internet of things system, effectively reduce consumption caused by mass data to network resources and storage resources, and effectively improve efficiency of data transmission, storage and subsequent data tracing.
The invention provides a method for tracing state data of an Internet of things terminal, which comprises the following steps:
Acquiring real-time state data of an Internet of things terminal;
judging whether the real-time state data of the terminals of the Internet of things are abnormal or not, if so, extracting the real-time state data of the terminals of the N Internet of things before and after the abnormal data to form an abnormal data packet and storing the abnormal data packet;
Extracting the mark information when the abnormal data packet is stored, and correspondingly storing the mark information and the abnormal data to form a query data packet;
And when the abnormal data packet is called, inquiring and calling the abnormal data packet according to the information contained in the inquiring data packet.
Further, an exception packet is formed according to the following method:
storing the acquired real-time data of the terminal of the Internet of things into a first storage queue, wherein the first storage queue is provided with N real-time data storage spaces according to a first-in first-out principle when the first storage queue accesses the data;
when the real-time state data of the terminal of the Internet of things is abnormal, storing the current abnormal data into a first storage queue, and writing the real-time state data of the terminal of the Internet of things extruded by the abnormal data in the first storage queue into a second storage queue;
The real-time state data of the Internet of things terminal after the current abnormal data is written into a first storage queue, and the extruded real-time state data in the first storage queue is written into a second storage queue;
judging whether the current abnormal data is extruded out of the first storage queue, if so, writing the abnormal data into the second storage queue, and sequentially writing all data in the first storage queue when the current abnormal data is extruded out into the second storage queue and positioned behind the current abnormal data;
When the real-time state data of the internet of things terminal stored in the first storage queue when the current abnormal data is extruded is stored in the second storage queue, the current abnormal data in the second storage queue and the real-time state data of N internet of things terminals before and after the current abnormal data are formed into an abnormal data packet.
Further, the flag information at the time of storing the abnormal data packet is the first address and the last address of the abnormal data packet.
Further, the query packet and the exception packet are located in different store queues when stored.
Further, after the abnormal data packet is formed, the first address and the last address of the abnormal data packet are extracted, and the current abnormal data, the first address and the last address of the abnormal data packet are correspondingly stored in a third storage queue.
Correspondingly, the invention also provides a system for tracing the state data of the terminal of the Internet of things, which comprises a processor, a first memory and a second memory;
The processor is used for acquiring real-time state data of the terminal of the Internet of things, judging whether the real-time state data of the terminal of the Internet of things is abnormal or not, and outputting alarm information when the real-time state data of the terminal of the Internet of things is abnormal;
The processor stores real-time state data of the terminal of the Internet of things into a first memory and a second memory;
The first memory is used for storing real-time state data of the terminal of the Internet of things, which is acquired by the processor, and the first processor follows a first-in first-out principle when the first processor accesses the data;
The second memory is provided with a state data storage queue and an alarm data storage queue, when the real-time state data of the terminal of the Internet of things is abnormal, 2N real-time state data before and after the current abnormal data and the current abnormal data form an abnormal data packet, the abnormal data packet is stored in the state data storage queue, and the first address and the last address of the abnormal data packet and the current abnormal data form a query data packet and are stored in the alarm data storage queue.
Further, an exception packet is formed according to the following method:
the processor stores the acquired real-time data of the terminal of the Internet of things into a first storage queue, wherein the first storage queue is provided with N real-time data storage spaces according to a first-in first-out principle when the first storage queue accesses the data;
when the processor judges that the real-time state data of the terminal of the Internet of things is abnormal, the processor stores the current abnormal data into a first storage queue, and then writes the real-time state data of the terminal of the Internet of things extruded by the abnormal data in the first storage queue into a second storage queue;
The processor continues to write real-time state data of the Internet of things terminal after the current abnormal data into the first storage queue and writes the extruded real-time state data in the first storage queue into the second storage queue;
The processor judges whether the current abnormal data is extruded out of the first storage queue, if so, the abnormal data is written into the second storage queue, and all data in the first storage queue when the current abnormal data is extruded out are sequentially written into the second storage queue and are positioned behind the current abnormal data;
When the real-time state data of the internet of things terminal stored in the first storage queue when the current abnormal data is extruded is stored in the second storage queue, the current abnormal data in the second storage queue and the real-time state data of N internet of things terminals before and after the current abnormal data are formed into an abnormal data packet.
Further, the processor makes the call of the exception packet according to the following method:
The processor receives a calling instruction sent by the upper computer;
the processor searches a query data packet corresponding to the current calling instruction in an alarm data storage queue of the second memory according to the calling instruction, and analyzes the searched query data packet to obtain abnormal data information contained in the calling instruction and a head address and a tail address of the abnormal data packet corresponding to the abnormal information;
And the processor calls the abnormal data packet from the state data storage queue of the second memory according to the abnormal data information and the first address and the last address of the abnormal data packet.
Further, the device also comprises an input module and an output module;
The input module is in communication connection with the processor and is used for inputting real-time state data of the terminal of the Internet of things into the processor;
the output module is connected with the processor and used for transmitting the data of the processor to the upper computer.
The method and the system have the beneficial effects that when the terminal of the Internet of things is abnormal, the abnormal data of the terminal of the Internet of things and the state data before and after the abnormal data can be accurately obtained, accurate data support is provided for key data or sensitive data analysis of the system of the Internet of things, consumption caused by mass data to network resources and storage resources can be effectively reduced, and the efficiency of data transmission, storage and subsequent data tracing is effectively improved.
Drawings
The invention is further described below with reference to the accompanying drawings and examples:
FIG. 1 is a schematic flow chart of the present invention.
FIG. 2 is a schematic flow chart of the present invention.
Fig. 3 is a schematic diagram of a system structure according to the present invention.
FIG. 4 is a schematic diagram of a data storage system according to the present invention.
Detailed Description
The invention is described in further detail below with reference to the attached drawing figures:
The invention provides a method for tracing state data of an Internet of things terminal, which comprises the following steps:
Acquiring real-time state data of an Internet of things terminal;
judging whether the real-time state data of the terminals of the Internet of things are abnormal or not, if so, extracting the real-time state data of the terminals of the N Internet of things before and after the abnormal data to form an abnormal data packet and storing the abnormal data packet;
Extracting the mark information when the abnormal data packet is stored, and correspondingly storing the mark information and the abnormal data to form a query data packet;
By the method, when the Internet of things terminal is abnormal, abnormal data and state data before and after the abnormal data of the Internet of things terminal can be accurately obtained, accurate data support is provided for key data or sensitive data analysis of an Internet of things system, consumption caused by mass data to network resources and storage resources can be effectively reduced, and the efficiency of data transmission, storage and subsequent data tracing is effectively improved.
Specifically, the abnormal data packet is formed according to the following method:
storing the acquired real-time data of the terminal of the Internet of things into a first storage queue, wherein the first storage queue is provided with N real-time data storage spaces according to a first-in first-out principle when the first storage queue accesses the data;
when the real-time state data of the terminal of the Internet of things is abnormal, storing the current abnormal data into a first storage queue, and writing the real-time state data of the terminal of the Internet of things extruded by the abnormal data in the first storage queue into a second storage queue;
The real-time state data of the Internet of things terminal after the current abnormal data is written into a first storage queue, and the extruded real-time state data in the first storage queue is written into a second storage queue;
judging whether the current abnormal data is extruded out of the first storage queue, if so, writing the abnormal data into the second storage queue, and sequentially writing all data in the first storage queue when the current abnormal data is extruded out into the second storage queue and positioned behind the current abnormal data;
When the real-time state data of the internet of things terminal stored in the first storage queue when the current abnormal data is extruded is stored in the second storage queue, the current abnormal data in the second storage queue and the real-time state data of N internet of things terminals before and after the current abnormal data are formed into an abnormal data packet.
The mark information when the abnormal data packet is stored is the first address and the last address of the abnormal data packet, and of course, other mark information can be additionally arranged for distinguishing different abnormal data packets, so that the abnormal data packet is convenient to search.
The query packet and the exception packet are stored in different storage queues, that is:
And after the abnormal data packet is formed, extracting the head address and the tail address of the abnormal data packet, and correspondingly storing the current abnormal data, the head address and the tail address of the abnormal data packet in a third storage queue.
Further description is provided below in connection with fig. 4:
In fig. 4, the left sequence is a first storage queue, the middle sequence is a third storage queue, and the right sequence is a second storage queue;
When the real-time state data of the terminal of the Internet of things is acquired and then stored into a first storage queue, the access principle of the first storage queue is a first-in first-out principle, namely, firstly-obtained data is stored into the first storage queue firstly, later-obtained data is stored according to a sequence, N data can be stored in the first storage queue, and when the storage limit of the first storage queue is reached along with the data storage, the first-obtained data is extruded;
When judging that abnormal data (the abnormal data is data representing the state of the terminal of the Internet of things, such as oversized index, undersized index and the like represented by the data) exists at present, storing the abnormal data into a first storage queue at the moment, wherein the abnormal data is also the real-time state of the terminal of the Internet of things represented by the abnormal data; when the current abnormal data arrives, the first data is extruded, the first data extruded is stored into the second storage queue, when the first data extruded by the abnormal data is stored into the second storage queue, the first address of the first data when the first data is stored into the second storage queue is used as the first address of the current abnormal data packet, the real-time state data after the abnormal data is still stored in the first storage queue, as the data is written, the data is extruded in the first storage queue, the extruded data is sequentially stored into the second storage queue, when the abnormal state data is extruded into the first storage queue, at this time, the N data after the abnormal data occurs are all stored into the second storage queue (of course, the N data are sequentially written into the first storage queue and are extruded after the current abnormal data based on the subsequent data), the N data are all stored into the second storage queue as the current abnormal data, the N data are all stored into the second storage queue, the N data are finally stored into the current abnormal data are stored into the second storage queue, and finally the abnormal data are stored into the current storage queue, n data before and after the current abnormal data form an abnormal data packet, and then a complete tracing data packet is formed, when the current abnormal data needs to be called, a query data packet required by a calling instruction is obtained from a third storage queue according to the calling instruction, the query data packet is analyzed, corresponding abnormal data information, the head address and the tail address of the abnormal data packet are obtained, and the corresponding abnormal data packet, namely the tracing data packet, is searched from a second storage queue according to the analysis result of the query data packet. In the process, other non-abnormal data (or called sensitive data) does not need to be stored, network resources, storage resources and transmission efficiency are saved, and calling efficiency is also obviously improved. When the abnormal data is generated, the Internet of things system generates corresponding alarm information, so that the abnormal data is also called alarm data.
In the above example, it is described that one abnormal data occurs or that the two abnormal data occur at a longer interval (longer means that the normal real-time status data between two adjacent abnormal data is greater than N), then the following situations often occur in practical application:
1. The internet of things starts to run to generate abnormal data, namely the first storage queue is firstly reached to be the abnormal data, then the abnormal data is not stored before the abnormal data occurs, and the abnormal data is still completed according to the steps, except that only n+1 data exist in the current abnormal data packet, the abnormal data is marked as 0 before the abnormal data, and the first address of the abnormal data packet in the second storage queue is the first address of the current abnormal data stored in the second storage queue.
2. For example, A, B, C continuous abnormal data, when A is judged to be abnormal data, only A is treated as abnormal data, B and C are treated as normal data, when B is judged to be abnormal data after A is judged to be abnormal data, only B is treated as abnormal data, and the rest are treated as normal data, and the subsequent treatment process is completely consistent with the process in the above.
Correspondingly, the invention also provides a system for tracing the state data of the terminal of the Internet of things, which comprises a processor, a first memory and a second memory;
The processor is used for acquiring real-time state data of the terminal of the Internet of things, judging whether the real-time state data of the terminal of the Internet of things is abnormal or not, and outputting alarm information when the real-time state data of the terminal of the Internet of things is abnormal;
The processor stores real-time state data of the terminal of the Internet of things into a first memory and a second memory;
The first memory is used for storing real-time state data of the terminal of the Internet of things, which is acquired by the processor, and the first processor follows a first-in first-out principle when the first processor accesses the data;
The second memory is provided with a state data storage queue and an alarm data storage queue, when the real-time state data of the terminal of the Internet of things is abnormal, 2N real-time state data before and after the current abnormal data and the current abnormal data form an abnormal data packet, the abnormal data packet is stored in the state data storage queue, and the first address and the last address of the abnormal data packet and the current abnormal data form a query data packet and are stored in the alarm data storage queue. By the system, the abnormal data and the state data before and after the abnormal data of the terminal of the Internet of things can be accurately obtained when the terminal of the Internet of things is abnormal, accurate data support is provided for key data or sensitive data analysis of the system of the Internet of things, consumption caused by massive data to network resources and storage resources can be effectively reduced, and the efficiency of data transmission, storage and subsequent data tracing is effectively improved.
Specifically, the abnormal data packet is formed according to the following method:
the processor stores the acquired real-time data of the terminal of the Internet of things into a first storage queue, wherein the first storage queue is provided with N real-time data storage spaces according to a first-in first-out principle when the first storage queue accesses the data;
when the processor judges that the real-time state data of the terminal of the Internet of things is abnormal, the processor stores the current abnormal data into a first storage queue, and then writes the real-time state data of the terminal of the Internet of things extruded by the abnormal data in the first storage queue into a second storage queue;
The processor continues to write real-time state data of the Internet of things terminal after the current abnormal data into the first storage queue and writes the extruded real-time state data in the first storage queue into the second storage queue;
The processor judges whether the current abnormal data is extruded out of the first storage queue, if so, the abnormal data is written into the second storage queue, and all data in the first storage queue when the current abnormal data is extruded out are sequentially written into the second storage queue and are positioned behind the current abnormal data;
When the real-time state data of the internet of things terminal stored in the first storage queue when the current abnormal data is extruded is stored in the second storage queue, the current abnormal data in the second storage queue and the real-time state data of N internet of things terminals before and after the current abnormal data are formed into an abnormal data packet.
The calling of the abnormal data is carried out according to the following steps that the processor calls the abnormal data packet according to the following method:
The processor receives a calling instruction sent by the upper computer;
the processor searches a query data packet corresponding to the current calling instruction in an alarm data storage queue of the second memory according to the calling instruction, and analyzes the searched query data packet to obtain abnormal data information contained in the calling instruction and a head address and a tail address of the abnormal data packet corresponding to the abnormal information;
And the processor calls the abnormal data packet from the state data storage queue of the second memory according to the abnormal data information and the first address and the last address of the abnormal data packet.
Of course, the second memory can be replaced by two memories to realize the storage of state data and alarm data, or one memory can be used to replace the first memory and the second memory, if one memory is used, the first memory queue, the second memory queue and the third memory queue are all equivalent alternatives.
In this embodiment, the system further includes an input module and an output module, where the input module is communicatively connected to the processor and is configured to input real-time status data of the terminal of the internet of things into the processor.
The input module is a transmission interface.
The access module is a wireless transmission module.
The output module is connected with the processor and used for transmitting the data of the processor to the upper computer.
The output module is a transmission interface.
The output module is a wireless transmission module. The above transmission interface adopts existing interfaces, such as ethernet interface, optical fiber interface, etc., and the wireless transmission module adopts existing modules, such as bluetooth module, mobile communication module (such as 4G module, 5G module), UWB module, zigBee module, etc.
Finally, it is noted that the above embodiments are only for illustrating the technical solution of the present invention and not for limiting the same, and although the present invention has been described in detail with reference to the preferred embodiments, it should be understood by those skilled in the art that modifications and equivalents may be made thereto without departing from the spirit and scope of the technical solution of the present invention, which is intended to be covered by the scope of the claims of the present invention.

Claims (1)

1.一种物联网终端状态数据追溯方法,其特征在于:包括以下步骤:1. A method for tracing the status data of an Internet of Things terminal, characterized in that it comprises the following steps: 获取物联网终端实时状态数据;Obtain real-time status data of IoT terminals; 判断物联网终端实时状态数据是否存在异常,如是,提取异常数据前后各N个物联网终端实时状态数据形成异常数据包并对异常数据包进行存储;Determine whether there is an abnormality in the real-time status data of the IoT terminal. If so, extract the real-time status data of the N IoT terminals before and after the abnormal data to form an abnormal data packet and store the abnormal data packet; 提取异常数据包存储时的标志信息,将标志信息和异常数据进行对应存储形成查询数据包;其中:异常数据包存储时的标志信息为异常数据包的首地址和末地址;Extract the flag information when the abnormal data packet is stored, and store the flag information and the abnormal data in correspondence to form a query data packet; wherein: the flag information when the abnormal data packet is stored is the first address and the last address of the abnormal data packet; 调用异常数据包时,根据查询数据包所包含的信息进行异常数据包的查询和调用;When calling an abnormal data packet, query and call the abnormal data packet according to the information contained in the query data packet; 依据如下方法形成异常数据包:The abnormal data packet is formed according to the following method: 将获取的物联网终端实时数据存储至第一存储队列中,所述第一存储队列存取数据时依据先进先出原则且第一存储队列具有N个实时数据存储空间;The acquired real-time data of the Internet of Things terminal is stored in a first storage queue, wherein the first storage queue accesses data according to the first-in-first-out principle and the first storage queue has N real-time data storage spaces; 当物联网终端实时状态数据存在异常时,将当前异常数据存入第一存储队列中,再将第一存储队列中被异常数据挤出的物联网终端实时状态数据写入至第二存储队列中;When there is an abnormality in the real-time status data of the Internet of Things terminal, the current abnormal data is stored in the first storage queue, and then the real-time status data of the Internet of Things terminal squeezed out by the abnormal data in the first storage queue is written into the second storage queue; 继续当前异常数据之后的物联网终端实时状态数据写入第一存储队列以及将第一存储队列中被挤出的实时状态数据写入第二存储队列;Continue to write the real-time status data of the Internet of Things terminal after the current abnormal data into the first storage queue and write the real-time status data squeezed out of the first storage queue into the second storage queue; 判断当前异常数据是否被挤出第一存储队列,如是,则将异常数据写入第二存储队列,且第一存储队列中在当前异常数据被挤出时的所有数据依次写入至第二存储队列并位于当前异常数据之后;Determine whether the current abnormal data is squeezed out of the first storage queue. If so, write the abnormal data into the second storage queue, and all data in the first storage queue when the current abnormal data is squeezed out are sequentially written into the second storage queue and are located after the current abnormal data; 当第一存储队列中在当前异常数据被挤出时所存入的物联网终端实时状态数据存入第二存储队列后,则将第二存储队列中的当前异常数据以及当前异常数据前后N个物联网终端的实时状态数据形成异常数据包;When the real-time status data of the Internet of Things terminal stored in the first storage queue when the current abnormal data is squeezed out is stored in the second storage queue, the current abnormal data in the second storage queue and the real-time status data of the N Internet of Things terminals before and after the current abnormal data are formed into an abnormal data packet; 当异常数据包形成之后,提取异常数据包的首地址和末地址,并将当前异常数据、异常数据包的首地址和末地址对应存储于第三存储队列中;查询数据包和异常数据包在存储时位于不同的存储队列。After the abnormal data packet is formed, the first address and the last address of the abnormal data packet are extracted, and the current abnormal data, the first address and the last address of the abnormal data packet are correspondingly stored in the third storage queue; the query data packet and the abnormal data packet are located in different storage queues when stored.
CN202110926442.9A 2021-08-12 2021-08-12 Internet of things terminal state data tracing method and system thereof Active CN113660119B (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202110926442.9A CN113660119B (en) 2021-08-12 2021-08-12 Internet of things terminal state data tracing method and system thereof

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202110926442.9A CN113660119B (en) 2021-08-12 2021-08-12 Internet of things terminal state data tracing method and system thereof

Publications (2)

Publication Number Publication Date
CN113660119A CN113660119A (en) 2021-11-16
CN113660119B true CN113660119B (en) 2024-12-17

Family

ID=78491585

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202110926442.9A Active CN113660119B (en) 2021-08-12 2021-08-12 Internet of things terminal state data tracing method and system thereof

Country Status (1)

Country Link
CN (1) CN113660119B (en)

Citations (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN111768513A (en) * 2020-06-10 2020-10-13 奇瑞新能源汽车股份有限公司 Data recording and fault diagnosis method for bidirectional DCDC converter based on UDS
CN113123932A (en) * 2021-02-23 2021-07-16 北京华能新锐控制技术有限公司 Real-time dynamic fault diagnosis method for wind turbine generator

Family Cites Families (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN108301989B (en) * 2018-01-31 2019-11-15 湖南优利泰克自动化系统有限公司 A kind of Wind turbines failure logging method
JP7051755B2 (en) * 2019-06-25 2022-04-11 東芝三菱電機産業システム株式会社 Failure data recording system and failure data transmitter
CN113190415B (en) * 2021-05-27 2025-01-07 北京京东拓先科技有限公司 Internet hospital system monitoring method, equipment, storage medium and program product

Patent Citations (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN111768513A (en) * 2020-06-10 2020-10-13 奇瑞新能源汽车股份有限公司 Data recording and fault diagnosis method for bidirectional DCDC converter based on UDS
CN113123932A (en) * 2021-02-23 2021-07-16 北京华能新锐控制技术有限公司 Real-time dynamic fault diagnosis method for wind turbine generator

Also Published As

Publication number Publication date
CN113660119A (en) 2021-11-16

Similar Documents

Publication Publication Date Title
CN108920659A (en) Data processing system and its data processing method, computer readable storage medium
CN107241305B (en) Network protocol analysis system based on multi-core processor and analysis method thereof
CN103942210A (en) Processing method, device and system of mass log information
CN114448830B (en) Equipment detection system and method
CN110191024B (en) Network traffic monitoring method and device
CN111400361A (en) Data real-time storage method and device, computer equipment and storage medium
CN110069378A (en) Data monitoring method, device, terminal and computer readable storage medium
CN113157609A (en) Storage system, data processing method, data processing device, electronic device, and storage medium
CN113660119B (en) Internet of things terminal state data tracing method and system thereof
CN114157731B (en) FC-AE protocol analyzer based on FPH-trie tree and dynamic priority scheduling
CN110535972A (en) A kind of the coal gas detection equipment centralized management and communication system, equipment and readable storage medium storing program for executing of hardware and software platform
CN112905571B (en) Train rail transit sensor data management method and device
CN107645564B (en) CAN message analysis method and system based on data cache
CN107480063B (en) Method and system for dynamically scanning SQL (structured query language) statement, electronic equipment and storage medium
CN104615528A (en) Intelligent cell phone sensor data online collecting and real-time processing method
CN111211939A (en) Device and method for realizing efficient flow table counting based on network processor
CN117573473A (en) Operation and maintenance system, operation and maintenance method and corresponding equipment for equipment in electric power system machine room
CN103955192B (en) A kind of curve form data sampling method for sewage work
CN117573752A (en) Big data information statistics acquisition method and system
CN116431429A (en) Unified monitoring platform and monitoring method for middleware
CN214376003U (en) Processing system for processing industrial data based on edge calculation
CN112435151B (en) Government information data processing method and system based on association analysis
CN116069774A (en) Data cleaning method, device and medium based on wireless timeout intelligent analysis
CN112506871B (en) Automated task management and log management method, system, electronic device and medium
CN109726181B (en) Data processing method and data processing device

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