CN-122027591-A - Method, device and system for processing TSN collector data

CN122027591ACN 122027591 ACN122027591 ACN 122027591ACN-122027591-A

Abstract

The invention provides a processing method, a device and a system of TSN collector data, the method comprises the steps of collecting data frames of a TSN collector, adding a synchronous head, a time tag, a serial number and a length into the data frames to obtain data frames containing collected information tags, screening the data frames containing the collected information tags according to a preset rule, extracting key parameters, repacking packets to ensure that low-delay and high-reliability transmission of key service flow is realized, and storing the data frames containing the collected information tags in a full quantity. The invention can realize the data screening forwarding and full data storage of the multipath TSN data frames and ensure the real-time performance and the integrity of data processing and storage.

Inventors

CHEN JIAORUI
ZHANG JIE
HUANG RUCHANG
Ding Tenghuan
WANG GUOQIANG

Assignees

中国飞行试验研究院

Dates

Publication Date: 20260512
Application Date: 20251227

Claims (8)

1. The processing method of the time sensitive network TSN collector data is characterized by comprising the following steps: acquiring a data frame of a TSN collector, and adding a synchronous head, a time tag, a serial number and a length into the data frame to obtain a data frame containing an acquisition information tag; Screening the data frames containing the acquired information labels according to a pre-configuration rule, extracting key parameters and re-grouping packets to ensure that the key service flow realizes low-delay and high-reliability transmission; and carrying out full-quantity storage on the data frames containing the acquisition information labels.
2. The method according to claim 1, wherein the data frames of the TSN collector are collected, and a synchronization header, a time tag, a sequence number and a length are added to the data frames to obtain data frames containing collected information tags, specifically as follows: analyzing the data frame package layer by layer to obtain data state information; Analyzing the state information; judging whether the data frame is complete or not according to the analysis result of the state information; when the data frame is complete, a synchronization header, a time tag, a sequence number and a length are added to the data frame.
3. The method of claim 1, further comprising parsing, by the clock device, the time direct current time code DC and the alternating current time code AC codes, the precision time protocol frame PTP data frame, and determining the time stamp based on the PTP data frame.
4. The method according to claim 1, wherein the screening of the data frames containing the collected information tag according to the pre-configured rule extracts key parameters and reassembles packets, specifically as follows: generating a pre-configuration rule based on the obtained VLAN ID, the priority label, the source/destination MAC address and the data offset; Analyzing VLAN ID, priority label, source/destination MAC address and data offset in the data frame containing the acquisition information label, and comparing the analyzed result with a preset rule; Removing unnecessary fields to obtain a plurality of small frames and storing the small frames into a buffer queue, so that the transmission cost is reduced; framing a plurality of small frame payloads in the buffer queue, and combining the small frame payloads into large frame data; A synchronization header, a time tag, a sequence number, a length, and a screening tag are added to the large frame data.
5. The method according to claim 1, characterized in that the data frames containing the acquisition information tag are stored in full, in particular as follows: storing different data frames into a plurality of memories according to the data port numbers; according to the data stream priority information, storing the data in different memories into a cache queue for caching; And determining the data frames to be called according to the multiport data storage flow, and writing the data frames to be called in the cache queue into the storage space.
6. The method according to claim 5, wherein the determining the data frame to be invoked according to the multiport data storage traffic is as follows: The method comprises the steps of carrying out time-sharing sequencing according to the priority level of the port, outputting the data frames of the port first with higher priority level, and outputting the data frames of the port with the same priority level according to the sequence of the data frame acquisition time.
7. A processing device for TSN collector data for performing the method of any of claims 1 to 6, comprising: the data acquisition module is used for acquiring the data frame of the TSN collector, and adding a synchronous head, a time tag, a serial number and a length to the data frame to obtain a data frame containing an acquisition information tag; the data screening module is used for screening the data frames containing the acquired information labels according to a preset rule, extracting key parameters and recombining packets to ensure that the key service flow realizes low-delay and high-reliability transmission; And the full-quantity storage module is used for storing the data frames containing the acquisition information labels in full quantity.
8. A processing system of TSN collector data is characterized by comprising the processing device of TSN collector data, a TSN collector, a storage module and a target terminal, The processing device of the TSN collector data collects the data frames of the TSN collector, adds a synchronous head, a time tag, a serial number and a length to the data frames to obtain data frames containing the collection information tag, screens the data frames containing the collection information tag according to a preset rule, extracts key parameters, reassembles the key parameters and sends the key parameters to a target terminal, and simultaneously sends the data frames containing the collection information tag to a storage module for full storage.

Description

Method, device and system for processing TSN collector data Technical Field The invention belongs to the technical field of computer networks, and relates to a method, a device and a system for processing TSN collector data. Background Time Sensitive Networks (TSNs) are an extension of the set of ethernet-based protocol standards developed by the IEEE 802.1 TSN task group. On the premise of keeping the best effort communication capability of the traditional Ethernet, the method ensures deterministic low-delay transmission of high-priority key traffic through an enhancement mechanism. TSN is often applied in industry, car etc. fields, satisfies low delay high reliable application demand. For TSN data acquisition and monitoring, high throughput and real-time performance of an acquisition system are required. The traditional TSN acquisition method is only designed for data exchange and delay, and a method for selecting parameter forwarding data and full data record is not provided for data monitoring and record. Disclosure of Invention The invention provides a data acquisition, selection forwarding and storage control method and system of a TSN collector, which aim to solve the technical problems of data real-time selection parameter forwarding and storage and 10Gpbs data full-scale storage. The technical scheme is as follows: in a first aspect, the present invention provides a method for processing TSN collector data, including the following steps: acquiring a data frame of a TSN collector, and adding a synchronous head, a time tag, a serial number and a length into the data frame to obtain a data frame containing an acquisition information tag; Screening the data frames containing the acquired information labels according to a pre-configuration rule, extracting key parameters and re-grouping packets to ensure that the key service flow realizes low-delay and high-reliability transmission; and carrying out full-quantity storage on the data frames containing the acquisition information labels. Further, the data frame of the TSN collector is collected, and a synchronization header, a time tag, a serial number and a length are added to the data frame to obtain a data frame containing a collected information tag, which is specifically as follows: analyzing the data frame package layer by layer to obtain data state information; Analyzing the state information; judging whether the data frame is complete or not according to the analysis result of the state information; when the data frame is complete, a synchronization header, a time tag, a sequence number and a length are added to the data frame. Further, the method further comprises the steps of analyzing the time direct current time code DC and the alternating current time code AC through the clock equipment, analyzing a PTP data frame of the accurate time protocol frame, and determining a time label based on the PTP data frame. Further, the data frames containing the collected information tags are screened according to a pre-configuration rule, key parameters are extracted and the packets are reassembled, specifically as follows: Generating a pre-configuration rule based on the obtained VLAN ID, the priority label, the source/destination MAC address and the data offset; Analyzing a virtual local area network identifier VLAN ID, a priority label, a source/destination MAC address and a data offset in a data frame containing the acquisition information label, and comparing the analyzed result with a preset rule; Removing unnecessary fields to obtain a plurality of small frames and storing the small frames into a buffer queue, so that the transmission cost is reduced; framing a plurality of small frame payloads in the buffer queue, and combining the small frame payloads into large frame data; A synchronization header, a time tag, a sequence number, a length, and a screening tag are added to the large frame data. Further, the method is characterized in that the data frame containing the collected information tag is subjected to full-quantity storage, and specifically comprises the following steps: storing different data frames into a plurality of memories according to the data port numbers; according to the data stream priority information, storing the data in different memories into a cache queue for caching; And determining the data frames to be called according to the multiport data storage flow, and writing the data frames to be called in the cache queue into the storage space. The method is further characterized in that the data frame to be called is determined according to the multiport data storage flow, and the method specifically comprises the following steps: The method comprises the steps of carrying out time-sharing sequencing according to the priority level of the port, outputting the data frames of the port first with higher priority level, and outputting the data frames of the port with the same priority level according to the sequence of the data frame