CN105282050A - Method and device for aggregating data flows - Google Patents

Abstract

Embodiments of the present invention provide a method and device for aggregating data streams. In this method, the intelligent network controller can obtain aggregation configuration information from the policy management and control system according to user requirements, and deliver the aggregation configuration information to the flow exporter, where the aggregation configuration information includes aggregation fields used for aggregation of data streams. In this way, the NDE can sample the data stream according to the aggregation configuration information, and aggregate the sampled data stream according to the aggregation field. The embodiments of the present invention can flexibly meet the user's aggregation requirements in real time through the above solution.

Description

Method and apparatus for aggregating data streams

technical field

The present invention relates to the field of communications, and more particularly, to methods and apparatus for aggregating data streams.

Background technique

Software Defined Network (Software Defined Network, SDN) is a new generation of network architecture. Its core idea is to decouple the data plane and control plane transmitted by network equipment, and centralize the management of the control plane to achieve flexible on-demand deployment of network resources.

In a network system, people always hope to maximize the use of network bandwidth, so it is necessary to plan ports and configure routes reasonably based on the number of services and service characteristics. However, the traffic in the network is dynamic, and a certain link in the network may be congested at a certain period of time, which may reduce the utilization rate of the network bandwidth. In order to improve the utilization rate of network bandwidth, you can view the traffic statistics of different levels of services in the network in real time, and adjust the transmission paths of services in the network reasonably according to the traffic statistics.

In a traditional implementation, statistics on data stream traffic in different dimensions can be realized through sampling aggregation technology. For example, an intelligent network controller (SmartNetworkController, SNC) may issue a sampling ratio to a network stream data exporter (NetStreamDataExporter, NDE). NDE can sample and aggregate data streams based on the specified aggregation mode, and analyze the aggregated stream statistical information through network stream data collection (NetStreamCollector, NSC), and finally realize the reasonable distribution of network traffic through the policy control system.

In the above implementation, NDE needs to develop aggregation modes of different dimensions in advance, so as to implement aggregation based on different granularities for data streams. For example, based on combined aggregation, in an SDN Virtual Extended Local Area Network (VirtualeXtensibleLocalAreaNetwork, VXLAN) scenario, a tenant may be represented by two fields: the user's destination Internet Protocol (InternetProtocol, IP) address and the VXLAN Network Identifier (VXLANNetworkIdentifier, VNI). A set of aggregate fields can develop an aggregation schema. This way of aggregating data streams can only count aggregated modes that have been developed in real time. When users want to collect aggregated flow information of an undeveloped aggregation mode, they must first develop a new aggregation mode according to user needs, and use the new aggregation mode to realize the aggregation of data streams. This method of aggregating data streams may lead to a long development cycle and cannot flexibly meet user aggregation requirements.

Contents of the invention

Embodiments of the present invention provide a method and device for aggregating data streams, which can flexibly meet users' aggregation requirements in real time.

In a first aspect, a method for aggregating data streams is provided, including: an intelligent network controller SNC receives aggregation configuration information sent by a policy management and control system according to user statistics requirements, the aggregation configuration information includes at least one aggregation field, and the aggregation field The field type on which the data flow is aggregated; the SNC sends aggregation configuration information to the traffic exporter NDE, so that the NDE samples the data flow according to the aggregation configuration information, and according to the at least one aggregation field The sampled data streams are aggregated.

In the embodiment of the present invention, the SNC can obtain aggregation configuration information from the policy management and control system according to user requirements, and deliver the aggregation configuration information to the NDE. The aggregation configuration information includes the aggregation fields used to aggregate data streams, so that the NDE can use Aggregate configuration information to sample the data stream, and aggregate the sampled data stream according to the aggregation field, which can solve the technical problem in the existing technology that needs to develop multiple aggregation modes according to user needs, and can flexibly meet the user's aggregation needs in real time .

With reference to the first aspect, in an implementation manner of the first aspect, the method further includes: the SNC assigns corresponding field type values to the at least one aggregation field; wherein, the SNC sends the traffic exporter NDE sending aggregation configuration information, where the aggregation configuration information includes the at least one aggregation field, so that the NDE samples the data flow according to the aggregation configuration information, and aggregates the sampled data flow according to the at least one aggregation field Including: the SNC sending the aggregation configuration information to the NDE, the aggregation configuration information including the at least one aggregation field and the field type value, so that the NDE samples the data flow according to the aggregation configuration information , and aggregate the sampled data stream according to the at least one aggregation field and the field type value.

With reference to the first aspect and the foregoing implementation manners thereof, in another implementation manner of the first aspect, the method further includes: the SNC receiving the at least An offset of an aggregation field in the data stream; the SNC sends the offset to the NDE.

With reference to the first aspect and the above-mentioned implementation manners, in another implementation manner of the first aspect, the method further includes: the SNC determines an access control list (AccessControlList, ACL) policy, and the ACL policy is used to indicate the The NDE filters the data flow; the SNC sends the ACL policy to the NDE.

By formulating an ACL policy and sending the ACL policy to the NDE, the SNC can make the NDE filter the data flow, that is, only the data flow meeting the ACL policy is aggregated. ACL filtering can flexibly implement various forms of filtering for source and destination IP addresses, protocol types, port numbers, etc. NDE can filter out some data streams that cannot be aggregated through ACL filtering, so that NDE can only collect statistics on eligible streams, reducing the complexity of subsequent aggregation and statistics of data streams based on aggregation fields. For example, the VNI field carried in the User Datagram Protocol (User Datagram Protocol, UDP) is not included in the data packets of other protocols. The NDE can filter the UDP packets through the ACL policy formulated by the SNC. In this way, when the NDE aggregates the data streams, the complexity of aggregating all the sampled data streams can be reduced, and the aggregation time can be shortened.

With reference to the first aspect and the above implementation manners, in another implementation manner of the first aspect, the method further includes: the SNC sending the at least one aggregation field and the field type value to the intelligent network controller NSC corresponding relationship.

The foregoing manner of aggregating data streams can be applied to regulate network traffic. For example, the SNC can also send the correspondence between at least one aggregation field and field type value to the NSC, so that the NSC can analyze the aggregated flow statistics according to the correspondence, and then enable the policy control system to adjust the network traffic.

In a second aspect, a method for aggregating data streams is provided, including: a traffic exporter NDE receives aggregation configuration information sent by an intelligent network controller SNC, and the aggregation configuration information includes at least one aggregation field, and the aggregation field is for data The field type on which streams are aggregated; the NDE receives data streams sent by other NDEs; the NDE samples the received data streams according to the aggregation configuration information to obtain the sampled data streams; the NDE according to The at least one aggregation field aggregates the sampled data stream.

In the embodiment of the present invention, the NDE samples the data stream according to the aggregation configuration information, and aggregates the sampled data stream according to the aggregation field, so that the aggregation requirements of the user can be flexibly met in real time.

With reference to the second aspect, in an implementation manner of the second aspect, the aggregation configuration information further includes a field type value of the at least one aggregation field; wherein, the NDE samples the Aggregating the sampled data streams includes: the NDE aggregates the sampled data streams according to the at least one aggregation field and the field type value.

After the NDE aggregates the data streams, the aggregated streams can be obtained, and the aggregated stream information can be collected to obtain aggregated stream statistical information. When the system needs to adjust the communication system through aggregated flow statistics, for example, to adjust traffic, the NDE can send the aggregated flow statistics to the NSC so that the NSC can analyze the aggregated flow statistics. The NSC can send the analysis results to the policy management and control system, and the policy management and control system can adjust and control the network traffic according to the analysis results, so as to reasonably allocate network transmission paths and reduce network congestion.

With reference to the second aspect and the above implementation manners, in another implementation manner of the second aspect, before the NDE aggregates the sampled data stream according to the at least one aggregation field, the method further includes : the NDE receives the access control table ACL policy sent by the SNC; filters the sampled data stream according to the ACL policy to obtain the filtered data stream; wherein the NDE aggregates the at least one Aggregating the sampled data stream by field includes: the NDE aggregates the filtered data stream according to the at least one aggregation field.

When NDE aggregates data streams, it uses ACL policies to filter data streams, which reduces the complexity of aggregating all sampled data streams and shortens the aggregation time.

In a third aspect, a method for aggregating data streams is provided, including: a policy control system determines aggregation configuration information according to user statistical requirements, the aggregation configuration information includes at least one aggregation field, and the aggregation field is for aggregating data flows The field type to be used; the policy control system sends the aggregation configuration information to the intelligent network controller SNC, so that the SNC sends the aggregation configuration information to the traffic exporter NDE, so that the NDE performs data processing according to the aggregation configuration information The flow is sampled, and the sampled data flow is aggregated according to the at least one aggregation field.

With reference to the third aspect, in an implementation manner of the third aspect, the method further includes: the policy management and control system acquires the data flow; the policy management and control system parses the data flow to obtain the at least one aggregation field Offset; the policy control system sends the offset to the network flow data collector SNC.

The acquisition of the data flow by the above-mentioned policy control system may be realized through packet capture. Packet capture is to intercept, resend, edit, and transfer data packets transmitted in the network, and is often used for data interception.

The policy control system can receive the traffic analysis results sent by the NSC to analyze the data flow statistics, and adjust the network traffic according to the traffic analysis results, thereby reducing network congestion.

In a fourth aspect, an apparatus for aggregating data streams is provided, including: a first receiving unit, configured to receive aggregation configuration information sent by a policy management and control system according to user statistics requirements, where the aggregation configuration information includes at least one aggregation field, and the The aggregation field is the type of field on which the data streams are aggregated; the first sending unit is configured to send the aggregation configuration information received by the first receiving unit to the flow exporter NDE, so that the NDE The information samples the data flow, and aggregates the sampled data flow according to the at least one aggregation field.

With reference to the fourth aspect, in an implementation manner of the fourth aspect, the device further includes: an allocation unit configured to allocate corresponding field type values to the at least one aggregation field; wherein the first sending unit specifically uses to send the aggregation configuration information to the NDE, where the aggregation configuration information includes the at least one aggregation field and the field type value, so that the NDE samples the data flow according to the aggregation configuration information, and according to the The at least one aggregation field and the field type value are used to aggregate the sampled data stream.

With reference to the fourth aspect and the above-mentioned implementation manners, in another implementation manner of the fourth aspect, the device further includes: a second receiving unit, configured to receive the information sent by the policy management and control system and obtained by parsing the data stream. An offset of the at least one aggregation field in the data stream; a second sending unit, configured to send the offset to the NDE.

With reference to the fourth aspect and its above-mentioned implementation manners, in another implementation manner of the fourth aspect, the apparatus further includes: a determination unit configured to determine an access control list ACL policy, and the ACL policy is used to indicate that the NDE Filtering the data flow; a third sending unit, configured to send the ACL policy to the NDE.

With reference to the fourth aspect and the above implementation manners, in another implementation manner of the fourth aspect, the apparatus further includes: a fourth sending unit, configured to send the at least one aggregation field and the The corresponding relationship between the above field type values.

The apparatus for aggregating data streams provided in the fourth aspect may be used to execute the method in the foregoing first aspect or any possible implementation manner of the first aspect. Specifically, the apparatus includes a unit configured to execute the method in the foregoing first aspect or any possible implementation manner of the first aspect.

In a fifth aspect, there is provided a device for aggregating data streams, the device is executed by a traffic exporter NDE, and the device includes: a first receiving unit, configured to receive aggregation configuration information sent by an intelligent network controller SNC, the The aggregation configuration information includes at least one aggregation field, the aggregation field is the field type on which the data flow is aggregated; the second receiving unit is used to receive the data flow sent by other NDE; The aggregated configuration information received by the receiving unit samples the data stream received by the second receiving unit to obtain the sampled data stream; the aggregated unit is configured to perform the aggregated configuration information obtained by the sampling unit according to the at least one aggregated field The above sampled data streams are aggregated.

With reference to the fifth aspect, in an implementation manner of the fifth aspect, the aggregation configuration information further includes a field type value of the at least one aggregation field; wherein the aggregation unit is specifically configured to and the field type value to aggregate the sampled data stream.

With reference to the fifth aspect and the above implementation manners thereof, in another implementation manner of the fifth aspect, the device further includes: a third receiving unit configured to receive the ACL policy sent by the SNC; a filtering unit, It is used to filter the sampled data flow according to the ACL policy to obtain the filtered data flow; wherein, the aggregation unit is specifically configured to perform the filtering on the filtered data flow according to the at least one aggregation field polymerization.

The apparatus for aggregating data streams provided in the fifth aspect may be used to execute the method in the second aspect or any possible implementation manner of the second aspect. Specifically, the apparatus includes a unit for performing the method in the above second aspect or any possible implementation manner of the second aspect.

According to the sixth aspect, there is provided an apparatus for aggregating data streams, which is characterized in that it includes: a determining unit configured to determine aggregated configuration information according to statistical requirements of users, the aggregated configuration information includes at least one aggregated field, and the aggregated field The type of field on which the data flow is aggregated; the first sending unit is configured to send the aggregation configuration information determined by the determining unit to the intelligent network controller SNC, so that the SNC sends to the traffic exporter NDE The aggregation configuration information enables the NDE to sample the data stream according to the aggregation configuration information, and aggregate the sampled data stream according to the at least one aggregation field.

With reference to the sixth aspect, in an implementation manner of the sixth aspect, the device further includes: an acquiring unit, configured to acquire the data stream; an parsing unit, configured to parse the data stream, to obtain the at least An offset of an aggregation field; a second sending unit, configured to send the offset to the network traffic data collector SNC.

The apparatus for aggregating data streams provided in the sixth aspect may be used to execute the method in the third aspect or any possible implementation manner of the third aspect. Specifically, the apparatus includes a unit for performing the method in the above third aspect or any possible implementation manner of the third aspect.

The aggregation field in the above embodiment may be any field. For example, the aggregation field may be an existing field defined in a standard, such as the Request For Comments (RequestForComments, RFC) 3954 standard, the RFC7011 standard, and the like. Aggregate fields can also be user-defined fields. Aggregate fields can also be a combination of existing fields and user-defined fields.

The aggregation configuration information may include the sampling ratio, but compared to the prior art where the SNC only sends the sampling ratio to the NDE, the embodiment of the present invention adds an aggregation field to the aggregation configuration information, and can flexibly realize aggregation of different dimensions through the aggregation field need.

Aggregation in the above embodiments refers to selecting, analyzing, categorizing, and merging the mass information in the sampled data stream according to certain rules, and obtaining the aggregated stream and aggregated stream statistical information. Aggregation is often used to collect statistics on certain characteristic data streams. For example, in the embodiment of the present invention, data streams with the specified aggregation field and the same field type value can be aggregated.

The policy management and control system can ultimately adjust the network traffic by means of aggregating data streams in the above embodiments. The method of aggregating data streams in the embodiment of the present invention can not only be used to regulate network traffic, but also can be used in other scenarios of network planning, such as network charging, network security, and the like.

Description of drawings

In order to more clearly illustrate the technical solutions of the embodiments of the present invention, the following will briefly introduce the accompanying drawings required in the embodiments of the present invention. Obviously, the accompanying drawings described below 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.

Fig. 1 is a schematic diagram of an application scenario of a communication system to which an embodiment of the present invention can be applied.

Fig. 2 is a schematic flowchart of a method for aggregating data streams according to an embodiment of the present invention.

Fig. 3 is a schematic interaction diagram of aggregating data flows in an SDN scenario to regulate network traffic according to an embodiment of the present invention.

Fig. 4 is a block diagram of an apparatus for aggregating data streams according to an embodiment of the present invention.

Fig. 5 is a block diagram of an apparatus for aggregating data streams according to another embodiment of the present invention.

Fig. 6 is a block diagram of an apparatus for aggregating data streams according to yet another embodiment of the present invention.

Fig. 7 is a block diagram of an apparatus for aggregating data streams according to an embodiment of the present invention.

Fig. 8 is a block diagram of an apparatus for aggregating data streams according to another embodiment of the present invention.

Fig. 9 is a block diagram of an apparatus for aggregating data streams according to yet another embodiment of the present invention.

detailed description

The following will clearly and completely describe the technical solutions in the embodiments of the present invention with reference to the drawings in the embodiments of the present invention. Obviously, the described embodiments are part of the embodiments of the present invention, not all of them. Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art without making creative efforts shall fall within the protection scope of the present invention.

Fig. 1 is a schematic diagram of an application scenario of a communication system to which an embodiment of the present invention can be applied.

The communication system in FIG. 1 includes a switch 101 , a switch 102 , a switch 103 , a switch 104 , a switch 105 , a switch 106 and a controller 107 . In the figure, a solid line represents a normal transmission service path, and a dotted line represents a congested link. It can be seen that congestion occurs between switch 102 and switch 105 . There may also be other paths for the data flow to reach the switch 102 from the switch 105, and dashed lines with arrows in FIG. 1 indicate other transmission paths. For example, the transmission path is switch 105-switch 106-switch 101-switch 102, or switch 105-switch 104-switch 103-switch 102. When the link between the switch 102 and the switch 105 is congested, the controller can adjust part of the traffic to other transmission paths by adjusting the network traffic. For example, part of the traffic is adjusted to the detour transmission path indicated by the dotted line in FIG. 1 .

In order for the controller to adjust traffic, it needs to present traffic at different levels of granularity in the network. In an SDN scenario, the SNC can send the sampling ratio to the NDE, and sample the forwarded data flow on the NDE interface through which the data flow passes, then aggregate and collect statistics on the data flow, and finally summarize the aggregated flow data of different dimensions into NSC. The NSC can analyze the traffic data and send the analysis results to the policy management and control system. Finally, through the policy management and control system, the aggregated traffic based on the specified aggregation field can be allocated reasonably. However, NDE needs to rely on the developed aggregation mode to realize the aggregation of data streams. When a user wants to count the aggregation flow traffic of an aggregation mode that has not yet been developed, a new aggregation mode should be developed according to the user's needs first. This cannot meet the user's demand for real-time and flexible aggregation flow statistics based on any set of aggregation fields. Embodiments of the present invention provide a method for flexibly acquiring data stream aggregation based on different aggregation fields. When the aggregation method in the embodiment of the present invention is applied to network traffic regulation, network traffic regulation based on different dimensions can be quickly and flexibly realized.

Fig. 2 is a schematic flowchart of a method for aggregating data streams according to an embodiment of the present invention.

The system of an embodiment of the present invention includes NDE, SNC and policy management and control system. Wherein, the SNC may be a controller, and the NDE may be a switch or a router. The SNC can deliver configurations to the NDE, so that the NDE performs operations according to the configurations.

201. The policy control system determines aggregated configuration information.

The policy management and control system can determine aggregated configuration information according to user statistical requirements. The aggregated configuration information includes at least one aggregated field. The aggregation field may be a field type based on which data streams are aggregated.

202. The policy control system sends aggregation configuration information to the SNC.

After determining the aggregated configuration information, the policy control system may send the aggregated configuration information to the SNC.

203. The SNC sends aggregation configuration information to the NDE.

After receiving the aggregation configuration information, the SNC can deliver the aggregation configuration information to the NDE.

204. The NDE samples the received data stream, and aggregates the sampled data stream.

After receiving the aggregation configuration information, the NDE may sample the data flow according to the sampling ratio in the aggregation configuration information, and the data flow may be a data flow forwarded to the NDE by other NDEs. NDE can also aggregate the sampled data streams, and aggregate data streams with the same characteristics together.

In the above embodiment, the SNC sends the aggregation configuration information used to aggregate the data streams to the NDE, so that the NDE can sample and aggregate the data streams according to the aggregation configuration information, so that the system no longer needs to meet different statistical requirements of users Develop a variety of aggregation modes, which can flexibly meet users' aggregation needs in real time, reduce development costs, and shorten the aggregation time of data streams.

Fig. 3 is a schematic interaction diagram of aggregating data flows in an SDN scenario to regulate network traffic according to an embodiment of the present invention.

The basic network flow (NetStream) data collection and analysis system of an embodiment of the present invention includes NDE, NSC, SNC and policy management and control system. Wherein, the NDE may be a switch or a router, and is used to collect data flow information, and send the collected data flow information to the NSC. The NSC can perform preliminary analysis and processing on the data flow information, and send the analysis and processing results to the policy control system. The policy control system can plan the network based on the analysis and processing results, for example, for billing and network traffic adjustment.

The aggregation field in this embodiment of the present invention may be a field defined in a standard, or a user-defined field.

301. The NDE receives the forwarded data flow.

When the data flow passes through the NDE, the NDE can receive the data flow forwarded by other NDEs.

302. The policy control system may capture packets of data streams forwarded in the NDE.

The policy control system can capture packets of the data flow forwarded by the NDE according to the user's statistical requirements.

Step 302 is an optional step. After the policy control system captures the packet, it can analyze the captured data flow to obtain the offset of the aggregation field in the data flow. When the user only counts existing fields in the existing standard, step 302 may not be performed. When the user needs to count user-defined fields, the policy control system can obtain the offset of the user-defined fields in the data stream through packet capture.

303. The policy control system determines aggregated configuration information.

The policy management and control system may include a network manager, and the network manager may learn user requirements and determine aggregated configuration information according to the user requirements. The aggregation configuration information includes at least one aggregation field, and the aggregation field can be used to describe the type of field on which the NDE aggregates the data stream.

Optionally, when the policy control system obtains the offset of the aggregation field in the data stream in step 302, the offset may also be included in the aggregation configuration information.

304. The policy control system sends aggregated configuration information to the SNC.

The policy control system can send flexible aggregated configuration information to the SNC. That is, the policy control system can send aggregated configuration information to the SNC according to the user's statistical requirements. Optionally, the aggregation configuration information may also include the offset of the aggregation field in the data stream.

305. The SNC assigns a field type value to the aggregation field.

SNC can assign field type values to aggregated fields. The field type value is the value corresponding to the field. For fields that are not defined in the standard, their corresponding values are not defined in the standard. SNC can assign field type values for aggregated fields. There is a one-to-one correspondence between aggregated fields and field type values.

Step 305 is an optional step. SNC can assign field type values to user-defined fields when they are included in the aggregation field. Whether the SNC assigns field type values to the fields defined in the standard is not limited in this embodiment of the present invention.

306. The SNC sends the aggregation configuration information to the NDE.

The SNC can send aggregated configuration information to the NDE. The SNC may send the aggregation field to the NDE separately, or send the aggregation field and the field type value corresponding to the aggregation field to the NDE at the same time, or send the field type value corresponding to each aggregation field to the NDE separately.

307. The SNC sends the correspondence between the aggregation field and the field type value to the NSC.

The NSC can only identify the field type value, and the SNC can send the correspondence between the aggregation field and the field type value to the NSC, so that the NSC can use the corresponding relationship between the aggregation field and the field type value after receiving the aggregation flow statistics information carrying the field type value Analyze aggregated flow traffic.

308. The NDE samples the data stream.

In order to realize the aggregation of data streams by NDE, it first needs to sample the data streams to obtain the sampled data streams. By setting an appropriate sampling interval, it is possible to reduce the statistical quantity of data flow while ensuring that the collected statistical information basically correctly reflects the data flow status of the entire network. In addition, sampling the data stream can also reduce the impact on the forwarding performance of the device.

309. The SNC determines whether to match the ACL policy.

The SNC can set an ACL policy so that the NDE can filter out some data flows through the ACL policy.

310. The SNC sends the ACL policy to the NDE.

When the SNC determines to match the ACL policy, the SNC can send the ACL policy to the NDE.

311. The NDE may filter the received data flow according to the ACL policy.

NDE can filter out some sampled data streams that cannot be aggregated through ACL filtering. In this way, when NDE aggregates data streams, it can reduce the complexity of aggregating all sampled data streams and shorten the aggregation time.

Steps 309 to 311 are all optional steps. In one embodiment of the present invention, the NDE may directly aggregate the sampled data streams without ACL filtering on the sampled data streams.

312. The NDE aggregates and collects statistics on the data stream.

NDE can aggregate and count the sampled data streams according to the aggregation configuration information, or aggregate and count the sampled and filtered data streams to obtain aggregated streams and aggregated stream statistics. For example, NDE can combine data flows with the same aggregation field to obtain the packet length, bytes, etc. of the aggregation flow.

313. The NDE sends the aggregated flow statistics to the NSC.

The NDE can send aggregated flow statistics to the NSC, for example, send data flow packet length and bytes. The NDE can only send the statistical information of the aggregated flow to the corresponding NSC. In this way, the aggregated data flow does not need to send the statistical information of each data flow, which can reduce the occupation of network bandwidth.

314. The NSC analyzes the traffic.

The NSC can analyze the traffic of the aggregated flow based on the received statistical information of the aggregated flow, and obtain the traffic analysis result. For example, the transmission rate of the data stream can be obtained from the packet length and bytes of the data stream, and then the traffic of the aggregated stream can be obtained.

315. The NSC sends the traffic analysis result to the policy control system.

In order to regulate the traffic, the NSC can send the traffic analysis result to the policy control system after obtaining the traffic analysis result.

316. The policy control system adjusts the traffic according to the traffic analysis result.

The policy control system can adjust traffic according to traffic analysis results.

It should be understood that the embodiments of the present invention can be used not only in SDN networks, but also in other traditional fixed networks. When the embodiment of the present invention is applied to other networks, the execution subject of each execution step is no longer the SNC, NDE, NSC, and policy control system, but the corresponding device with corresponding functions in the network.

Step 313 to step 316 are optional steps. After the NDE aggregates the data streams in step 312, the aggregated streams or aggregated stream statistical information can be used for traffic statistics, and steps 313 to 316 are performed, and the aggregated streams or aggregated stream statistical information can also be used in other scenarios. For example, the aggregated flow or aggregated flow statistical information may be sent to the analysis system, so as to implement analysis on network charging, etc., and then perform network charging adjustment.

The method for aggregating data streams according to an embodiment of the present invention is described in detail above with reference to FIG. 2 and FIG. 3 , and the apparatus for aggregating data streams according to an embodiment of the present invention will be described in detail below in conjunction with FIG. 4 to FIG. 9 .

FIG. 4 shows an apparatus 10 for aggregating data streams according to an embodiment of the present invention, and the apparatus 10 may be an SNC. The device 10 in FIG. 4 may be a first receiving unit 11 and a first sending unit 12 .

The first receiving unit 11 is configured to receive the aggregated configuration information sent by the policy management and control system according to user statistics requirements. The aggregation configuration information includes at least one aggregation field, and the aggregation field is a field type based on which data streams are aggregated.

The first sending unit 12 is configured to send the aggregation configuration information received by the first receiving unit to the traffic exporter NDE, so that the NDE samples the data flow according to the aggregation configuration information, and aggregates the sampled data flow according to at least one aggregation field.

In the embodiment of the present invention, the SNC can obtain aggregation configuration information from the policy management and control system according to user requirements, and deliver the aggregation configuration information to the NDE. The aggregation configuration information includes the aggregation fields used to aggregate data streams, so that the NDE can use Aggregate configuration information to sample the data stream, and aggregate the sampled data stream according to the aggregation field, which can solve the technical problem in the existing technology that needs to develop multiple aggregation modes according to user needs, and can flexibly meet the user's aggregation needs in real time .

The apparatus 10 for aggregating data streams according to the embodiment of the present invention may correspond to the SNC in the method for aggregating data streams in the embodiment of the present invention. Each unit/module and other operations or functions in the device 10 are for realizing the corresponding flow of the SNC in the method flowchart 2 and FIG. 3 respectively, and for the sake of brevity, details are not repeated here.

FIG. 5 shows an apparatus 20 for aggregating data streams provided by an embodiment of the present invention, and the apparatus 20 may be an NDE. The apparatus 20 in FIG. 5 may include a first receiving unit 21 , a second receiving unit 22 , a sampling unit 23 and an aggregation unit 24 .

The first receiving unit 21 is configured to receive the aggregation configuration information sent by the intelligent network controller SNC. The aggregation configuration information includes at least one aggregation field, and the aggregation field is a field type based on which data streams are aggregated.

The second receiving unit 22 is configured to receive data streams sent by other NDEs.

The sampling unit 23 is configured to sample the data stream received by the second receiving unit according to the aggregation configuration information received by the first receiving unit, to obtain the sampled data stream.

The aggregation unit 24 is configured to aggregate the sampled data stream obtained by the sampling unit according to at least one aggregation field.

In the embodiment of the present invention, the NDE samples the data stream according to the aggregation configuration information sent by the SNC, and aggregates the sampled data stream according to the aggregation field, so that the user's aggregation requirements can be flexibly met in real time.

The apparatus 20 for aggregating data streams according to the embodiment of the present invention may correspond to the NDE in the method for aggregating data streams in the embodiment of the present invention. Each unit/module and other operations or functions in the device 20 are to realize the corresponding flow of the NDE in the method flowchart 2 and FIG. 3 respectively, and for the sake of brevity, details are not repeated here.

FIG. 6 shows an apparatus 30 for aggregating data streams according to an embodiment of the present invention, and the apparatus 30 may be a policy control system. The device 30 in FIG. 6 includes a determining unit 31 and a first sending unit 32 .

The determining unit 31 is configured to determine the aggregated configuration information according to the statistical requirements of the user. The aggregation configuration information includes at least one aggregation field, and the aggregation field is a field type based on which data streams are aggregated.

The first sending unit 32 is configured to send the aggregation configuration information determined by the determination unit to the intelligent network controller SNC, so that the SNC sends the aggregation configuration information to the flow exporter NDE, so that the NDE samples the data flow according to the aggregation configuration information, And aggregate the sampled data stream according to at least one aggregation field.

The policy management and control system in the embodiment of the present invention can obtain aggregation configuration information according to user statistical requirements, and deliver the aggregation configuration information to the NDE through the SNC, where the aggregation configuration information includes aggregation fields used for aggregation of data streams. In this way, NDE can sample the data flow according to the aggregation configuration information, and aggregate the sampled data flow according to the aggregation field, so as to solve the technical problem in the existing technology that needs to develop multiple aggregation modes according to user needs, and can flexibly meet the requirements in real time. Aggregation needs of users.

The device 30 for aggregating data streams according to the embodiment of the present invention may correspond to the policy control system in the method for aggregating data streams in the embodiment of the present invention. Each unit/module and other operations or functions in the device 30 are to realize the corresponding flow of the method flow chart 2 and the policy management and control system in FIG.

FIG. 7 shows an apparatus 40 for aggregating data streams according to an embodiment of the present invention, and the apparatus 40 may be an SNC. The device 40 may comprise a transmitter 41 , a receiver 42 , a processor 43 , a memory 44 and a bus system 45 .

The receiver 42 is configured to receive the aggregated configuration information sent by the policy management and control system according to user statistical requirements. The aggregation configuration information includes at least one aggregation field, and the aggregation field is a field type based on which data streams are aggregated.

The transmitter 41 is configured to send the aggregation configuration information received by the first receiving unit to the traffic exporter NDE, so that the NDE samples the data flow according to the aggregation configuration information, and aggregates the sampled data flow according to at least one aggregation field.

In the embodiment of the present invention, the SNC can obtain aggregation configuration information from the policy management and control system according to user requirements, and deliver the aggregation configuration information to the NDE. The aggregation configuration information includes the aggregation fields used to aggregate data streams, so that the NDE can use Aggregate configuration information to sample the data stream, and aggregate the sampled data stream according to the aggregation field, which can solve the technical problem in the existing technology that needs to develop multiple aggregation modes according to user needs, and can flexibly meet the user's aggregation needs in real time .

The device 40 for aggregating data streams according to the embodiment of the present invention may correspond to the SNC in the method for aggregating data streams in the embodiment of the present invention. Each device and other operations or functions in the device 40 are to realize the corresponding flow of the SNC in the method flowchart 2 and FIG. 3 respectively, and for the sake of brevity, details are not repeated here.

FIG. 8 shows an apparatus 50 for aggregating data streams provided by an embodiment of the present invention, and the apparatus 50 may be an NDE. The device 50 may comprise a receiver 51 , a processor 52 , a memory 53 and a bus system 54 .

The receiver 51 is configured to receive aggregation configuration information sent by the intelligent network controller SNC. The aggregation configuration information includes at least one aggregation field, and the aggregation field is a field type based on which data streams are aggregated.

The receiver 51 is also used to receive data streams sent by other NDEs.

The processor 52 is configured to sample the data stream received by the second receiving unit according to the aggregation configuration information received by the first receiving unit, to obtain a sampled data stream.

The processor 52 is further configured to aggregate the sampled data stream obtained by the sampling unit according to at least one aggregation field.

In the embodiment of the present invention, the NDE samples the data stream according to the aggregation configuration information sent by the SNC, and aggregates the sampled data stream according to the aggregation field, so that the user's aggregation requirements can be flexibly met in real time.

The apparatus 50 for aggregating data streams according to the embodiment of the present invention may correspond to the NDE in the method for aggregating data streams in the embodiment of the present invention. Each device and other operations or functions in the apparatus 50 are to realize the corresponding flow of the NDE in the method flowchart 2 and FIG. 3 respectively, and for the sake of brevity, details are not repeated here.

FIG. 9 shows an apparatus 60 for aggregating data streams according to an embodiment of the present invention, and the apparatus 60 may be a policy control system. The device 60 may comprise a transmitter 61 , a receiver 62 , a processor 63 , a memory 64 and a bus system 65 .

The processor 63 is configured to determine the aggregated configuration information according to the statistical requirements of the user. The aggregated configuration information includes at least one aggregated field. Aggregated fields are the type of fields by which data streams are aggregated.

The transmitter 61 is used to send the aggregation configuration information determined by the determination unit to the intelligent network controller SNC, so that the SNC sends the aggregation configuration information to the traffic exporter NDE, so that the NDE samples the data flow according to the aggregation configuration information, and according to at least one The aggregation field aggregates the sampled data stream.

The policy management and control system in the embodiment of the present invention can obtain aggregation configuration information according to user statistical requirements, and deliver the aggregation configuration information to the NDE through the SNC, where the aggregation configuration information includes aggregation fields used for aggregation of data streams. In this way, NDE can sample the data flow according to the aggregation configuration information, and aggregate the sampled data flow according to the aggregation field, so as to solve the technical problem in the existing technology that needs to develop multiple aggregation modes according to user needs, and can flexibly meet the requirements in real time. Aggregation needs of users.

The device 60 for aggregating data streams according to the embodiment of the present invention may correspond to the policy control system in the method for aggregating data streams in the embodiment of the present invention. Each device and other operations or functions in the device 60 are for implementing the corresponding flow of the method flowchart 2 and the NDE in FIG. 3 , and for the sake of brevity, details are not described here.

Various components in the above-mentioned apparatus 40, apparatus 50, and apparatus 60, such as a receiver, a transmitter, a processor, and a memory, may be coupled together through a bus system. Wherein, besides the data bus, the bus system may also include a power bus, a control bus and a status signal bus. However, for the sake of clarity, the various buses are labeled as bus systems in the figures. The above-mentioned device 40, device 50 and device 60 may also include a memory and a processor. The memory, which can include read only memory and random access memory, provides instructions and data to the processor. A portion of the memory may also include non-volatile random access memory. For example, memory may store aggregated configuration information. The processor can be used to execute the instructions stored in the memory, and when the processor executes the instructions, the processor can execute the corresponding processes of the corresponding devices in FIG. 2 and FIG. 3 of the above method embodiment, and for the sake of brevity, details are not repeated here.

The processor can be a general-purpose processor, a digital signal processor, an application-specific integrated circuit, a field programmable gate array or other programmable logic device, a discrete gate or transistor logic device, or a discrete hardware component, and can implement or execute the Disclosed methods, steps and logic block diagrams. A general purpose processor may be a microprocessor or any conventional processor or the like.

It should be understood that reference throughout this specification to "one embodiment" or "an embodiment" means that a particular feature, structure, or characteristic related to the embodiment is included in at least one embodiment of the present invention. Thus, appearances of "in one embodiment" or "in an embodiment" in various places throughout the specification are not necessarily referring to the same embodiment. Furthermore, the particular features, structures or characteristics may be combined in any suitable manner in one or more embodiments.

It should be understood that in various embodiments of the present invention, the sequence numbers of the above-mentioned processes do not mean the order of execution, and the execution order of each process should be determined by its functions and internal logic, rather than by the embodiment of the present invention. The implementation process constitutes any limitation.

It should be understood that in the embodiment of the present invention, "B corresponding to A" means that B is associated with A, and B can be determined according to A. However, it should also be understood that determining B according to A does not mean determining B only according to A, and B may also be determined according to A and/or other information.

Those skilled in the art can realize that the method steps and units described in the embodiments disclosed herein can be realized by electronic hardware, computer software, or a combination of the two. In order to clearly illustrate the possibility of hardware and software For interchangeability, in the above description, the steps and components of each embodiment have been generally described according to their functions. Whether these functions are executed by hardware or software depends on the specific application and design constraints of the technical solution. Those of ordinary skill in the art may use different methods to implement the described functions for each particular application, but such implementation should not be regarded as exceeding the scope of the present invention.

The methods or steps described in connection with the embodiments disclosed herein may be implemented by hardware, software programs executed by a processor, or a combination of both. The software program can be placed in random access memory (RAM), internal memory, read-only memory (ROM), electrically programmable ROM, electrically erasable programmable ROM, registers, hard disk, removable disk, CD-ROM, or any other Any other known storage medium.

Although the present invention has been described in detail in connection with preferred embodiments with reference to the accompanying drawings, the present invention is not limited thereto. Without departing from the spirit and essence of the present invention, those skilled in the art can make various equivalent modifications or replacements to the embodiments of the present invention, and these modifications or replacements should all fall within the scope of the present invention.

Claims (20)

1. a method for aggregate data flow, is characterized in that, comprising:

Intelligent network controller SNC receives the aggregation configuration information that tactful managing and control system sends according to user's statistical demand, and described aggregation configuration information comprises at least one Aggregation field, and described Aggregation field is for carrying out the field type being polymerized institute's foundation to data stream;

Described SNC sends described aggregation configuration information to NetStream Data Exporter NDE, so that described NDE samples to data stream according to described aggregation configuration information, and is polymerized the data flow after sampling according at least one Aggregation field described.

2. the method as described in right 1, is characterized in that, described method also comprises:

Described SNC is that at least one Aggregation field described distributes corresponding field type value respectively;

Wherein, described SNC sends aggregation configuration information to NetStream Data Exporter NDE, described aggregation configuration information comprises at least one Aggregation field described, so that described NDE samples to data stream according to described aggregation configuration information, and according at least one Aggregation field described, data flow after sampling is carried out polymerization and is comprised:

Described SNC sends described aggregation configuration information to described NDE, described aggregation configuration information comprises at least one Aggregation field described and described field type value, so that described NDE samples to data stream according to described aggregation configuration information, and according at least one Aggregation field described and described field type value, the data flow after sampling is polymerized.

3. method as claimed in claim 1 or 2, it is characterized in that, described method also comprises:

Described SNC receives the side-play amount of at least one Aggregation field described in described data flow obtained by the described data flow of parsing that described tactful managing and control system sends;

Described SNC sends described side-play amount to described NDE.

4. the method according to any one of claim 1-3, is characterized in that, described method also comprises:

Described SNC determines access control list ACL strategy, and described ACL strategy is used to indicate described NDE and filters described data flow;

Described SNC sends described ACL strategy to described NDE.

5. the method according to any one of claim 1-4, is characterized in that, described method also comprises:

Described SNC sends the corresponding relation of at least one Aggregation field described and described field type value to intelligent network controller NSC.

6. a method for aggregate data flow, is characterized in that, comprising:

NetStream Data Exporter NDE receives the aggregation configuration information that intelligent network controller SNC sends, and described aggregation configuration information comprises at least one Aggregation field, and described Aggregation field is for carrying out the field type being polymerized institute's foundation to data stream;

Described NDE receives the data flow that other NDE sends;

The described data flow that described NDE receives according to described aggregation configuration information butt joint is sampled, and obtains the data flow after sampling;

Described NDE is polymerized the data flow after described sampling according at least one Aggregation field described.

7. method as claimed in claim 6, is characterized in that, described aggregation configuration information also comprises the field type value of at least one Aggregation field described;

Wherein, described NDE carries out polymerization according at least one Aggregation field described to the data flow after described sampling and comprises:

Described NDE is polymerized the data flow after described sampling according at least one Aggregation field described and described field type value.

8. method as claimed in claims 6 or 7, is characterized in that, before described NDE to be polymerized the data flow after described sampling according at least one Aggregation field described, described method also comprises:

Described NDE receives the access control list ACL strategy that described SNC sends;

According to described ACL strategy, the data flow after described sampling is filtered, obtain the data flow after filtering;

Wherein, described NDE carries out polymerization according at least one Aggregation field described to the data flow after described sampling and comprises:

Described NDE is polymerized the data flow after described filtration according at least one Aggregation field described.

9. a method for aggregate data flow, is characterized in that, comprising:

Strategy managing and control system is according to the statistical demand determination aggregation configuration information of user, and described aggregation configuration information comprises at least one Aggregation field, and described Aggregation field is for carrying out the field type being polymerized institute's foundation to data stream;

Strategy managing and control system sends described aggregation configuration information to described intelligent network controller SNC, so that described SNC sends described aggregation configuration information to NetStream Data Exporter NDE, NDE is sampled to data stream according to described aggregation configuration information, and according at least one Aggregation field described, data flow after sampling is polymerized.

10. method as claimed in claim 9, it is characterized in that, described method also comprises:

Strategy managing and control system obtains described data flow;

Strategy managing and control system is resolved described data flow, obtains the side-play amount of at least one Aggregation field described;

Strategy managing and control system sends described side-play amount to network flow data gatherer SNC.

The device of 11. 1 kinds of aggregate data flow, is characterized in that, comprising:

First receiving element, for receiving the aggregation configuration information that tactful managing and control system sends according to user's statistical demand, described aggregation configuration information comprises at least one Aggregation field, and described Aggregation field is for carrying out the field type being polymerized institute's foundation to data stream;

First transmitting element, for sending the described aggregation configuration information that described first receiving element receives to NetStream Data Exporter NDE, so that described NDE samples to data stream according to described aggregation configuration information, and according at least one Aggregation field described, data flow after sampling is polymerized.

12. devices as described in right 11, it is characterized in that, described device also comprises:

Allocation units, for distributing corresponding field type value respectively at least one Aggregation field described;

Wherein, first transmitting element is specifically for sending described aggregation configuration information to described NDE, described aggregation configuration information comprises at least one Aggregation field described and described field type value, so that described NDE samples to data stream according to described aggregation configuration information, and according at least one Aggregation field described and described field type value, the data flow after sampling is polymerized.

13. devices as described in claim 11 or 12, it is characterized in that, described device also comprises:

Second receiving element, for receive that described tactful managing and control system sends obtained by the described data flow of parsing described in the side-play amount of at least one Aggregation field in described data flow;

Second transmitting element, for sending described side-play amount to described NDE.

14. devices according to any one of claim 11-13, it is characterized in that, described device also comprises:

Determining unit, for determining access control list ACL strategy, described ACL strategy is used to indicate described NDE and filters described data flow;

3rd transmitting element, for sending described ACL strategy to described NDE.

15. devices according to any one of claim 11-14, it is characterized in that, described device also comprises:

4th transmitting element, for sending the corresponding relation of at least one Aggregation field described and described field type value to intelligent network controller NSC.

The device of 16. 1 kinds of aggregate data flow, is characterized in that, described device is performed by NetStream Data Exporter NDE, and described device comprises:

First receiving element, for receiving the aggregation configuration information that intelligent network controller SNC sends, described aggregation configuration information comprises at least one Aggregation field, and described Aggregation field is for carrying out the field type being polymerized institute's foundation to data stream;

Second receiving element, for receiving the data flow that other NDE sends;

Sampling unit, samples to the described data flow that the second receiving element receives for the described aggregation configuration information received according to described first receiving element, obtains the data flow after sampling;

Polymerized unit, is polymerized for the data flow after the described sampling that obtains described sampling unit according at least one Aggregation field described.

17. devices as claimed in claim 16, is characterized in that, described aggregation configuration information also comprises the field type value of at least one Aggregation field described;

Wherein, described polymerized unit is specifically for being polymerized the data flow after described sampling according at least one Aggregation field described and described field type value.

18. devices as described in claim 16 or 17, it is characterized in that, described device also comprises:

3rd receiving element, for receiving the access control list ACL strategy that described SNC sends;

Filter element, for filtering the data flow after described sampling according to described ACL strategy, obtains the data flow after filtering;

Wherein, described polymerized unit is specifically for being polymerized the data flow after described filtration according at least one Aggregation field described.

The device of 19. 1 kinds of aggregate data flow, is characterized in that, comprising:

Determining unit, for the statistical demand determination aggregation configuration information according to user, described aggregation configuration information comprises at least one Aggregation field, and described Aggregation field is for carrying out the field type being polymerized institute's foundation to data stream;

First transmitting element, for sending the described aggregation configuration information that described determining unit is determined to described intelligent network controller SNC, so that described SNC sends described aggregation configuration information to NetStream Data Exporter NDE, NDE is sampled to data stream according to described aggregation configuration information, and according at least one Aggregation field described, data flow after sampling is polymerized.

20. devices as claimed in claim 19, it is characterized in that, described device also comprises:

Acquiring unit, for obtaining described data flow;

Resolution unit, for resolving described data flow, obtains the side-play amount of at least one Aggregation field described;

Second transmitting element, for sending described side-play amount to network flow data gatherer SNC.