Intelligently distributed stage data mining system

• US 10,402,415 B2
• Filed: 07/10/2016
• Issued: 09/03/2019
• Est. Priority Date: 07/22/2015
• Status: Active Grant

• Current Assignee: Zhejiang Dafeng Industry Company Limited
• Original Assignee: Zhejiang Dafeng Industry Company Limited
• Inventors: Feng, Hua, Feng, Qiyun, Liu, Zhen, Tian, Haihong, Wang, Dong, Wu, Lifeng
• Primary Examiner(s): Nguyen, Phong H
• Application Number:
  US15/188,816
• Publication Number:
  US 20170140004A1
• Time in Patent Office: Days
• Field of Search: 707776
• CPC Class Codes: G06F 16/22 Indexing; Data structures therefor; Storage structures
• CPC Class Codes: G06F 16/2465 Query processing support for facilitating data mining operations in structured databases
• CPC Class Codes: H04L 2101/659 Internet protocol version 6 [IPv6] addresses
• CPC Class Codes: H04W 4/80 Services using short range communication, e.g. near-field communication [NFC], radio-frequency identification [RFID] or low energy communication
• CPC Class Codes: H04W 84/12 WLAN [Wireless Local Area Networks]

Abstract

An intelligently distributed stage data mining system is disclosed herein, including an intelligent central server, a first WLAN receiving and transmitting unit, a local cluster control unit, a second WLAN receiving and transmitting unit, a third WLAN receiving and transmitting unit, a self-adaptive multi-dimensional transmission processing unit, a plurality of ZigBee receiving and transmitting units and a distributed data extraction unit. The intelligent central server is used for sending data acquisition and stage correction instruction to the local cluster control unit, and for receiving the stage real-time data uploaded by the self-adaptive multi-dimensional transmission processing unit. The local cluster control unit is used for receiving the data acquisition instruction sent by the intelligent central server, and forwarding instructions to the self-adaptive multi-dimensional transmission processing unit.

Claims

1. An intelligently distributed stage data mining system comprising at least one processor coupled to a memory comprising:

an intelligent central server,

a first wireless local area network (WLAN) receiving and transmitting unit,

a local cluster control unit,

a second WLAN receiving and transmitting unit,

a third WLAN receiving and transmitting unit,

a self-adaptive multi-dimensional transmission processing unit,

a plurality of high-level communication protocol (ZigBee) receiving and transmitting units, and

a distributed data extraction unit;

wherein the intelligent central server is used for sending data acquisition instruction and stage correction instruction to the local cluster control unit, and receiving the stage real-time data uploaded by the self-adaptive multi-dimensional transmission processing unit;

the local cluster control unit is used for receiving the data acquisition instruction sent by the intelligent central server, and forwarding instruction to the self-adaptive multi-dimensional transmission processing unit;

the self-adaptive multi-dimensional transmission processing unit is used for acquiring the data acquired by the distributed data extraction unit and uploading it to the intelligent central server according to the data transmission instruction of the local cluster control unit; and

the distributed data extraction unit is used for real-time acquisition of relevant data of the stage performance;

wherein the self-adaptive multi-dimensional transmission processing unit comprises a data volume detection unit used for detecting the data volume of the transmitted data;

wherein the data volume detection unit specifically comprises a transmission stream table establishing unit, a feature sequence acquisition unit, an internal memory, an analysis unit, a first decision unit, a second decision unit, and a third decision unit;

wherein,

the transmission stream table establishing unit is used for establishing a transmission stream table;

the feature sequence acquisition unit is used for acquiring the feature sequence of various monitored transmission streams in the transport layer, and store them in the memory;

the analysis unit is used for analyzing the intercepted data packet header, to acquire its protocol type, source internet protocol (IP), source port, destination IP, destination port and datagram length;

the first decision unit is used for determining if the source IP, source port, destination IP and destination port recorded in the transmission stream are the same as those of the data packet under the same protocol type in the transmission stream table;

the second decision unit is used for deciding if the type of the transmission node of the transmission stream has been calibrated when the first decision unit decides a same storage situation, if not, then recording the direction of the data packet and datagram length in the transmission stream and loading in the transmission stream table; and

the third decision unit is used for deciding if the data packet record of the network data stream reaches the set threshold value of number of data packet, if reaching the threshold value, which shows the feature sequence of the transmission stream has been collected, then make a record of the data transmission quantity in the stage.

2. The system according to claim 1, wherein the self-adaptive multidimensional transmission processing unit further comprises a direct memory access unit, a plurality of transit storage units, a data type identification unit, and an IP address matching unit, wherein,

the direct memory access unit is used for receiving the data transmission instruction of the local cluster control unit, and controlling the transit storage unit, data type identification unit, IP address matching unit and data volume detection unit;

the data type identification unit is used for recognizing the type of the received data;

the IP address matching unit is used for matching the received data with the a pre-assigned internet protocol version 6 (IPv6) address, to determine accurate data sources; and

the transit storage unit is used for sorted storing of the data submitted by the stage equipment data extraction unit, stage personnel data extraction unit and stage field data extraction unit according to the data types and the matched IPv6 address.

3. The system according to claim 2, wherein the direct memory access unit comprises a buffering relay unit, which comprises a first first-in first-out buffer and a second first-in first-out buffer.

4. The system according to claim 3, wherein the direct memory access unit further comprises a finite high-speed storage collection, which comprises two sets of configuration registers and a set of state registers, the two sets of configuration registers are used to control each data stream communication of the self-adaptive multi-dimensional transmission processing unit, in turn, and the set of state registers is used to start the self-adaptive multi-dimensional transmission processing unit and reflect the transmission state of the self-adaptive multi-dimensional transmission processing unit.

5. The system according to claim 4, wherein the direct memory access unit further comprises an interface control sequence unit, which comprises a state recognizer, when the self-adaptive multi-dimensional transmission processing unit has access to the data extraction unit, the state recognizer directly controls the interface signal of receiving or transmitting data of the distributed data extraction unit, and detects the working condition of the data extraction unit in a real-time manner.