[go: up one dir, main page]

CN105119758A - Data collection method and collection system - Google Patents

Data collection method and collection system Download PDF

Info

Publication number
CN105119758A
CN105119758A CN201510582701.5A CN201510582701A CN105119758A CN 105119758 A CN105119758 A CN 105119758A CN 201510582701 A CN201510582701 A CN 201510582701A CN 105119758 A CN105119758 A CN 105119758A
Authority
CN
China
Prior art keywords
layer
data
target
application
interface
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.)
Pending
Application number
CN201510582701.5A
Other languages
Chinese (zh)
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.)
China United Network Communications Group Co Ltd
Original Assignee
China United Network Communications Group 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 China United Network Communications Group Co Ltd filed Critical China United Network Communications Group Co Ltd
Priority to CN201510582701.5A priority Critical patent/CN105119758A/en
Publication of CN105119758A publication Critical patent/CN105119758A/en
Pending legal-status Critical Current

Links

Landscapes

  • Computer And Data Communications (AREA)

Abstract

本发明实施例公开了一种数据采集的方法及采集系统,涉及通信技术领域,能够解决数据采集过程中,因重复获取同一网络接口的数据而造成的接口资源浪费的问题。本发明实施例的方法包括:共享层分别获取应用层的每个应用程序的字节需求,字节需求用于表示应用程序需要的数据字节的相关信息;共享层根据应用层的每个应用程序的字节需求,通过统一接口获取目标数据;共享层向应用层的每个应用程序发送每个应用程序对应的目标数据。本发明适用于一种采集系统。

The embodiment of the present invention discloses a data collection method and a collection system, which relate to the field of communication technology and can solve the problem of waste of interface resources caused by repeated acquisition of data from the same network interface during the data collection process. The method in the embodiment of the present invention includes: the sharing layer obtains the byte requirements of each application program in the application layer respectively, and the byte requirements are used to represent the relevant information of the data bytes required by the application program; According to the byte requirements of the program, the target data is obtained through a unified interface; the sharing layer sends the target data corresponding to each application to each application in the application layer. The invention is applicable to a collection system.

Description

一种数据采集的方法及采集系统A method and system for collecting data

技术领域technical field

本发明涉及通信技术领域,尤其涉及一种数据采集的方法及采集系统。The invention relates to the field of communication technology, in particular to a data collection method and a collection system.

背景技术Background technique

目前,在数据采集过程中,通常可以根据应用程序所需数据的来源,从不同网络接口分别获取数据,并将从不同网络接口获取的数据整合,以便于应用程序的使用,也就是传统的“烟囱式”采集。At present, in the process of data collection, it is usually possible to obtain data from different network interfaces according to the source of the data required by the application, and integrate the data obtained from different network interfaces to facilitate the use of the application, that is, the traditional " Chimney" collection.

随着通信技术的发展,多样的应用程序应运而生,需要根据不同应用程序各自的字节需求分别进行数据采集。比如:应用程序1需要获取来自C/D接口和SCP(ServiceControlPoint,业务控制点)接口的数据,而应用程序2仅需要获取来自C/D接口的数据。这样,就需要两次获取来自C/D接口的数据,导致同一网络接口的数据被重复采集,从而造成数据采集过程中接口资源的浪费。With the development of communication technology, a variety of applications have emerged, and data collection needs to be performed according to the byte requirements of different applications. For example: application 1 needs to obtain data from a C/D interface and an SCP (Service Control Point, Service Control Point) interface, while application 2 only needs to obtain data from a C/D interface. In this way, data from the C/D interface needs to be acquired twice, resulting in repeated acquisition of data from the same network interface, resulting in waste of interface resources during the data acquisition process.

发明内容Contents of the invention

本发明实施例提供一种数据采集的方法及采集系统,能够解决数据采集过程中,因重复获取同一网络接口的数据而造成的接口资源浪费的问题。Embodiments of the present invention provide a data collection method and a collection system, which can solve the problem of waste of interface resources caused by repeated acquisition of data from the same network interface during the data collection process.

为达到上述目的,本发明实施例采用如下技术方案:In order to achieve the above object, the embodiment of the present invention adopts the following technical solutions:

第一方面,本发明实施例提供一种数据采集的方法,所述方法用于一种采集系统,所述采集系统设置有应用层和共享层,所述方法包括:In a first aspect, an embodiment of the present invention provides a method for data collection, the method is used in a collection system, the collection system is provided with an application layer and a shared layer, and the method includes:

所述共享层分别获取所述应用层的每个应用程序的字节需求,所述字节需求用于表示应用程序需要的数据字节的相关信息;The sharing layer respectively obtains the byte requirement of each application program of the application layer, and the byte requirement is used to represent the relevant information of the data byte required by the application program;

所述共享层根据所述应用层的所述每个应用程序的字节需求,通过统一接口获取目标数据;The sharing layer obtains the target data through a unified interface according to the byte requirement of each application program of the application layer;

所述共享层向所述应用层的所述每个应用程序发送所述每个应用程序对应的目标数据。The sharing layer sends the target data corresponding to each application program to the each application program of the application layer.

第二方面,本发明实施例提供一种采集系统,所述采集系统设置有应用层和共享层,所述共享层,用于分别获取所述应用层的每个应用程序的字节需求,所述字节需求用于表示应用程序需要的数据字节的相关信息;In the second aspect, an embodiment of the present invention provides a collection system, the collection system is provided with an application layer and a sharing layer, and the sharing layer is used to separately obtain the byte requirements of each application program of the application layer, so The above byte requirements are used to represent the relevant information of the data bytes required by the application;

所述共享层,还用于根据所述应用层的所述每个应用程序的字节需求,通过统一接口获取目标数据;The sharing layer is further configured to obtain target data through a unified interface according to the byte requirement of each application program of the application layer;

所述共享层,还用于向所述应用层的所述每个应用程序发送所述每个应用程序对应的目标数据。The sharing layer is further configured to send the target data corresponding to each application program to the each application program in the application layer.

本发明实施例提供的一种数据采集的方法及采集系统,共享层分别获取应用层的每个应用程序的字节需求,并根据每个应用程序的字节需求来通过统一接口获取目标数据,之后向每个应用程序发送每个应用程序对应的目标数据。其中,字节需求用于表示应用程序需要的数据字节的相关信息。相比较于现有技术中针对不同的应用程序,分别从各个网络接口获取每个应用程序所需的数据,本发明实施例可以根据每个应用程序的字节需求,统一获取目标数据。因此,当多个应用程序需要获取同一网络接口的数据时,由于是通过统一接口来获取目标数据,因此,避免了不同应用程序在调用相同数据时进行数据的重复采集,从而解决数据采集过程中,因重复获取同一网络接口的数据而造成的接口资源浪费的问题。In the data collection method and collection system provided by the embodiments of the present invention, the sharing layer separately obtains the byte requirements of each application program in the application layer, and obtains the target data through a unified interface according to the byte requirements of each application program, The target data corresponding to each application is then sent to each application. Among them, the byte requirement is used to represent the relevant information of the data byte required by the application program. Compared with obtaining the data required by each application program from each network interface for different application programs in the prior art, the embodiment of the present invention can uniformly obtain target data according to the byte requirements of each application program. Therefore, when multiple applications need to obtain the data of the same network interface, because the target data is obtained through the unified interface, it avoids repeated collection of data when different applications call the same data, thereby solving the problem of data collection. , the problem of wasting interface resources caused by repeatedly obtaining data from the same network interface.

附图说明Description of drawings

为了更清楚地说明本发明实施例中的技术方案,下面将对实施例中所需要使用的附图作简单地介绍,显而易见地,下面描述中的附图仅仅是本发明的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据这些附图获得其它的附图。In order to more clearly illustrate the technical solutions in the embodiments of the present invention, the following will briefly introduce the accompanying drawings that need to be used in the embodiments. Obviously, the accompanying drawings in the following description are only some embodiments of the present invention. For Those of ordinary skill in the art can also obtain other drawings based on these drawings without making creative efforts.

图1为本发明实施例提供的一种具体应用场景示意图;FIG. 1 is a schematic diagram of a specific application scenario provided by an embodiment of the present invention;

图2为本发明实施例提供的一种数据采集的方法流程图;Fig. 2 is a flow chart of a data acquisition method provided by an embodiment of the present invention;

图3为本发明实施例提供的另一种数据采集的方法流程图;FIG. 3 is a flow chart of another data collection method provided by an embodiment of the present invention;

图4为本发明实施例提供的另一种数据采集的方法流程图;FIG. 4 is a flow chart of another data collection method provided by an embodiment of the present invention;

图5为本发明实施例提供的一种采集系统的结构示意图。Fig. 5 is a schematic structural diagram of an acquisition system provided by an embodiment of the present invention.

具体实施方式Detailed ways

下面将结合本发明实施例中的附图,对本发明实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例仅仅是本发明一部分实施例,而不是全部的实施例。基于本发明中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其它实施例,都属于本发明保护的范围。The following will clearly and completely describe the technical solutions in the embodiments of the present invention with reference to the accompanying drawings in the embodiments of the present invention. Obviously, the described embodiments are only some, not all, embodiments of the present invention. Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art without making creative efforts belong to the protection scope of the present invention.

本发明实施例可以用于一种采集系统,如图1所示,采集系统可以设置有应用层、共享层和采集层。应用层设置有N个应用程序,分别为应用程序1至应用程序N。其中,应用程序1至应用程序N可以具体为各类服务平台和业务系统,业务系统可以包括政府部门安全系统、网络优化系统、上网记录查询系统等业务系统中至少一种;共享层可以包括数据共享层和数据解码层,数据共享层可以执行通信协议的关联、解析,并将处理结果,也就是每个应用程序对应的目标数据标准化归一输出,同时还可以负责目标数据的存储,数据解码层可以执行网络数据包的解码、通信协议的识别,以及话单的生成等功能,网络数据包的解码具体可以为从目标网络接口获取原始数据;采集层,也可以被称为预处理层,主要用于完成网络接口的原始数据的采集和预处理,具体可以包括原始信令的采集、汇聚、分流。在本发明实施例中,采集层可以用来获取如图1所示的C/D接口、CS(CircuitSwitched,电路交换)域Mc接口、SCP接口等其他网络接口的原始数据。需要说明的是,采集层还可以用于实现PS(PacketSwitched,分组交换)域Gn、Gb/Iu-PS、S1_MME(MobilityManagementEntity,移动管理实体)、S1_U、S11、S6a、SGs、S5/S8、防火墙等网络接口的原始数据的接入,以及采集并完成数据的解析。其中,Mc接口包括A/Iu-CS接口。之后,共享层可以通过目标接口来获取采集层完成解析的数据。在本发明实施例中,采集层还可以实现单用户,或是同时多用户的原始信令的跟踪,并能够向应用层传输相应的跟踪文件。The embodiment of the present invention can be used in an acquisition system. As shown in FIG. 1 , the acquisition system can be provided with an application layer, a sharing layer and an acquisition layer. The application layer is provided with N application programs, which are application program 1 to application program N respectively. Among them, the application program 1 to the application program N can be specifically various service platforms and business systems, and the business system can include at least one of the business systems such as government department security systems, network optimization systems, and online record query systems; the sharing layer can include data Sharing layer and data decoding layer. The data sharing layer can perform the association and analysis of communication protocols, and standardize and output the processing results, that is, the target data corresponding to each application. At the same time, it can also be responsible for the storage of target data and data decoding. The layer can perform functions such as decoding of network data packets, identification of communication protocols, and generation of bills. The decoding of network data packets can specifically obtain raw data from the target network interface; the acquisition layer can also be called the preprocessing layer, It is mainly used to complete the collection and preprocessing of the original data of the network interface, which may specifically include the collection, aggregation, and distribution of original signaling. In the embodiment of the present invention, the collection layer can be used to obtain raw data of other network interfaces such as C/D interface, CS (CircuitSwitched, circuit switched) domain Mc interface, SCP interface, etc. as shown in FIG. 1 . It should be noted that the acquisition layer can also be used to implement PS (PacketSwitched, packet switching) domain Gn, Gb/Iu-PS, S1_MME (MobilityManagementEntity, mobile management entity), S1_U, S11, S6a, SGs, S5/S8, firewall Access to the original data of the network interface, as well as collect and complete the analysis of the data. Wherein, the Mc interface includes the A/Iu-CS interface. Afterwards, the sharing layer can obtain the data parsed by the acquisition layer through the target interface. In the embodiment of the present invention, the acquisition layer can also realize the tracking of the original signaling of a single user or multiple users at the same time, and can transmit corresponding tracking files to the application layer.

本发明实施例提供一种数据采集的方法,如图2所示,该方法包括:The embodiment of the present invention provides a method for data collection, as shown in Figure 2, the method includes:

101、共享层分别获取应用层的每个应用程序的字节需求。101. The sharing layer respectively acquires the byte requirement of each application program in the application layer.

其中,字节需求用于表示应用程序需要的数据字节的相关信息。Among them, the byte requirement is used to represent the relevant information of the data byte required by the application program.

在本发明实施例中,应用层的每个应用程序,也就是各类服务平台和业务系统的字节需求可能各不相同。比如:应用程序1需要获取来自C/D接口和SCP接口的数据,而应用程序2仅需要获取来自C/D接口的数据。In the embodiment of the present invention, each application program in the application layer, that is, various service platforms and business systems may have different byte requirements. For example: application 1 needs to obtain data from the C/D interface and SCP interface, and application 2 only needs to obtain data from the C/D interface.

102、共享层根据应用层的每个应用程序的字节需求,通过统一接口获取目标数据。102. The sharing layer obtains the target data through a unified interface according to the byte requirement of each application program in the application layer.

当步骤101中的应用程序1需要来自C/D接口的数据中的前3个字节,应用程序2需要来自C/D接口的数据中的前5个字节,来自C/D接口的数据总共包括20个字节。因此,为了保证应用程序1和应用程序2的执行,可以直接从来自C/D接口的20个字节的数据中,获取前5个字节的数据,以便于应用程序1和应用程序2使用。When application 1 in step 101 needs the first 3 bytes of the data from the C/D interface, application 2 needs the first 5 bytes of the data from the C/D interface, and the data from the C/D interface A total of 20 bytes are included. Therefore, in order to ensure the execution of application 1 and application 2, the first 5 bytes of data can be obtained directly from the 20 bytes of data from the C/D interface, so that application 1 and application 2 can use it .

103、共享层向应用层的每个应用程序发送每个应用程序对应的目标数据。103. The sharing layer sends the target data corresponding to each application program to each application program in the application layer.

需要说明的是,每个应用程序对应的目标数据的文件类型和文件格式均相同。在本发明实施例中,执行完步骤102之后,可以向应用程序1发送经过共享层处理的3个字节的数据,同时向应用程序2发送经过共享层处理的5个字节的数据。It should be noted that the file type and file format of the target data corresponding to each application program are the same. In the embodiment of the present invention, after step 102 is executed, the 3-byte data processed by the shared layer may be sent to the application program 1, and the 5-byte data processed by the shared layer may be sent to the application program 2 at the same time.

本发明实施例提供的一种数据采集的方法,共享层分别获取应用层的每个应用程序的字节需求,并根据每个应用程序的字节需求来通过统一接口获取目标数据,之后向每个应用程序发送每个应用程序对应的目标数据。其中,字节需求用于表示应用程序需要的数据字节的相关信息。相比较于现有技术中针对不同的应用程序,分别从各个网络接口获取每个应用程序所需的数据,本发明实施例可以根据每个应用程序的字节需求,统一获取目标数据。因此,当多个应用程序需要获取同一网络接口的数据时,由于是通过统一接口来获取目标数据,因此,避免了不同应用程序在调用相同数据时进行数据的重复采集,从而解决数据采集过程中,因重复获取同一网络接口的数据而造成的接口资源浪费的问题。In the data collection method provided by the embodiment of the present invention, the shared layer obtains the byte requirements of each application program in the application layer respectively, and obtains the target data through a unified interface according to the byte requirements of each application program, and then sends each Each application sends the target data corresponding to each application. Among them, the byte requirement is used to represent the relevant information of the data byte required by the application program. Compared with obtaining the data required by each application program from each network interface for different application programs in the prior art, the embodiment of the present invention can uniformly obtain target data according to the byte requirements of each application program. Therefore, when multiple applications need to obtain the data of the same network interface, because the target data is obtained through the unified interface, it avoids repeated collection of data when different applications call the same data, thereby solving the problem of data collection. , the problem of wasting interface resources caused by repeatedly obtaining data from the same network interface.

在本发明实施例的一个实现方式中,在如图2所示的实现方式的基础上,还可以实现为如图3所示的实现方式,相关信息包括:数据字节的目标网络接口的信息和目标数据的内容,步骤102共享层根据应用层的每个应用程序的字节需求,通过统一接口获取目标数据,可以具体实现为步骤1021至步骤1023:In an implementation of the embodiment of the present invention, on the basis of the implementation shown in Figure 2, it can also be implemented as the implementation shown in Figure 3, and the relevant information includes: the information of the target network interface of the data byte and the content of the target data, the shared layer in step 102 obtains the target data through a unified interface according to the byte requirements of each application program in the application layer, which can be specifically implemented as steps 1021 to 1023:

1021、共享层根据目标网络接口的信息,确定所有网络接口中的目标网络接口。1021. The sharing layer determines a target network interface among all network interfaces according to the information of the target network interface.

1022、采集层从共享层确定的目标网络接口获取原始数据。1022. The collection layer obtains the original data from the target network interface determined by the sharing layer.

1023、共享层根据目标数据的内容,通过目标接口获取原始数据中的目标数据。1023. The sharing layer acquires the target data in the original data through the target interface according to the content of the target data.

需要说明的是,目标接口可以为XDR(ExternalDataRepresentation,外部数据表示)共享接口,XDR共享接口采用的通信协议为SDTP(SerialDataTransportProtocol,串行数据传输协议)。XDR共享接口具体可以为IF1接口,其中,IF1接口可以支持实时和非实时数据的分发,并且可以满足大量数据的传送需求。此外,IF1接口可以提供数据订阅、发布、传递等数据共享功能。在本发明实施例中,通过IF1接口进行传输的数据内容可以包括:采用SDTP或文件传输协议进行传输的数据,具体可以用于传输单接口XDR,单接口XDR对应的原始信令或原始业务包头数据,指定用户、设备或指定XDRID对应的原始数据。通过IF1接口进行数据传输,可以实现传输的文件类型和文件格式的统一,从而满足应用层中各类服务平台和业务系统对于对应的目标数据的采集需求。It should be noted that the target interface may be an XDR (External Data Representation, external data representation) shared interface, and the communication protocol adopted by the XDR shared interface is SDTP (Serial Data Transport Protocol, serial data transmission protocol). Specifically, the XDR sharing interface may be an IF1 interface, wherein the IF1 interface may support the distribution of real-time and non-real-time data, and may meet the transmission requirements of a large amount of data. In addition, the IF1 interface can provide data sharing functions such as data subscription, publishing, and delivery. In the embodiment of the present invention, the data content transmitted through the IF1 interface may include: data transmitted using SDTP or file transfer protocol, which may specifically be used to transmit single-interface XDR, original signaling or original service header corresponding to single-interface XDR Data, the original data corresponding to the specified user, device or specified XDRID. Data transmission through the IF1 interface can realize the unification of the transmitted file type and file format, so as to meet the collection requirements of various service platforms and business systems in the application layer for the corresponding target data.

本发明实施例提供的一种数据采集的方法,共享层分别获取应用层的每个应用程序需要的数据字节的目标网络接口的信息和目标数据的内容,根据目标网络接口的信息来确定所有网络接口中的目标网络接口,并从目标网络接口获取原始数据,之后根据目标数据的内容,从目标接口获取原始数据中的目标数据,并向每个应用程序发送每个应用程序对应的目标数据。相比较于现有技术中针对不同的应用程序,分别从各个网络接口获取每个应用程序所需的数据,本发明实施例可以根据每个应用程序需要的数据字节的目标网络接口的信息和目标数据的内容,统一获取目标数据。因此,当多个应用程序需要获取同一网络接口的数据时,由于是通过统一接口来获取目标数据,因此,避免了不同应用程序在调用相同数据时进行数据的重复采集。并且,通过先确定所有网络接口中的目标网络接口,再获取从目标网络接口获取的原始数据中的目标数据,因此,能够在解决数据采集过程中,因重复获取同一网络接口的数据而造成的接口资源浪费的问题的同时,提高获取目标数据的准确性。In the method of data collection provided by the embodiment of the present invention, the sharing layer obtains the information of the target network interface and the content of the target data of the data bytes required by each application program of the application layer respectively, and determines all the data according to the information of the target network interface. The target network interface in the network interface, and obtain the original data from the target network interface, and then according to the content of the target data, obtain the target data in the original data from the target interface, and send the target data corresponding to each application to each application . Compared with obtaining the data required by each application program from each network interface for different applications in the prior art, the embodiment of the present invention can use the information of the target network interface and the data bytes required by each application program The content of the target data, and obtain the target data uniformly. Therefore, when multiple applications need to obtain data from the same network interface, since the target data is obtained through a unified interface, repeated collection of data when different applications call the same data is avoided. Moreover, by first determining the target network interface in all network interfaces, and then obtaining the target data in the original data obtained from the target network interface, it is possible to solve the problem caused by repeated acquisition of data from the same network interface during the data collection process. While solving the problem of waste of interface resources, improve the accuracy of obtaining target data.

在本发明实施例的一个实现方式中,在如图2所示的实现方式的基础上,还可以实现为如图4所示的实现方式,在执行步骤102共享层根据应用层的每个应用程序的字节需求,通过统一接口获取目标数据之后,还可以执行步骤104和步骤105:In an implementation of the embodiment of the present invention, on the basis of the implementation shown in FIG. 2, it can also be implemented as the implementation shown in FIG. For the byte requirements of the program, after obtaining the target data through the unified interface, step 104 and step 105 can also be performed:

104、共享层调用统一接口,并存储目标数据。104. The sharing layer invokes the unified interface and stores the target data.

105、共享层根据目标协议和目标数据,生成每个应用程序对应的目标数据。105. The sharing layer generates target data corresponding to each application program according to the target protocol and target data.

本发明实施例提供的一种数据采集的方法,在共享层根据应用层的每个应用程序的字节需求来获取目标数据之后,可以先由共享层调用统一接口来存储目标数据,之后根据目标协议和目标数据来生成每个应用程序对应的目标数据,并向每个应用程序发送每个应用程序对应的目标数据。其中,字节需求用于表示应用程序需要的数据字节的相关信息。相比较于现有技术中针对不同的应用程序,分别从各个网络接口获取每个应用程序所需的数据,本发明实施例可以根据每个应用程序的字节需求,统一获取目标数据并存储。因此,当多个应用程序需要获取同一网络接口的数据时,由于是通过统一接口来获取目标数据,因此,避免了不同应用程序在调用相同数据时进行数据的重复采集,从而解决数据采集过程中,因重复获取同一网络接口的数据而造成的接口资源浪费的问题。In the data acquisition method provided by the embodiment of the present invention, after the shared layer obtains the target data according to the byte requirements of each application program in the application layer, the shared layer can first call the unified interface to store the target data, and then according to the target Protocol and target data to generate target data corresponding to each application, and send target data corresponding to each application to each application. Among them, the byte requirement is used to represent the relevant information of the data byte required by the application program. Compared with obtaining the data required by each application program from each network interface for different application programs in the prior art, the embodiment of the present invention can uniformly obtain and store target data according to the byte requirements of each application program. Therefore, when multiple applications need to obtain the data of the same network interface, because the target data is obtained through the unified interface, it avoids repeated collection of data when different applications call the same data, thereby solving the problem of data collection. , the problem of wasting interface resources caused by repeatedly obtaining data from the same network interface.

本发明实施例提供一种采集系统20,如图5所示,采集系统20设置有应用层21和共享层22,共享层22,用于分别获取应用层21的每个应用程序的字节需求,字节需求用于表示应用程序需要的数据字节的相关信息。An embodiment of the present invention provides a collection system 20, as shown in Figure 5, the collection system 20 is provided with an application layer 21 and a shared layer 22, and the shared layer 22 is used to obtain the byte requirements of each application program in the application layer 21 respectively , byte requirements are used to represent information about the data bytes required by the application.

共享层22,还用于根据应用层21的每个应用程序的字节需求,通过统一接口获取目标数据。The sharing layer 22 is also used to obtain target data through a unified interface according to the byte requirements of each application program in the application layer 21 .

共享层22,还用于向应用层21的每个应用程序发送每个应用程序对应的目标数据。The shared layer 22 is also configured to send target data corresponding to each application to each application of the application layer 21 .

在本发明实施例的一个实现方式中,如图5所示,采集系统20设置有采集层23,相关信息包括:数据字节的目标网络接口的信息和目标数据的内容,共享层22,具体用于根据目标网络接口的信息,确定所有网络接口中的目标网络接口。In an implementation of the embodiment of the present invention, as shown in Figure 5, the collection system 20 is provided with a collection layer 23, and the relevant information includes: the information of the target network interface of the data bytes and the content of the target data, the sharing layer 22, specifically It is used to determine the target network interface among all network interfaces according to the information of the target network interface.

采集层23,用于从共享层22确定的目标网络接口获取原始数据。The collection layer 23 is configured to obtain raw data from the target network interface determined by the sharing layer 22 .

共享层22,具体用于根据目标数据的内容,通过目标接口获取原始数据中的目标数据。The sharing layer 22 is specifically used to obtain the target data in the original data through the target interface according to the content of the target data.

在本发明实施例的一个实现方式中,在共享层22根据应用层的每个应用程序的字节需求,通过统一接口获取目标数据之后,共享层22,还用于调用统一接口,并存储目标数据。In an implementation of the embodiment of the present invention, after the sharing layer 22 obtains the target data through the unified interface according to the byte requirements of each application program in the application layer, the sharing layer 22 is also used to call the unified interface and store the target data. data.

共享层22,还用于根据目标协议和目标数据,生成每个应用程序对应的目标数据。The shared layer 22 is also used to generate target data corresponding to each application program according to the target protocol and target data.

需要说明的是,目标接口为外部数据表示XDR共享接口,XDR共享接口采用的通信协议为串行数据传输协议SDTP;每个应用程序对应的目标数据的文件类型和文件格式均相同。It should be noted that the target interface is an external data representation XDR shared interface, and the communication protocol adopted by the XDR shared interface is the serial data transfer protocol SDTP; the file type and file format of the target data corresponding to each application are the same.

本发明实施例提供的一种采集系统,共享层分别获取应用层的每个应用程序的字节需求,并根据每个应用程序的字节需求来通过统一接口获取目标数据,之后向每个应用程序发送每个应用程序对应的目标数据。其中,字节需求用于表示应用程序需要的数据字节的相关信息。相比较于现有技术中针对不同的应用程序,分别从各个网络接口获取每个应用程序所需的数据,本发明实施例可以根据每个应用程序的字节需求,统一获取目标数据。因此,当多个应用程序需要获取同一网络接口的数据时,由于是通过统一接口来获取目标数据,因此,避免了不同应用程序在调用相同数据时进行数据的重复采集,从而解决数据采集过程中,因重复获取同一网络接口的数据而造成的接口资源浪费的问题。In an acquisition system provided by an embodiment of the present invention, the sharing layer separately obtains the byte requirements of each application program in the application layer, and obtains the target data through a unified interface according to the byte requirements of each application program, and then sends each application The program sends object data corresponding to each application. Among them, the byte requirement is used to represent the relevant information of the data byte required by the application program. Compared with obtaining the data required by each application program from each network interface for different application programs in the prior art, the embodiment of the present invention can uniformly obtain target data according to the byte requirements of each application program. Therefore, when multiple applications need to obtain the data of the same network interface, because the target data is obtained through the unified interface, it avoids repeated collection of data when different applications call the same data, thereby solving the problem of data collection. , the problem of wasting interface resources caused by repeatedly obtaining data from the same network interface.

本说明书中的各个实施例均采用递进的方式描述,各个实施例之间相同相似的部分互相参见即可,每个实施例重点说明的都是与其他实施例的不同之处。尤其,对于系统实施例而言,由于其基本相似于方法实施例,所以描述得比较简单,相关之处参见方法实施例的部分说明即可。Each embodiment in this specification is described in a progressive manner, the same and similar parts of each embodiment can be referred to each other, and each embodiment focuses on the differences from other embodiments. In particular, as for the system embodiment, since it is basically similar to the method embodiment, the description is relatively simple, and for related parts, please refer to part of the description of the method embodiment.

本领域普通技术人员可以理解实现上述实施例方法中的全部或部分流程,是可以通过计算机程序来指令相关的硬件来完成,所述的程序可存储于计算机可读取存储介质中,该程序在执行时,可包括如上述各方法的实施例的流程。其中,所述的存储介质可为磁碟、光盘、只读存储记忆体(Read-OnlyMemory,ROM)或随机存储记忆体(RandomAccessMemory,RAM)等。Those of ordinary skill in the art can understand that all or part of the processes in the methods of the above embodiments can be implemented through computer programs to instruct related hardware, and the programs can be stored in computer-readable storage media. During execution, it may include the processes of the embodiments of the above-mentioned methods. Wherein, the storage medium may be a magnetic disk, an optical disk, a read-only memory (Read-Only Memory, ROM) or a random access memory (Random Access Memory, RAM) and the like.

以上所述,仅为本发明的具体实施方式,但本发明的保护范围并不局限于此,任何熟悉本技术领域的技术人员在本发明揭露的技术范围内,可轻易想到的变化或替换,都应涵盖在本发明的保护范围之内。因此,本发明的保护范围应该以权利要求的保护范围为准。The above is only a specific embodiment of the present invention, but the scope of protection of the present invention is not limited thereto. Anyone skilled in the art can easily think of changes or substitutions within the technical scope disclosed in the present invention. All should be covered within the protection scope of the present invention. Therefore, the protection scope of the present invention should be determined by the protection scope of the claims.

Claims (10)

1.一种数据采集的方法,其特征在于,所述方法用于一种采集系统,所述采集系统设置有应用层和共享层,所述方法包括:1. A method for data collection, characterized in that, the method is used in a collection system, and the collection system is provided with an application layer and a shared layer, and the method comprises: 所述共享层分别获取所述应用层的每个应用程序的字节需求,所述字节需求用于表示应用程序需要的数据字节的相关信息;The sharing layer respectively obtains the byte requirement of each application program of the application layer, and the byte requirement is used to represent the relevant information of the data byte required by the application program; 所述共享层根据所述应用层的所述每个应用程序的字节需求,通过统一接口获取目标数据;The sharing layer obtains the target data through a unified interface according to the byte requirement of each application program of the application layer; 所述共享层向所述应用层的所述每个应用程序发送所述每个应用程序对应的目标数据。The sharing layer sends the target data corresponding to each application program to the each application program of the application layer. 2.根据权利要求1所述的方法,其特征在于,所述采集系统设置有采集层,所述相关信息包括:所述数据字节的目标网络接口的信息和所述目标数据的内容,所述共享层根据所述应用层的所述每个应用程序的字节需求,通过统一接口获取目标数据,包括:2. method according to claim 1, is characterized in that, described acquisition system is provided with acquisition layer, and described related information comprises: the information of the target network interface of described data byte and the content of described target data, so The sharing layer obtains the target data through a unified interface according to the byte requirements of each application program in the application layer, including: 所述共享层根据所述目标网络接口的信息,确定所有网络接口中的所述目标网络接口;The sharing layer determines the target network interface among all network interfaces according to the information of the target network interface; 所述采集层从所述共享层确定的所述目标网络接口获取原始数据;The collection layer obtains raw data from the target network interface determined by the sharing layer; 所述共享层根据所述目标数据的内容,通过目标接口获取所述原始数据中的目标数据。The sharing layer obtains the target data in the original data through the target interface according to the content of the target data. 3.根据权利要求1所述的方法,其特征在于,在所述共享层根据所述应用层的所述每个应用程序的字节需求,通过统一接口获取目标数据之后,所述方法还包括:3. The method according to claim 1, characterized in that, after the shared layer obtains the target data through a unified interface according to the byte requirement of each application program of the application layer, the method further comprises : 所述共享层调用所述统一接口,并存储所述目标数据;The sharing layer invokes the unified interface and stores the target data; 所述共享层根据目标协议和所述目标数据,生成所述每个应用程序对应的目标数据。The sharing layer generates the target data corresponding to each application program according to the target protocol and the target data. 4.根据权利要求2所述的方法,其特征在于,所述目标接口为外部数据表示XDR共享接口,所述XDR共享接口采用的通信协议为串行数据传输协议SDTP。4. The method according to claim 2, wherein the target interface is an external data representation XDR sharing interface, and the communication protocol adopted by the XDR sharing interface is a serial data transfer protocol SDTP. 5.根据权利要求1至3中任一项所述的方法,其特征在于,所述每个应用程序对应的目标数据的文件类型和文件格式均相同。5. The method according to any one of claims 1 to 3, characterized in that the file type and file format of the target data corresponding to each application program are the same. 6.一种采集系统,其特征在于,所述采集系统设置有应用层和共享层,所述共享层,用于分别获取所述应用层的每个应用程序的字节需求,所述字节需求用于表示应用程序需要的数据字节的相关信息;6. A collection system, characterized in that, the collection system is provided with an application layer and a shared layer, and the shared layer is used to respectively obtain the byte requirements of each application program of the application layer, and the byte Requirements are used to represent information about the data bytes required by the application; 所述共享层,还用于根据所述应用层的所述每个应用程序的字节需求,通过统一接口获取目标数据;The sharing layer is further configured to obtain target data through a unified interface according to the byte requirement of each application program of the application layer; 所述共享层,还用于向所述应用层的所述每个应用程序发送所述每个应用程序对应的目标数据。The sharing layer is further configured to send the target data corresponding to each application program to the each application program in the application layer. 7.根据权利要求6所述的采集系统,其特征在于,所述采集系统设置有采集层,所述相关信息包括:所述数据字节的目标网络接口的信息和所述目标数据的内容,所述共享层,具体用于根据所述目标网络接口的信息,确定所有网络接口中的所述目标网络接口;7. acquisition system according to claim 6, is characterized in that, described acquisition system is provided with acquisition layer, and described relevant information comprises: the information of the target network interface of described data byte and the content of described target data, The sharing layer is specifically configured to determine the target network interface among all network interfaces according to the information of the target network interface; 所述采集层,用于从所述共享层确定的所述目标网络接口获取原始数据;The collection layer is configured to obtain raw data from the target network interface determined by the sharing layer; 所述共享层,具体用于根据所述目标数据的内容,通过目标接口获取所述原始数据中的目标数据。The sharing layer is specifically configured to obtain the target data in the original data through the target interface according to the content of the target data. 8.根据权利要求6所述的采集系统,其特征在于,在所述共享层根据所述应用层的所述每个应用程序的字节需求,通过统一接口获取目标数据之后,所述共享层,还用于调用所述统一接口,并存储所述目标数据;8. The acquisition system according to claim 6, characterized in that, after the shared layer obtains the target data through a unified interface according to the byte requirement of each application program of the application layer, the shared layer , which is also used to call the unified interface and store the target data; 所述共享层,还用于根据目标协议和所述目标数据,生成所述每个应用程序对应的目标数据。The sharing layer is further configured to generate target data corresponding to each application program according to the target protocol and the target data. 9.根据权利要求7所述的采集系统,其特征在于,所述目标接口为外部数据表示XDR共享接口,所述XDR共享接口采用的通信协议为串行数据传输协议SDTP。9. The acquisition system according to claim 7, wherein the target interface is an external data representation XDR sharing interface, and the communication protocol adopted by the XDR sharing interface is a serial data transfer protocol SDTP. 10.根据权利要求6至8中任一项所述的采集系统,其特征在于,所述每个应用程序对应的目标数据的文件类型和文件格式均相同。10. The collection system according to any one of claims 6 to 8, characterized in that the file types and file formats of the target data corresponding to each application program are the same.
CN201510582701.5A 2015-09-14 2015-09-14 Data collection method and collection system Pending CN105119758A (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN201510582701.5A CN105119758A (en) 2015-09-14 2015-09-14 Data collection method and collection system

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN201510582701.5A CN105119758A (en) 2015-09-14 2015-09-14 Data collection method and collection system

Publications (1)

Publication Number Publication Date
CN105119758A true CN105119758A (en) 2015-12-02

Family

ID=54667656

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201510582701.5A Pending CN105119758A (en) 2015-09-14 2015-09-14 Data collection method and collection system

Country Status (1)

Country Link
CN (1) CN105119758A (en)

Cited By (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN110351158A (en) * 2018-04-08 2019-10-18 恒安嘉新(北京)科技股份公司 Network speed calculation method and system
CN112291185A (en) * 2019-07-24 2021-01-29 中国移动通信集团贵州有限公司 Method and device for collecting network data

Citations (10)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20050025183A1 (en) * 2003-08-01 2005-02-03 Alcatel Network traffic data processing system and method for auto-configuration of a router
CN101567001A (en) * 2009-05-22 2009-10-28 清华大学 Method for managing metadata file layout of parallel file system
US20110004446A1 (en) * 2008-12-15 2011-01-06 Accenture Global Services Gmbh Intelligent network
CN101964081A (en) * 2010-09-13 2011-02-02 中国恩菲工程技术有限公司 Production information system based on factory management infrastructure platform
CN102271156A (en) * 2011-07-20 2011-12-07 武汉爱迪智能工程有限公司 Data sharing service system based on internet of things
CN102289739A (en) * 2011-07-29 2011-12-21 上海互联网软件有限公司 Community service management system
CN102739420A (en) * 2011-04-07 2012-10-17 北京源汇远科技有限公司 Distributed complex giant system based on digital drainage network operation management and maintenance
CN102904967A (en) * 2012-11-06 2013-01-30 包茂林 Intelligent Internet of things data exchange platform scheme based on hardware electromechanical field
CN104463472A (en) * 2014-12-12 2015-03-25 江阴中科今朝科技有限公司 Electronic government platform system
CN104615778A (en) * 2015-02-27 2015-05-13 浪潮集团有限公司 Method, device and system for avoiding re-extracting data

Patent Citations (10)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20050025183A1 (en) * 2003-08-01 2005-02-03 Alcatel Network traffic data processing system and method for auto-configuration of a router
US20110004446A1 (en) * 2008-12-15 2011-01-06 Accenture Global Services Gmbh Intelligent network
CN101567001A (en) * 2009-05-22 2009-10-28 清华大学 Method for managing metadata file layout of parallel file system
CN101964081A (en) * 2010-09-13 2011-02-02 中国恩菲工程技术有限公司 Production information system based on factory management infrastructure platform
CN102739420A (en) * 2011-04-07 2012-10-17 北京源汇远科技有限公司 Distributed complex giant system based on digital drainage network operation management and maintenance
CN102271156A (en) * 2011-07-20 2011-12-07 武汉爱迪智能工程有限公司 Data sharing service system based on internet of things
CN102289739A (en) * 2011-07-29 2011-12-21 上海互联网软件有限公司 Community service management system
CN102904967A (en) * 2012-11-06 2013-01-30 包茂林 Intelligent Internet of things data exchange platform scheme based on hardware electromechanical field
CN104463472A (en) * 2014-12-12 2015-03-25 江阴中科今朝科技有限公司 Electronic government platform system
CN104615778A (en) * 2015-02-27 2015-05-13 浪潮集团有限公司 Method, device and system for avoiding re-extracting data

Cited By (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN110351158A (en) * 2018-04-08 2019-10-18 恒安嘉新(北京)科技股份公司 Network speed calculation method and system
CN110351158B (en) * 2018-04-08 2020-12-04 恒安嘉新(北京)科技股份公司 Network speed calculation method and system
CN112291185A (en) * 2019-07-24 2021-01-29 中国移动通信集团贵州有限公司 Method and device for collecting network data
CN112291185B (en) * 2019-07-24 2022-11-22 中国移动通信集团贵州有限公司 Method and device for collecting network data

Similar Documents

Publication Publication Date Title
CN110312279B (en) Network data monitoring method and device
WO2016095516A1 (en) Complex event processing method, apparatus and system
EP3321821B1 (en) Big data exchange method and device
CN115278639A (en) Perceptual data acquisition method, device, device and storage medium
US20150319238A1 (en) Method, device and storage medium for data processing
CN104809650A (en) Dynamic adaptive accessing method of heterogeneous sensor data
US20230042747A1 (en) Message Processing Method and Device, Storage Medium, and Electronic Device
CN110413418A (en) Cache synchronization device and method, cache synchronization system, electronic equipment
CN106100914A (en) The method for pushing of a kind of cloud AC warning information and system
WO2020125074A1 (en) Message arrival rate determination method and device, data statistics server and storage medium
CN108366356A (en) The interoperability methods and device of M2M systems and identification (RNC-ID) analytic system
CN109510748B (en) Node and node interaction method and system
CN108153803A (en) A kind of data capture method, device and electronic equipment
CN111008254B (en) Object creation method, device, computer equipment and storage medium
CN108901035A (en) The recognition methods of internet-of-things terminal and device
CN105119758A (en) Data collection method and collection system
CN114513552A (en) Data processing method, device, equipment and storage medium
CN111224891B (en) Flow application identification system and method based on dynamic learning triples
WO2016197783A2 (en) Method and apparatus for controlling message transmission
CN109814871B (en) Node management method and system based on DDS bus
CN102438048A (en) Method and system for calling remote service in Internet
CN113779018B (en) A data processing method and device
CN115766373A (en) A conversion method between dds and Zigbee protocol
CN115087025A (en) Private network data collection method, equipment and storage medium
WO2020168521A1 (en) Message parsing method, data sending end, data receiving end, and system

Legal Events

Date Code Title Description
C06 Publication
PB01 Publication
C10 Entry into substantive examination
SE01 Entry into force of request for substantive examination
RJ01 Rejection of invention patent application after publication

Application publication date: 20151202

RJ01 Rejection of invention patent application after publication