WO2014161281A1 - 联机处理数据的方法、设备及系统 - Google Patents

联机处理数据的方法、设备及系统 Download PDF

Info

Publication number
WO2014161281A1
WO2014161281A1 PCT/CN2013/084374 CN2013084374W WO2014161281A1 WO 2014161281 A1 WO2014161281 A1 WO 2014161281A1 CN 2013084374 W CN2013084374 W CN 2013084374W WO 2014161281 A1 WO2014161281 A1 WO 2014161281A1
Authority
WO
WIPO (PCT)
Prior art keywords
user
data
business volume
business
information
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.)
Ceased
Application number
PCT/CN2013/084374
Other languages
English (en)
French (fr)
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.)
Huawei Technologies Co Ltd
Original Assignee
Huawei Technologies 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 Huawei Technologies Co Ltd filed Critical Huawei Technologies Co Ltd
Priority to JP2015524630A priority Critical patent/JP6100900B2/ja
Priority to KR1020157001746A priority patent/KR20150023857A/ko
Priority to RU2015105984A priority patent/RU2612570C2/ru
Priority to EP13881196.3A priority patent/EP2857992A4/en
Publication of WO2014161281A1 publication Critical patent/WO2014161281A1/zh
Priority to US14/868,000 priority patent/US20160020982A1/en
Anticipated expiration legal-status Critical
Ceased legal-status Critical Current

Links

Classifications

    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/27—Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
    • H04L41/50—Network service management, e.g. ensuring proper service fulfilment according to agreements
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/28—Databases characterised by their database models, e.g. relational or object models
    • G06F16/283—Multi-dimensional databases or data warehouses, e.g. MOLAP or ROLAP
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L43/00—Arrangements for monitoring or testing data switching networks
    • H04L43/08—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters
    • H04L43/0876—Network utilisation, e.g. volume of load or congestion level

Definitions

  • the present invention relates to data processing techniques, and more particularly to a method, apparatus, and system for processing data online. Background technique
  • An On-Line Transaction Processing (OLAP) server is usually set up in each subnet of the operator to obtain the traffic of each subnet.
  • OLAP On-Line Transaction Processing
  • an OLAP server in each subnet obtains the traffic of each user, and then manually exports the traffic data of all users in the OLAP server as A Comma Separated Value (CSV) file, manually importing the CSV file into a separate database, and summarizing the traffic data of all users in the independent database to generate a central report.
  • CSV Comma Separated Value
  • Embodiments of the present invention provide a method, device, and system for processing data online to improve the efficiency of processing data online.
  • an embodiment of the present invention provides a method for processing data online, including: sending a data request message to at least one sub-line analysis processing OLAP server; receiving user service data information sent by the at least one sub-OLAP server, The user service data information includes the traffic volume information of the roaming user and the traffic volume information of the non-roaming user that satisfies the first condition parameter, where the traffic volume information includes the user identifier and the corresponding traffic volume;
  • the service total amount information of each user that meets the second condition parameter is identified by the sum of the corresponding traffic volume, where the service total amount information includes the user identifier and the corresponding sum of the service volumes.
  • the service quantity summation is performed based on the user identifier and the corresponding traffic volume, and the sum of the service volumes corresponding to the user identifier is satisfied.
  • the total amount of business information of each user of the second condition parameter includes:
  • the total traffic volume information of each user that satisfies the second condition parameter is determined.
  • the data request message carries a data reporting parameter, where the data reporting parameter includes any one of the following or The combination is: a service type parameter to be counted, a statistical time period parameter, and the first condition parameter.
  • the first condition parameter is that the traffic volume is greater than the first a condition parameter of a preset threshold, or a condition parameter in which the traffic is ranked before the first preset ranking among the traffic of all non-roaming users;
  • the second condition parameter is a condition parameter that the sum of the traffic volume is greater than the second preset threshold, or the condition parameter that the sum of the traffic volume is ranked before the second preset ranking in the sum of the traffic of all users.
  • the user identifier and the corresponding The service volume is summed with the traffic, and after the sum of the traffic volume corresponding to the user identifier and the service total information of each user that meets the second condition parameter is obtained, the method further includes:
  • a multi-dimensional traffic graph is generated based on the total amount of business information of each user that satisfies the second condition parameter.
  • each of the sub-line analysis processing OLAP servers are set in different geography region.
  • an embodiment of the present invention provides a method for processing data online, including: receiving a data request message sent by a central online analysis processing OLAP server, and acquiring the data request with the data request The data reporting parameter associated with the message;
  • the user service data information includes the traffic volume information of the roaming user and the non-roaming user that satisfies the first condition parameter.
  • Traffic information where the traffic information includes a user identifier and a corresponding traffic volume;
  • the calculating, by the data reporting parameter, the traffic volume of the roaming user and the non-roaming user, before obtaining the user service data information :
  • each user traffic information includes a user identifier of the user, a single traffic volume of the user, a home location identifier of the user, and generating the single traffic volume Geographical area identifier;
  • Determining that the user is a roaming user and determining, according to the data reporting parameter, all user services including the user identifier, if the home location identifier of the user is inconsistent with the geographic area identifier that generates the single service volume.
  • the single traffic in the quantity information is counted, and the traffic information of the roaming user is obtained;
  • Determining that the user is a non-roaming user and determining, according to the data reporting parameter, all users that include the user identifier, if the home location identifier of the user is consistent with the geographic area identifier that generates the single-time traffic volume.
  • the traffic of the non-roaming user in the traffic information is obtained, and the traffic volume of the non-roaming user is obtained according to the traffic volume of all the non-roaming users.
  • the data reporting parameter includes any one or a combination of the following: a service type parameter to be counted, a statistical time period parameter, the first Conditional parameter
  • the data reporting parameter includes a service type parameter to be counted
  • the data is based on the data
  • the reporting parameter is used to collect statistics on the service volume of the roaming user and the non-roaming user
  • the information about the user service data includes: collecting statistics on the service quantity of the service type parameter to be counted by the roaming user and the non-roaming user, and obtaining the user service data information.
  • the data reporting parameter includes the statistic time period parameter
  • the statistic is performed on the service quantity of the roaming user and the non-roaming user according to the data reporting parameter, and the user service data information is obtained by: the roaming user and the non-roaming user are corresponding to:
  • the traffic of the statistical time period parameter is counted to obtain user service data information.
  • the first condition parameter is that the traffic volume is greater than the first a condition parameter of a preset threshold, or a condition parameter in which the traffic is ranked before the first preset ranking among the traffic of all non-roaming users;
  • the second condition parameter is a condition parameter that the sum of the traffic volume is greater than the second preset threshold, or the condition parameter that the sum of the traffic volume is ranked before the second preset ranking in the sum of the traffic of all users.
  • the acquiring the data associated with the data request message includes:
  • the obtaining the data report parameter associated with the data request message includes:
  • Extracting the carried data reporting parameter from the data request message Extracting the carried data reporting parameter from the data request message.
  • the embodiment of the present invention provides a central online analysis processing server, including: a sending module, configured to send a data request message to at least one sub-line analysis processing OLAP server;
  • a receiving module configured to receive user service data information sent by the at least one sub-OLAP server, where the user service data information includes traffic information of the roaming user and traffic information of the non-roaming user that satisfies the first condition parameter,
  • the traffic information includes the user identifier and the corresponding traffic volume;
  • a processing module configured to perform traffic summation based on the user identifier and the corresponding traffic volume, and obtain a total traffic volume of each user that satisfies the second condition parameter by the total traffic volume corresponding to the user identifier
  • the information, the service total information includes the user identifier and the corresponding sum of the traffic.
  • the processing module is specifically configured to:
  • the total traffic volume information of each user that satisfies the second condition parameter is determined.
  • the sending module is specifically configured to: send a data request that carries a data reporting parameter to the at least one sub OLAP server
  • the data reporting parameter includes any one or a combination of the following: a service type parameter to be counted, a statistical time period parameter, and the first condition parameter.
  • the processing module is further configured to: The total amount of business information of each user of the second condition parameter generates a multi-dimensional traffic chart.
  • the embodiment of the present invention provides a sub-line analysis processing server, which includes:
  • a receiving module configured to receive a data request message sent by the central online analysis processing OLAP server, and obtain a data reporting parameter associated with the data request message;
  • the processing module is configured to perform statistics on the service volume of the roaming user and the non-roaming user according to the data reporting parameter, and obtain user service data information, where the user service data information includes the traffic quantity information of the roaming user and the first condition parameter is met. Traffic information of the non-roaming user, the traffic information includes a user identifier and a corresponding traffic volume;
  • a sending module configured to send the user service data information to the central OLAP server, so that the central OLAP server performs service summation based on the user identifier and the corresponding traffic volume, and obtains the user identifier corresponding to The traffic volume sum meets the service total information of each user that satisfies the second condition parameter, and the service total amount information includes the user identifier and the corresponding sum of the traffic amounts.
  • the at least one user traffic information sent by the deep packet parsing device is received, where each user traffic information includes a user identifier of the user, and the user's ticket Secondary traffic, the attribution of the user, and the generation of the single industry Geographical area identification of traffic;
  • the processing module is specifically configured to:
  • Determining that the user is a roaming user and determining, according to the data reporting parameter, all user services including the user identifier, if the home location identifier of the user is inconsistent with the geographic area identifier that generates the single service volume.
  • the single traffic in the quantity information is counted, and the traffic information of the roaming user is obtained;
  • Determining that the user is a non-roaming user and determining, according to the data reporting parameter, all users that include the user identifier, if the home location identifier of the user is consistent with the geographic area identifier that generates the single-time traffic volume.
  • the traffic of the non-roaming user in the traffic information is obtained, and the traffic volume of the non-roaming user is obtained according to the traffic volume of all the non-roaming users.
  • the data reporting parameter includes any one or a combination of the following: a service type parameter to be counted, a statistical time period parameter, the first The processing module is specifically configured to: if the data reporting parameter includes a service type parameter to be counted, perform statistics on the service quantity of the service type parameter to be counted by the roaming user and the non-roaming user, and obtain the user service Data information, the user service data information includes traffic information of the roaming user, and traffic information of the non-roaming user that satisfies the first condition parameter, where the traffic information includes the user identifier and the corresponding traffic volume;
  • the data reporting parameter includes a statistical time period parameter
  • statistics are performed on the service quantity of the statistical time period parameter corresponding to the roaming user and the non-roaming user, to obtain user service data information, where the user service data information includes roaming
  • the receiving module is specifically configured to receive a central online analysis processing and send the OLAP server a data request message, according to a predetermined mapping relationship between the data request message and the data report parameter, acquiring a data report parameter associated with the data request message;
  • an embodiment of the present invention provides an online processing data system, including a central online analytical processing OLAP server and at least one sub-line analytical processing OLAP server, where:
  • the central OLAP server is configured to: send a data request message to the at least one child OLAP server; receive user service data information sent by the at least one child OLAP server, where the user service data information includes traffic information of the roaming user and meets the a traffic parameter information of the non-roaming user of the condition parameter, the traffic volume information includes a user identifier and a corresponding traffic volume; and the traffic volume is summed based on the user identifier and the corresponding traffic volume, and the user identifier is obtained.
  • the traffic total sum meets the total service information of each user of the second condition parameter, where the total service information includes a sum of the user identifier and the corresponding traffic volume;
  • the sub-OLAP server is configured to: receive a data request message sent by the central OLAP server, and obtain a data report parameter corresponding to the data request message; and perform services on the roaming user and the non-roaming user according to the data reporting parameter And performing statistics on the user to obtain user service data information; and transmitting the user service data information to the central OLAP server, where the user service data information includes traffic information of the roaming user and a service of the non-roaming user that satisfies the first condition parameter
  • the quantity information includes the user identifier and the corresponding traffic volume.
  • the central OLAP server is specifically configured to:
  • the sub OLAP server is specifically configured to:
  • each user traffic information includes a user identifier of the user, a single traffic volume of the user, a home location identifier of the user, and generating the single traffic volume Geographical area identifier;
  • Determining that the user is a roaming user and determining, according to the data reporting parameter, all user services including the user identifier, if the home location identifier of the user is inconsistent with the geographic area identifier that generates the single service volume.
  • the quantity of the traffic in the quantity information is collected to obtain the traffic volume information of the roaming user, where the traffic volume information includes the user identifier and the corresponding traffic volume;
  • Determining that the user is a non-roaming user and determining, according to the data reporting parameter, all users that include the user identifier, if the home location identifier of the user is consistent with the geographic area identifier that generates the single-time traffic volume.
  • the traffic of the non-roaming user is obtained according to the traffic of the non-roaming user, and the traffic information of the non-roaming user that satisfies the first condition parameter is determined according to the traffic volume of all the non-roaming users, where the service
  • the quantity information includes a user identifier and a corresponding traffic volume; the user service data information is sent to the central OLAP server to enable the central
  • the OLAP server performs the service summation based on the user identifier and the corresponding traffic volume, and obtains the service total information of each user that satisfies the second condition parameter, and the total service information.
  • the user identification and the corresponding sum of the traffic are included.
  • the sub OLAP server is specifically configured to:
  • the data reporting parameter includes any one or a combination of the following: a service type parameter to be counted, a statistical time period parameter, and the first condition parameter;
  • the service quantity of the service type parameter that is required to be counted is calculated by the roaming user and the non-roaming user, and the user service data information is obtained, where the user service data information includes roaming.
  • User's business volume information and meeting the first condition The traffic information of the non-roaming user of the parameter, where the traffic information includes the user identifier and the corresponding traffic volume; or
  • the data reporting parameter includes a statistical time period parameter
  • the traffic volume of the roaming user and the non-roaming user corresponding to the statistical time period parameter is collected, and the user service data information is obtained, where the user service data information includes the traffic volume of the roaming user.
  • the traffic information of the non-roaming user that satisfies the first condition parameter where the traffic information includes the user identifier and the corresponding traffic volume;
  • An embodiment of the present invention provides a method, device, and system for processing data online, where a central OLAP server sends a data request message to at least one sub OLAP server, and the central OLAP server receives user service data information sent by at least one sub OLAP server.
  • the user service data information includes traffic information of the roaming user and traffic information of the non-roaming user that satisfies the first condition parameter, that is, the child OLAP server filters the non-roaming user, and the central OLAP server only receives the traffic information of the part of the non-roaming user.
  • the central OLAP server sums the traffic volume according to the user, and obtains the traffic total information of each user that satisfies the second condition parameter, and the central OLAP server only needs the traffic volume of the roaming user reported by the sub-OLAP server. And the traffic of the non-roaming users satisfying the first condition parameter is summed, that is, the sub-OLAP server performs preliminary statistics first, and the central OLAP server further performs statistics based on the preliminary statistics of the sub-OLAP server, and the data of the central OLAP server Reducing the amount of data processing efficiency.
  • Embodiment 1 is a flowchart of Embodiment 1 of a method for processing data online according to the present invention
  • Embodiment 2 is a flowchart of Embodiment 2 of a method for processing data online according to the present invention
  • Embodiment 3 is a flowchart of Embodiment 3 of a method for processing data online according to the present invention
  • 4 is a flowchart of Embodiment 4 of a method for processing data online according to the present invention.
  • FIG. 5 is a schematic structural diagram of Embodiment 1 of a central online analysis processing server according to the present invention
  • FIG. 6 is a schematic structural diagram of Embodiment 1 of a sub-line analysis processing server according to the present invention.
  • FIG. 7 is a schematic structural diagram of Embodiment 2 of a central online analysis processing server according to the present invention
  • FIG. 8 is a schematic structural diagram of Embodiment 2 of a sub-line analysis processing server according to the present invention.
  • Embodiment 9 is a schematic structural diagram of Embodiment 1 of an online processing data system according to the present invention.
  • FIG. 10 is a schematic diagram of an application of an online processing data system according to the present invention. detailed description
  • FIG. 1 is a flowchart of Embodiment 1 of a method for processing data online according to the present invention.
  • the execution host of the present implementation is an On-Line Transaction Processing (OLAP) server, and the central online analytical processing server can be implemented by software and/or hardware.
  • OLAP On-Line Transaction Processing
  • the method in this embodiment may include:
  • Step 101 Send a data request message to at least one child OLAP server.
  • the query request can be triggered to the central OLAP server.
  • the query request can carry the data parameters that the central OLAP server needs to count, that is, Data statistics parameters.
  • the data statistics parameter may generally include any one of a service type parameter, a statistical time period parameter, and a first condition parameter to be counted.
  • the data statistics parameter may be carried by the query request, and may also be a preset default parameter, and may also determine all parameters according to the mapping relationship between the partial parameters carried in the query request and the preset partial parameters and other parameters.
  • the data statistics parameter carried in the query request is a service type parameter to be counted
  • the preset part parameter is a statistical time period parameter
  • the central OLAP server can map the relationship between the service type parameter and the statistical time period parameter according to the statistics. , determine the statistical time period parameters.
  • the central OLAP server After receiving the query request, the central OLAP server sends a data request message to at least one child OLAP server, so that the child OLAP server performs data statistics.
  • the statistical user service data information is reported to the central OLAP server.
  • the data request message may carry a data report parameter or may not carry a data report parameter.
  • the data report parameter may be the same as the data statistics parameter, or may be different from the data statistics parameter.
  • the statistics in this embodiment include activities such as collection, collation, calculation, and analysis of related data.
  • the child OLAP server can perform data statistics according to the data reporting parameters.
  • the sub-OLAP server first obtains the data reporting parameter associated with the data request message, which may be implemented in the following two manners.
  • One possible implementation manner is a mapping relationship between the predetermined data request message and the data reporting parameter. And obtaining the data reporting parameter associated with the data request message, that is, the sub-OLAP server, after receiving the data request message, acquiring the data reporting parameter according to the mapping relationship.
  • Another possible implementation manner is that if the data request message carries the data report parameter, the carried data report parameter is extracted from the data request message.
  • the data request message can also carry a part of the data reporting parameter, and the sub OLAP server determines all the data reporting parameters according to the mapping relationship between the predetermined data request message and the partial data reporting parameter.
  • the data reporting parameter includes any one or a combination of the following: a service type parameter to be counted, a statistical time period parameter, and a first condition parameter.
  • the service type parameter to be counted may include a traffic service, a video service, a voice service, and the like;
  • the statistical time period parameter includes a start point and an end point of the statistical time, for example, from 7:00 pm to 9:00 pm on 2012-12-18, for specific
  • the statistic time period parameter is not limited in this embodiment;
  • the first condition parameter may be a condition parameter that is specifically satisfied by the traffic volume of the non-roaming user returned by the child OLAP server to the central OLAP server.
  • the data reporting message carries the data reporting parameter, and the central OLAP server can uniformly manage the data statistics.
  • the sub-OLAP server does not need to store the data reporting parameter, which can reduce the data storage capacity of each sub-OLAP server.
  • Step 102 Receive user service data information that is sent by the at least one sub-OLAP server, where the user service data information includes traffic information of the roaming user and traffic information of the non-roaming user that satisfies the first condition parameter, where the service volume
  • the information includes the user identification and the corresponding amount of traffic.
  • the sub-OLAP server may be distributed in a subnet deployed by the operator in different geographical areas, and the subnet may be in a city, and the user may be a user who uses the mobile terminal.
  • User service data information is sent to the central OLAP server.
  • the central OLAP receives user service data information sent by at least one sub-OLAP server.
  • the user identifier may be various identifiers of the mobile terminal, such as an international mobile subscriber identity code or a mobile phone number, and the traffic volume is a traffic volume corresponding to the subscriber identity.
  • the sub-OLAP server is located in Guangzhou.
  • the service type parameter to be counted is the traffic service, and the statistical time period parameter is the third quarter.
  • the first condition parameter is the condition parameter whose traffic is greater than the first preset threshold.
  • the user service data information includes: traffic information of the roaming user, such as a user whose home location is Shenzhen, when the user roams to Guangzhou in the third quarter, as the traffic information of the roaming user using the traffic service in Guangzhou and generating traffic.
  • traffic information of the roaming user such as a user whose home location is Shenzhen, when the user roams to Guangzhou in the third quarter, as the traffic information of the roaming user using the traffic service in Guangzhou and generating traffic.
  • the user service data information also includes the traffic information of the non-roaming user that satisfies the first condition parameter, that is, the user whose home belongs to Guangzhou, uses the traffic service locally in Guangzhou, and generates traffic information of the traffic.
  • the traffic information of the non-roaming user that satisfies the first condition parameter, that is, the user whose home belongs to Guangzhou, uses the traffic service locally in Guangzhou, and generates traffic information of the traffic.
  • the traffic information of the non-roaming user that satisfies the first condition parameter, that is, the user whose home belongs to Guangzhou, uses the traffic service locally in Guangzhou, and generates traffic information of the traffic.
  • statistics are collected for these users. The obtained statistical results are for the operators to understand the network. The actual operation situation does not contribute much.
  • a large amount of data will increase the processing burden of the central OLAP server.
  • the sub-OLAP server filters the non-roaming users to obtain non-roaming users that satisfy the first condition parameter, for example, when non-roaming When the traffic of the user is greater than the first preset threshold, the non-roaming user is a roaming user that satisfies the first condition parameter.
  • the first condition parameter may also be a condition parameter in which the traffic volume ranks before the first preset rank among the traffic of all non-roaming users. For example, when the first preset rank is 1000, the non-roaming users whose total traffic is in the top 1000 in the third quarter are non-roaming users who satisfy the first condition parameter.
  • the traffic statistics received by the central OLAP server are the traffic statistics sent by the multiple sub-OLAP servers, and the traffic statistics sent by each sub-OLAP server are implemented in Guangzhou with the above sub-OLAP servers. For example, this embodiment is not illustrated here.
  • Step 103 Perform service summation based on the user identifier and the corresponding traffic volume, and obtain total service information of each user that meets the second condition parameter, and the total service volume.
  • the information includes the user identification and the corresponding sum of the traffic.
  • the central OLAP server After receiving the user service data information sent by the at least one sub-OLAP server, the central OLAP server sums the traffic volume of each user based on the user identifier, obtains the sum of the traffic of each user, and obtains each of the second condition parameters. The total amount of business information of the user.
  • the central OLAP server when the user uses the service at the home location and roams to multiple other geographical areas to use the service, the central OLAP server will receive the corresponding multiple geographic areas to which the user roams.
  • the plurality of sub-OLAP servers respectively send the user as the traffic information of the roaming user.
  • the central OLAP server will also receive the traffic information of the user as the non-roaming user sent by the sub-OLAP server corresponding to the home location of the user.
  • the total amount of traffic of the user as the roaming user and the non-roaming user may be counted based on the user identifier of the user, that is, The sum of all the traffic corresponding to the same user identifier is obtained, and the total amount of services of the user is obtained.
  • the sum of the traffic of the user is the traffic of the user as the non-roaming user.
  • the second condition parameter may be a preset second condition parameter, and may also be a second condition parameter carried in the query request when the operator triggers the query request.
  • the embodiment is not particularly limited herein.
  • the second condition parameter is a condition parameter that the sum of the traffic volume is greater than the second preset threshold, or the condition parameter that the sum of the traffic volume is ranked before the second preset ranking in the total traffic volume of all users.
  • the central OLAP server further filters the user, and the service type parameter to be counted is the traffic service parameter. For example, when the total traffic of each user is greater than the second preset threshold, or the total traffic of the user is ranked second. Before the ranking, the user is a user who satisfies the second condition parameter, and stores the total amount of service information of the user that meets the second condition parameter, where the service total amount information includes the user identifier and the sum of the traffic volume corresponding to the user identifier. .
  • the method for processing data online by the embodiment of the present invention sends a data request message to the at least one sub-OLAP server through the central OLAP server, and the central OLAP server receives the user service data information sent by the at least one sub-OLAP server, where the user service data information includes the roaming user.
  • the OLAP server filters the non-roaming users.
  • the central OLAP server only receives the traffic information of some non-roaming users.
  • the central OLAP server sums the traffic volume according to the user, and obtains the total traffic volume of each user that satisfies the second condition parameter.
  • Information the central OLAP server only needs to sum the traffic of the roaming users reported by the sub-OLAP server and the traffic of the non-roaming users satisfying the first condition parameter, that is, the sub-OLAP server first performs preliminary statistics, and the central OLAP server re- Based on the preliminary statistics of the preliminary statistics of the sub-OLAP server, the data processing capacity of the central OLAP server is reduced, and the data processing efficiency is improved.
  • the central OLAP server performs summation of traffic based on the user identifier and the corresponding traffic volume, and obtains a sum of traffic corresponding to the user identifier to satisfy the second condition.
  • the parameter information of each user's business total information it also includes:
  • a multi-dimensional traffic graph is generated according to the total amount of business information of each user that satisfies the second condition parameter.
  • the central OLAP server can model the multi-angle thinking mode of the decision-makers according to the multi-angle thinking mode of the decision-makers, and generate a multi-dimensional traffic graph according to the total business information of each user satisfying the second condition parameter, wherein the dimension refers to the analysis angle.
  • the statistical time period parameter is a dimension
  • the business type parameter and the user ID are also one dimension.
  • the online processing data method provided by the present embodiment can quickly obtain data from various analysis angles according to the multi-dimensional traffic chart, and can also dynamically switch between various angles or perform multi-angle comprehensive analysis, which has great analysis flexibility. .
  • FIG. 2 is a flowchart of Embodiment 2 of a method for processing data online according to the present invention.
  • the execution body of this embodiment is a child OLAP server, and the child OLAP server can be implemented by software and/or hardware.
  • the method in this embodiment may include:
  • Step 201 Receive a data request message sent by the central OLAP server, and obtain a data report parameter associated with the data request message.
  • the child OLAP server receives the data request message sent by the central OLAP server for data statistics.
  • the sub-OLAP server needs to obtain the data reporting parameters associated with the data request message before performing data statistics.
  • the manner in which the sub-OLAP server obtains the data reporting parameters associated with the data request message includes the following possible implementation manners.
  • One possible implementation manner is to obtain a mapping relationship between the data request message and the data reporting parameter according to the predetermined data request message.
  • the data reporting parameter that is, the child OLAP server, after receiving the data request message, acquires the number according to the mapping relationship According to the reported parameters.
  • Another possible implementation manner is that if the data request message carries the data report parameter, the carried data report parameter is extracted from the data request message.
  • Step 202 Perform statistics on the traffic volume of the roaming user and the non-roaming user according to the data reporting parameter, and obtain user service data information, where the user service data information includes the traffic volume information of the roaming user and the non-first parameter The traffic information of the roaming user, where the traffic information includes a user identifier and a corresponding traffic volume.
  • the sub-OLAP server performs statistics on the traffic volume of the roaming user and the non-roaming user according to the data reporting parameter, and obtains the traffic information of the roaming user and the traffic information of the non-roaming user that satisfies the first preset condition parameter.
  • the data reporting parameter includes any one of the following or a combination thereof: a service type parameter to be counted, a statistical time period ⁇ t, and a first condition parameter.
  • the sub-OLAP server can perform statistics according to the specific content of the data reporting parameters. For example, if the data reporting parameter includes the service type parameter to be counted, the step 202 includes: performing statistics on the service quantity of the service type parameter to be counted by the roaming user and the non-roaming user according to the data reporting parameter, and obtaining the user service data information; Or
  • the step 202 includes: collecting statistics on the service quantity corresponding to the statistical time period parameter of the roaming user and the non-roaming user according to the data reporting parameter, and obtaining the user service data information.
  • the statistical time period parameter and the service type parameter can be combined to count the traffic volume of the specific service type in the statistical time period of the roaming user and the non-roaming user.
  • the child OLAP server In order to improve the processing efficiency of the central OLAP server, the child OLAP server must also determine the non-roaming users that satisfy the first condition parameter.
  • the first condition parameter is a condition parameter whose traffic is greater than the first preset threshold, or a condition parameter whose traffic is ranked before the first preset ranking among the traffic of all non-roaming users.
  • Step 203 Send the user service data information to the central OLAP server, so that the central OLAP server performs service summation based on the user identifier and the corresponding traffic volume, and obtains a service corresponding to the user identifier.
  • the total amount of services of each user that satisfies the second condition parameter, and the total amount of service information includes the sum of the user identifiers and the corresponding traffic volume.
  • the second condition parameter is that the sum of the traffic is greater than the second preset threshold.
  • the condition parameter, or the sum of the traffic is the condition parameter before the second preset rank in the sum of the traffic of all users.
  • the method for processing data online by the embodiment of the present invention receives the data request message sent by the central OLAP server through the sub-OLAP server, and performs statistics on the service volume of the roaming user and the non-roaming user, and obtains user service data information, where the user service data information includes The traffic information of the roaming user and the traffic information of the non-roaming user satisfying the first condition parameter, the traffic information includes the user identifier and the traffic volume, and the user service data information is sent to the central OLAP server, that is, the sub-OLAP server performs the non-roaming user.
  • the sub-OLAP server sends only the traffic information of the non-roaming users to the central OLAP server, so that the central OLAP server only needs the traffic of the roaming users reported by the sub-OLAP server and the non-roaming users that satisfy the first condition parameter.
  • the traffic is summed, that is, the sub-OLAP server performs preliminary statistics first, and the central OLAP server further statistics based on the preliminary statistics of the sub-OLAP server.
  • the data processing volume of the central OLAP server is reduced, and the data processing efficiency is improved. .
  • FIG. 3 is a flowchart of Embodiment 3 of a method for processing data online according to the present invention. This embodiment will be described in detail in step 202 of the embodiment of Fig. 2 on the basis of the embodiment of Fig. 2.
  • step 301 is further included.
  • the sub-OLAP server receives at least one piece of user traffic information sent by the deep packet parsing device, where each user traffic information includes a user identifier of the user, a single traffic volume of the user, a home location identifier of the user, and generation. Geographical area ID for a single transaction.
  • Deep Packet Inspection (DPI) devices can sense network applications and detect traffic based on the application layer.
  • the DPI device may be connected to a gateway device set in each geographical area for a server having a DPI function, and on the other hand, because the access of the mobile terminal of the user in each geographical area is finally aggregated to
  • the DPI module can be set in the gateway to make the gateway have DPI capability and act as a DPI device.
  • each sub-OLAP server has a gateway connected thereto.
  • the DPI device learns that the user uses the service in the area corresponding to the gateway, the DPI device sends at least one user traffic information to the sub-OLAP server, the service.
  • the quantity information includes the user identification of the user, a single transaction amount, a attribution identification, and a geographical area identification that generates a single transaction amount.
  • the geographic area identifier of the traffic may be the place where the user generates a single traffic when using the service.
  • the user's single-time traffic can be used by the user to use the traffic generated by the service once, for example, the traffic generated by the user using the primary traffic service, or the duration of the call generated by the user using the primary call service, etc., for a single time
  • the specific manner of the traffic is not limited in this embodiment.
  • the attribution identifier and the geographic area identifier that generates a single amount of traffic may be the device number of the corresponding DPI device.
  • the sub-OLAP servers located in different geographical areas have corresponding DPI devices.
  • the device number of the DPI device corresponding to the sub-OLAP server in Shenzhen is 1001, and the DPI device corresponding to the sub-OLAP server located in Guangzhou.
  • the device number is 1002, the device number of the DPI device corresponding to the sub-OLAP server in Zhuhai is 1003, and the device number of the DPI device corresponding to the Dongguan sub-OLAP server is 1004.
  • the mapping information in Table 1 can be used as metadata and maintained by each DPI device.
  • the attribution identifier is 1001
  • the service is used in Guangzhou
  • the corresponding traffic is generated (the geographical area identifier 1002 that generates a single transaction amount)
  • the DPI device in Guangzhou senses the behavior of the user, and sends user traffic information to the sub-OLAP server connected thereto, the information including the mobile phone number of the user, the single transaction volume, the attribution identifier 1001, and the generation of a single service.
  • the sub-OLAP server when receiving the user traffic information sent by the DPI device, can receive the real-time information one by one, or can receive multiple user traffic information at the same time in large quantities, and the specific information received by the sub-OLAP server. The implementation manner is not repeated here.
  • the sub-OLAP server after receiving the user traffic information sent by the DPI device, saves the user traffic information.
  • a user information table may be newly created, and the user information table is newly created. It is used to store user traffic information, such as the identity of the user, the attribution identifier, the geographic area identifier that generates a single traffic, and the traffic volume.
  • the child OLAP server may insert the user traffic information in the user information table, in order to distinguish each user traffic information of the user and determine
  • a time point field for generating a single transaction amount may be added to the user information table for recording the time for generating a single transaction amount.
  • step 202 specifically includes:
  • Step 2021 Determine whether the home location identifier of the user is consistent with the geographic area identifier that generates a single traffic volume. If not, go to step 2022, and if yes, go to step 2023.
  • Step 2022 Determine that the user is a roaming user, and perform statistics on the single traffic volume of all the user traffic information including the user identifier according to the data reporting parameter, and obtain the traffic volume information of the roaming user.
  • Step 2023 Determine that the user is a non-roaming user. And collecting, according to the data reporting parameter, a single traffic volume of all user traffic information including the user identifier, and obtaining the traffic volume of the non-roaming user; determining, according to the traffic volume of the non-roaming user, the non-roaming user that meets the first condition parameter Traffic information.
  • the sub-OLAP server can directly obtain relevant information from the user information table.
  • the child OLAP server may determine that the user is a roaming user or a non-roaming user according to the home location identifier in the user information table and the geographic area identifier that generates the single traffic.
  • Table 2 lists only some of the fields in the user information table: user ID, attribution, and geographic area identifier that generates a single transaction.
  • the sub-OLAP server determines whether the home location identifier is consistent with the geographic area identifier that generates the single traffic volume, that is, when the child OLAP server determines that the same user in the second table generates a single traffic volume, the user's home location identifier and the single service are generated. Whether the geographic area identifiers of the quantity are consistent. For example, for the user 13512345678, the home identity 1001 and the geographic area identifier 1002 that generates a single traffic are inconsistent, then the user is determined to be a roaming user, and step 2022 is performed. For the user 1322345678, the home identity 1002 and the single service are generated. The geographic area identifier 1002 is determined, and the user is determined to be a non-roaming user, and step 2023 is performed.
  • the roaming information table and the non-roaming information table may be newly created according to the user information table.
  • the roaming information table may only include The user ID of the roaming user, the single traffic volume of the roaming user, and the time when the single traffic volume is generated; correspondingly, the non-roaming information table may also include only the user identity of the non-roaming user, the single traffic volume of the roaming user, and the generation The time of this single transaction. It can be understood by those skilled in the art that there are various ways of constructing the table in this embodiment, and the specific manner of constructing the table in this embodiment is not particularly limited.
  • step 2022 it is determined that when the current user is a roaming user, the single traffic volume of all user service information including the user identifier is counted according to the data reporting parameter, and the traffic volume of the roaming user is obtained.
  • the statistics may be performed according to the parameters in the data reporting parameters.
  • the statistical time period parameter indicates that the statistical time period is the second week of May, and when the service type parameter to be counted is the traffic service parameter, the user is in the All the single traffic belonging to the traffic service generated during this time period is accumulated.
  • step 2023 when it is determined that the current user is a non-roaming user, the single-time traffic in all the user traffic information including the user identifier is counted according to the data reporting parameter, and the traffic of the non-roaming user is obtained, according to all non-roaming.
  • the user's traffic volume determines the user identifier and the traffic volume of the non-roaming user that meets the first condition parameter. Specifically, the user may perform statistics according to each parameter in the data reporting parameter.
  • the traffic belonging to the traffic service of each non-roaming user in the statistical time period from 7:00 to 8:00 is counted, and the non-roaming that satisfies the first condition parameter is determined according to the single traffic volume of the traffic service of each non-roaming user.
  • the first condition parameter may be a condition parameter whose traffic volume is greater than the first preset threshold.
  • the online processing data method of the present example has a strong pertinence by using the roaming user to determine the traffic volume information and the non-roaming user based on the first condition parameter, thereby avoiding the meaningless system resource waste.
  • the performance of online processing of data methods has been greatly improved.
  • FIG. 4 is a flowchart of Embodiment 4 of a method for processing data online according to the present invention.
  • the two sub-OLAP servers are used as an example, that is, after the operator decision maker triggers the query request, the online processing data method of this embodiment includes the following steps:
  • Step 401 The decision maker triggers a query request to the central OLAP server
  • Step 402 The central OLAP server sends a data request message to the child OLAP server 1;
  • Step 403 The central OLAP server sends a data request message to the child OLAP server 2; those skilled in the art may understand that step 402 and step 403 have no strict timing relationship. Both can be done simultaneously.
  • Step 405 The sub-OLAP server 2 obtains the data reporting parameter associated with the data request message, and performs statistics on the traffic volume of the roaming user and the non-roaming user according to the data reporting parameter, to obtain user service data information.
  • step 404 and step 405 there is no strict timing relationship between step 404 and step 405, and the two can be performed simultaneously.
  • Step 406 The child OLAP server 1 sends the user service data information to the central OLAP server.
  • Step 407 the child OLAP server 2 sends the user service data information to the central OLAP server.
  • steps 406 and 407 have no strict timing. Relationship, the two can be carried out simultaneously.
  • Step 408 The central OLAP server performs traffic summation based on the user identifier, and obtains service total information of each user that satisfies the second condition parameter.
  • Step 409 The central OLAP server generates a multi-dimensional traffic graph according to the total service information of each user that satisfies the second condition parameter.
  • each sub-OLAP server may refer to the embodiment shown in FIG. 2 and FIG. 3.
  • the online processing data method performed by the central OLAP server can be referred to the embodiment shown in FIG.
  • each sub-OLAP server includes 1 million users, that is, the total user is 4 million, assuming 15% of the total users. Roaming to the other three areas, 20% of the total users roam to the other two areas, 25% of the total users roam to the other area, and the other 40% of the total users do not roam.
  • the service type is a traffic service
  • the statistical time period is from January 1, 2012 to January 31, 2012
  • the online data processing method of this embodiment is used, and the user trajectory information finally calculated by the central OLAP server is used.
  • the time for generating multidimensional traffic charts is 121 seconds.
  • the final statistics of the central OLAP server are about 400,000 under the same scenarios and conditions.
  • the time for generating the multidimensional traffic chart is 517 seconds, compared with the prior art, the online processing data method provided by this embodiment has a performance improvement of 76.6%.
  • FIG. 5 is a schematic structural diagram of Embodiment 1 of a central online analysis processing server according to the present invention.
  • the central OLAP server 50 provided in this embodiment includes a sending module 501, a receiving module 502, and a processing module 503.
  • the sending module 501 is configured to send a data request message to the at least one sub-line analysis processing OLAP server;
  • the receiving module 502 is configured to receive user service data information that is sent by the at least one sub-OLAP server, where the user service data information includes traffic information of the roaming user and traffic information of the non-roaming user that satisfies the first condition parameter,
  • the traffic information includes the user identifier and the corresponding traffic volume;
  • the processing module 503 is configured to perform traffic summation based on the user identifier and the corresponding traffic volume, and obtain service total information of each user that satisfies the second condition parameter in the total traffic volume corresponding to the user identifier, where the service is The total amount information includes the user identification and the corresponding sum of the traffic amounts.
  • the central online analysis processing server of this embodiment may be used to implement the technical solution of the embodiment shown in FIG. 1.
  • the implementation principle and technical effects are similar, and details are not described herein again.
  • processing module 503 is specifically configured to:
  • the total traffic volume information of each user that satisfies the second condition parameter is determined.
  • the sending module 501 is specifically configured to: send, to the at least one sub-OLAP server, a data request message that carries a data reporting parameter, where the data reporting parameter includes any one of the following or a combination thereof: a service type parameter to be counted And a statistical time period parameter and the first condition parameter.
  • the first condition parameter is a condition parameter that the traffic volume is greater than the first preset threshold, or a condition parameter that the traffic volume is ranked before the first preset ranking in the traffic volume of all non-roaming users;
  • the condition parameter is a condition parameter whose sum of traffic is greater than a second preset threshold, or a condition parameter in which the sum of traffic is ranked before the second preset rank in the sum of traffic of all users.
  • the processing module 503 is further configured to:
  • a multi-dimensional traffic graph is generated based on the total amount of business information of each user that satisfies the second condition parameter.
  • each of the sub-OLAP servers is disposed in a different geographical area.
  • the central online analysis processing server of this embodiment may be used to implement the technical solution of the method for processing the online processing data.
  • the implementation principle and technical effects are similar, and details are not described herein again.
  • FIG. 6 is a schematic structural diagram of Embodiment 1 of a sub-line analysis processing server according to the present invention.
  • the sub-OLAP server 60 provided in this embodiment includes a receiving module 601, a processing module 602, and a sending module 603.
  • the receiving module 601 is configured to receive a data request message sent by the central online analysis processing OLAP server, and obtain a data reporting parameter associated with the data request message.
  • the processing module 602 is configured to perform statistics on the service volume of the roaming user and the non-roaming user according to the data reporting parameter, and obtain user service data information, where the user service data information includes the traffic quantity information of the roaming user and the first condition parameter is met. Traffic information of the non-roaming user, the traffic information includes a user identifier and a corresponding traffic volume;
  • the sending module 603 is configured to send the user service data information to the central OLAP server, so that the central OLAP server performs service summation based on the user identifier and the corresponding traffic volume, and obtains the user identifier corresponding to The traffic volume sum meets the service total information of each user that satisfies the second condition parameter, and the service total amount information includes the user identifier and the corresponding sum of the traffic amounts.
  • the sub-line analysis processing server of this embodiment may be used to implement the technical solution of the embodiment of FIG. 2, and the implementation principle and technical effects thereof are similar, and details are not described herein again.
  • the receiving module 601 is further configured to:
  • each user traffic information includes a user identifier of the user, a single traffic volume of the user, a home location identifier of the user, and generating the single traffic volume Geographical area identifier;
  • the processing module 602 is specifically configured to:
  • Determining that the user is a roaming user and determining, according to the data reporting parameter, all user services including the user identifier, if the home location identifier of the user is inconsistent with the geographic area identifier that generates the single service volume.
  • the single traffic in the quantity information is counted, and the roaming user is obtained.
  • Determining that the user is a non-roaming user and determining, according to the data reporting parameter, all users that include the user identifier, if the home location identifier of the user is consistent with the geographic area identifier that generates the single-time traffic volume.
  • the traffic of the non-roaming user in the traffic information is obtained, and the traffic volume of the non-roaming user is obtained according to the traffic volume of all the non-roaming users.
  • the data reporting parameter includes any one or a combination of the following: a service type parameter to be counted, a statistical time period parameter, and the first condition parameter;
  • the processing module 602 is specifically configured to: if the data reporting parameter includes a service type parameter to be counted, perform statistics on the service quantity of the service type parameter to be counted by the roaming user and the non-roaming user, and obtain user service data information.
  • the user service data information includes the traffic volume information of the roaming user and the traffic volume information of the non-roaming user that meets the first condition parameter, where the traffic volume information includes the user identifier and the corresponding traffic volume;
  • the data reporting parameter includes a statistical time period parameter
  • the first condition parameter is a condition parameter that the traffic volume is greater than the first preset threshold, or a condition parameter that the traffic volume is ranked before the first preset ranking in the traffic volume of all non-roaming users;
  • the condition parameter is a condition parameter whose sum of traffic is greater than a second preset threshold, or a condition parameter in which the sum of traffic is ranked before the second preset rank in the sum of traffic of all users.
  • the receiving module 601 is specifically configured to receive a data request message sent by the central online analysis processing OLAP server, and acquire data associated with the data request message according to a predetermined mapping relationship between the data request message and the data reporting parameter. Reporting parameters;
  • the method is: receiving the data request message sent by the OLAP server by the central online analysis processing, and if the data request message carries the data reporting parameter, extracting the carried data reporting parameter from the data request message.
  • FIG. 7 is a schematic structural diagram of Embodiment 2 of a central online analysis processing server according to the present invention.
  • the central OLAP server 70 includes: at least one processor 701, such as a CPU, at least one network interface 704 or other user interface 703, a memory 705, and at least one communication bus 702. Communication bus 702 is used to implement connection communication between these components.
  • the central OLAP server 70 optionally includes a user interface 703, including a display, keyboard or pointing device (e.g., a mouse, trackball, touchpad or tactile display).
  • the memory 705 may include a high speed RAM memory and may also include a non-volatile memory such as at least one disk memory.
  • the memory 705 can optionally include at least one storage device located remotely from the aforementioned processor 701.
  • memory 705 stores the following elements, executable modules or data structures, or a subset thereof, or their extension set:
  • the operating system 7051 which contains various system programs for implementing various basic services and handling hardware-based tasks;
  • the application module 7052 includes various applications for implementing various application services.
  • the application module 7052 includes but is not limited to the sending module 501, the receiving module 502, and the processing module.
  • each module in the application module 7052 refers to the corresponding modules in the embodiment shown in FIG. 5, and details are not described herein.
  • the processor 701 is configured to: send a data request message to the at least one sub-line analysis processing OLAP server;
  • the user service data information includes traffic information of the roaming user and traffic information of the non-roaming user that satisfies the first condition parameter, where the service volume information includes the user Identification and corresponding business volume;
  • the summation of the traffic is performed based on the user identifier and the corresponding traffic volume, and the total traffic information of each user that satisfies the second condition parameter is obtained, including:
  • the total traffic volume information of each user that satisfies the second condition parameter is determined.
  • the data request message carries a data report parameter
  • the data report parameter includes any one or a combination of the following: a service type parameter to be counted, a statistical time period parameter, and the first condition parameter.
  • the first condition parameter is a condition parameter that the traffic volume is greater than the first preset threshold, or a condition parameter that the traffic volume is ranked before the first preset ranking in the traffic volume of all non-roaming users;
  • the condition parameter is a condition parameter whose sum of traffic is greater than a second preset threshold, or a condition parameter in which the sum of traffic is ranked before the second preset rank in the sum of traffic of all users.
  • the method further includes :
  • a multi-dimensional traffic graph is generated based on the total amount of business information of each user that satisfies the second condition parameter.
  • the central online analysis processing server of this embodiment may be used to implement the technical solution of the method for processing the online processing data.
  • the implementation principle and technical effects are similar, and details are not described herein again.
  • FIG. 8 is a schematic structural diagram of Embodiment 2 of a sub-line analysis processing server according to the present invention.
  • the sub-OLAP server 80 includes: at least one processor 801, such as a CPU, at least one network interface 804 or other user interface 803, a memory 805, and at least one communication bus 802. Communication bus 802 is used to implement connection communication between these components.
  • the sub-OLAP server 80 optionally includes a user interface 803 including a display, a keyboard or a pointing device (e.g., a mouse, a trackball, a touchpad, or a touch sensitive display).
  • the memory 805 may include a high speed RAM memory and may also include a non-volatile memory such as at least one disk memory.
  • the memory 805 can optionally include at least one storage device located remotely from the aforementioned processor 801.
  • memory 805 stores the following elements, executable modules or data structures, or a subset thereof, or their extension set:
  • Operating system 8051 which contains various system programs for implementing various basic services and processing hardware-based tasks;
  • the application module 8052 includes various applications for implementing various application services.
  • the application module 8052 includes but is not limited to the receiving module 601, the processing module 602, and the sending module.
  • each module in the application module 8052 refers to the corresponding module in the embodiment shown in FIG. 6, which is not mentioned herein.
  • the processor 801 is configured to: receive a data request message sent by the central OLAP, and obtain a data report parameter associated with the data request message;
  • the user service data information includes the traffic volume information of the roaming user and the non-roaming user that satisfies the first condition parameter.
  • Traffic information where the traffic information includes a user identifier and a corresponding traffic volume;
  • the method further includes:
  • each user traffic information includes a user identifier of the user, a single traffic volume of the user, a home location identifier of the user, and generating the single traffic volume Geographical area identifier;
  • Determining that the user is a roaming user and determining, according to the data reporting parameter, all user services including the user identifier, if the home location identifier of the user is inconsistent with the geographic area identifier that generates the single service volume.
  • the single traffic in the quantity information is counted, and the traffic information of the roaming user is obtained;
  • Determining that the user is a non-roaming user and determining, according to the data reporting parameter, all users that include the user identifier, if the home location identifier of the user is consistent with the geographic area identifier that generates the single-time traffic volume.
  • the single-time traffic in the traffic information is collected, and the traffic of the non-roaming user is obtained; and the non-roaming user's traffic is determined according to the non-roaming user's traffic.
  • the traffic information of the roaming user is determining, according to the data reporting parameter, all users that include the user identifier, if the home location identifier of the user is consistent with the geographic area identifier that generates the single-time traffic volume.
  • the data reporting parameter includes any one or a combination of the following: a service type parameter to be counted, a statistical time period parameter, and the first condition parameter;
  • the data reporting parameter includes a service type parameter to be counted
  • the statistic is performed on the service quantity of the roaming user and the non-roaming user according to the data reporting parameter, and the user service data information is obtained: the roaming user and the non-roaming
  • the user performs statistics according to the service quantity of the service type parameter to be counted, and obtains user service data information;
  • the data reporting parameter includes the statistic time period parameter
  • the statistic is performed on the service quantity of the roaming user and the non-roaming user according to the data reporting parameter, and the user service data information is obtained by: the roaming user and the non-roaming user are corresponding to:
  • the traffic of the statistical time period parameter is counted to obtain user service data information.
  • the first condition parameter is a condition parameter that the traffic volume is greater than the first preset threshold, or a condition parameter that the traffic volume is ranked before the first preset ranking in the traffic volume of all non-roaming users;
  • the condition parameter is a condition parameter whose sum of traffic is greater than a second preset threshold, or a condition parameter in which the sum of traffic is ranked before the second preset rank in the sum of traffic of all users.
  • the obtaining the data reporting parameter associated with the data request message includes: obtaining, according to a predetermined mapping relationship between the data request message and the data reporting parameter, a data reporting parameter associated with the data request message;
  • the obtaining the data report parameter associated with the data request message includes:
  • Extracting the carried data reporting parameter from the data request message Extracting the carried data reporting parameter from the data request message.
  • the sub-line analysis processing server of this embodiment may be used to implement the technical solution of the method for processing the online processing data.
  • the implementation principle and technical effects are similar, and details are not described herein again.
  • FIG. 9 is a schematic structural diagram of Embodiment 1 of an online processing data system according to the present invention.
  • the online processing data system 90 provided by this embodiment includes a central OLAP server and at least one sub OLAP server.
  • the online processing system 90 includes a central OLAP server 901, a first sub-OLAP server 902, a second sub-OLAP server 903, a third sub-OLAP server 904, and a fourth sub-OLAP server 905. .
  • OLAPs in the system of the embodiment of the present invention is scalable; the OLAP series is also scalable; and the single OLAP load can be uniformly extended.
  • a disk array can also be built in or externally, and the disk array is used to store various user information tables.
  • the central OLAP server 901 can be a central OLAP server as shown in FIG.
  • Each sub-OLAP server may be a structure of a sub-OLAP server as shown in FIG. 6.
  • the central OLAP server 901 is configured to send a data request message to the at least one sub OLAP server, and receive user service data information sent by the at least one sub OLAP server, where the user service data information includes a roaming user.
  • the sub-OLAP server is configured to: receive a data request message sent by the central OLAP server 901, and obtain a data report parameter corresponding to the data request message; and perform traffic to the roaming user and the non-roaming user according to the data reporting parameter Performing statistics to obtain user service data information; and transmitting the user service data information to the central OLAP server 901, where the user service data information includes traffic quantity information of the roaming user and traffic information of the non-roaming user that satisfies the first condition parameter
  • the traffic information includes a user identifier and a corresponding traffic volume.
  • central OLAP server 901 is specifically configured to:
  • sub OLAP server is specifically configured to:
  • each user traffic information includes a user identifier of the user, a single traffic volume of the user, a home location identifier of the user, and generating the single traffic volume Geographical area identifier;
  • Determining that the user is a roaming user and determining, according to the data reporting parameter, all user services including the user identifier, if the home location identifier of the user is inconsistent with the geographic area identifier that generates the single service volume.
  • the quantity of the traffic in the quantity information is collected to obtain the traffic volume information of the roaming user, where the traffic volume information includes the user identifier and the corresponding traffic volume;
  • Determining that the user is a non-roaming user and determining, according to the data reporting parameter, all users that include the user identifier, if the home location identifier of the user is consistent with the geographic area identifier that generates the single-time traffic volume.
  • the traffic of the non-roaming user is obtained according to the traffic of the non-roaming user, and the traffic information of the non-roaming user that satisfies the first condition parameter is determined according to the traffic volume of all the non-roaming users, where the service The quantity information includes the user identifier and the corresponding traffic volume; the user service data information is sent to the central OLAP server 901, so that the central OLAP server 901 performs the summation of the traffic based on the user identifier and the corresponding traffic volume, and obtains the The total amount of traffic corresponding to the user identifier satisfies the total service information of each user that satisfies the second condition parameter, and the total service information includes the sum of the user identifier and the corresponding traffic volume.
  • sub OLAP server is specifically configured to:
  • the data reporting parameter includes any one or a combination of the following: a service type parameter to be counted, a statistical time period parameter, and the first condition parameter;
  • the service quantity of the service type parameter that is required to be counted is calculated by the roaming user and the non-roaming user, and the user service data information is obtained, where the user service data information includes roaming.
  • the data reporting parameter includes a statistical time period parameter
  • the traffic volume of the roaming user and the non-roaming user corresponding to the statistical time period parameter is collected, and the user service data information is obtained, where the user service data information includes the traffic volume of the roaming user.
  • the traffic information of the non-roaming user that satisfies the first condition parameter where the traffic information includes the user identifier and the corresponding traffic volume;
  • the central OLAP server 901 Sending the user service data information to the central OLAP server 901, so that the central OLAP server 901 performs the summation of the traffic based on the user identifier and the corresponding traffic volume, and obtains the sum of the traffic amounts corresponding to the user identifiers to satisfy the second.
  • the central OLAP server 901 can be implemented by the structure shown in FIG. 7, and each sub-OLAP server can be implemented by the structure shown in FIG.
  • the online processing data system of this embodiment may be used to implement the foregoing technical solution of the method for processing data on the line.
  • the implementation principle and technical effects are similar, and details are not described herein again.
  • the online processing data system of this embodiment may be used to implement the foregoing technical solution of the method for processing data on the line.
  • the implementation principle and technical effects are similar, and details are not described herein again.
  • FIG. 10 is a schematic diagram of an application of an online processing data system according to the present invention.
  • the sub-OLAP server can also be connected to the DPI device during the specific application process. As shown in Figure 10, the first child OLAP server
  • the second sub-OLAP server 1103, the third sub-OLAP server 1104, and the fourth sub-OLAP server 1105 are respectively connected to the DPI devices numbered 1001, 1002, 1003, and 1004.
  • the DPI device learns that the user uses the service in the geographical area corresponding to the gateway, the DPI device sends at least one user traffic information to the child OLAP.
  • the DPI device sends the user traffic information of the local user in the Guangzhou area to the second sub-OLAP server.
  • the traffic information for the user who is roaming to the Guangzhou area and whose attribution is the Shenzhen area is sent to the second sub-OLAP server 1103.
  • Each sub-OLAP server receives at least one piece of user traffic information sent by the DPI device.
  • a storage device such as a disk array, may be built in or externally used to store the traffic including the user.
  • a variety of user information tables for information may be used.
  • each sub-OLAP server When each sub-OLAP server receives the data request message sent by the central OLAP server 1101, each sub-OLAP server obtains the traffic quantity information of the roaming user and the first condition parameter according to the stored service quantity information of the user according to the data request message. Traffic volume letter for non-roaming users Interest. The specific implementation process is shown in FIG. 3, and details are not described herein again.
  • Each sub-OLAP server sends user service data information to the central OLAP server 1101, including traffic information of the roaming user and a traffic volume of the non-roaming user satisfying the first condition parameter.
  • the central OLAP server 1101 is based on the user identifier and the corresponding traffic volume.
  • the traffic summation is performed, and the total amount of traffic corresponding to the user identifier is obtained, and the total service information of each user that satisfies the second condition parameter is included, where the total service information includes a sum of the user identifier and the traffic volume.
  • the online processing data system sends a data request message to the at least one sub-OLAP server through the central OLAP server, and the central OLAP server receives the user service data information sent by the at least one sub-OLAP server, where the user service data information includes the service of the roaming user.
  • the quantity information and the traffic information of the non-roaming users satisfying the first condition parameter, that is, the sub-OLAP server filters the non-roaming users, and the central OLAP server only receives the traffic information of some non-roaming users; the central OLAP server performs the traffic according to the users.
  • the central OLAP server only needs the traffic of the roaming user reported by the sub-OLAP server and the service of the non-roaming user satisfying the first condition parameter.
  • the quantity is summed, that is, the sub-OLAP server performs preliminary statistics first, and the central OLAP server further statistics based on the preliminary statistics of the sub-OLAP server, the data processing volume of the central OLAP server is reduced, and the data processing efficiency is improved.
  • the aforementioned program can be stored in a computer readable storage medium.
  • the program when executed, performs the steps including the foregoing method embodiments; and the foregoing storage medium includes: a medium that can store program codes, such as a ROM, a RAM, a magnetic disk, or an optical disk.

Landscapes

  • Engineering & Computer Science (AREA)
  • Databases & Information Systems (AREA)
  • Theoretical Computer Science (AREA)
  • Physics & Mathematics (AREA)
  • Data Mining & Analysis (AREA)
  • General Engineering & Computer Science (AREA)
  • General Physics & Mathematics (AREA)
  • Signal Processing (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Computing Systems (AREA)
  • Environmental & Geological Engineering (AREA)
  • Mobile Radio Communication Systems (AREA)
  • Management, Administration, Business Operations System, And Electronic Commerce (AREA)
  • Telephonic Communication Services (AREA)
  • Information Retrieval, Db Structures And Fs Structures Therefor (AREA)

Abstract

本发明实施例提供一种联机处理数据的方法、设备及系统。该方法包括：向至少一个子联机分析处理OLAP服务器发送数据请求消息；接收至少一个子OLAP服务器发送的用户业务数据信息，用户业务数据信息包括漫游用户的业务量信息以及满足第一条件参数的非漫游用户的业务量信息，业务量信息包括用户标识和对应的业务量；基于所述用户标识及所述对应的业务量进行业务量求和，得到所述用户标识对应的业务量总和满足第二条件参数的各用户的业务总量信息，所述业务总量信息包括所述用户标识和对应的所述业务量总和。本发明实施例提供的联机处理数据的方法、设备及系统，可以提升联机处理数据的效率。

Description

联机处理数据的方法、 设备及系统
技术领域 本发明涉及数据处理技术， 尤其涉及一种联机处理数据的方法、 设备及 系统。 背景技术
随着网络技术的迅速发展以及网络的日益普及，运营商的子网分布也 越来越广， 如一个运营商的子网可能遍布在全国的不同地理区域。 通常在 运营商的各子网中设置联机分析处理（ On-Line Transaction Processing , 筒 称 OLAP )服务器， 以获得各子网的业务量。
现有技术中， 为了能够根据各子网的业务量， 获得中心报表， 通常是 各子网中的 OLAP服务器获取各个用户的业务量，再手工将 OLAP服务器 中的所有用户的业务量数据导出为逗号分隔值（ Comma Separated value, CSV ) 文件， 再将 CSV文件手工导入到独立的数据库中， 并对独立的数 据库中的所有用户的业务量数据进行汇总， 生成中心报表。
然而，现有技术中对独立的数据库中的所有用户的业务量数据进行汇 总， 生成中心报表的处理方式， 数据处理量大， 效率低下。 发明内容
本发明实施例提供一种联机处理数据的方法、 设备及系统， 以提升联机 处理数据的效率。
第一方面， 本发明实施例提供一种联机处理数据的方法， 包括： 向至少一个子联机分析处理 OLAP服务器发送数据请求消息； 接收所述至少一个子 OLAP服务器发送的用户业务数据信息， 所述用户 业务数据信息包括漫游用户的业务量信息以及满足第一条件参数的非漫游用 户的业务量信息， 所述业务量信息包括用户标识和对应的业务量；
基于所述用户标识及所述对应的业务量进行业务量求和， 得到所述用户 标识对应的业务量总和满足第二条件参数的各用户的业务总量信息， 所述业 务总量信息包括所述用户标识和对应的所述业务量总和。
结合第一方面， 在第一方面的第一种可能的实现方式中， 所述基于所述 用户标识及所述对应的业务量进行业务量求和， 得到所述用户标识对应的业 务量总和满足第二条件参数的各用户的业务总量信息， 包括：
基于所述用户标识及所述对应的业务量统计所述用户标识对应的用户作 为漫游用户和非漫游用户的业务量总和；
根据各所述用户的业务量总和， 确定业务量总和满足第二条件参数的各 用户的业务总量信息。
结合第一方面的第一种可能的实现方式， 在第一方面的第二种可能的实 现方式中， 所述数据请求消息中携带数据上报参数， 所述数据上报参数包括 如下中的任一或其组合： 需统计的业务类型参数、 统计时间段参数、 所述第 一条件参数。
结合第一方面、 第一方面的第一种或第二种任一种可能的实现方式， 在 第一方面的第三种可能的实现方式中， 所述第一条件参数为业务量大于第一 预设阈值的条件参数， 或业务量在所有非漫游用户的业务量中排在第一预设 排名之前的条件参数；
所述第二条件参数为业务量总和大于第二预设阈值的条件参数， 或业务 量总和在所有用户的业务量总和中排在第二预设排名之前的条件参数。
结合第一方面、 第一方面的第一种至第三种任一可能的实现方式中， 在 第一方面的第四种可能的实现方式中， 所述基于所述用户标识及所述对应的 业务量进行业务量求和， 得到所述用户标识对应的业务量总和满足第二条件 参数的各用户的业务总量信息之后， 还包括：
根据所述满足第二条件参数的各用户的业务总量信息， 生成多维业务量 图表。
结合第一方面、 第一方面的第一种至第四种任一可能的实现方式， 在第 一方面的第五种可能的实现方式中， 各所述子联机分析处理 OLAP服务器设 置在不同地理区域。
第二方面， 本发明实施例提供一种联机处理数据的方法， 包括： 接收中 央联机分析处理 OLAP服务器发送的数据请求消息， 并获取与所述数据请求 消息关联的数据上报参数；
根据所述数据上报参数， 对漫游用户和非漫游用户的业务量进行统计， 得到用户业务数据信息， 所述用户业务数据信息包括漫游用户的业务量信息 以及满足第一条件参数的非漫游用户的业务量信息， 所述业务量信息包括用 户标识和对应的业务量；
向所述中央 OLAP服务器发送所述用户业务数据信息， 以使所述中央 OLAP服务器基于所述用户标识及所述对应的业务量进行业务量求和， 得到 所述用户标识对应的业务量总和满足第二条件参数的各用户的业务总量信 息， 所述业务总量信息包括所述用户标识和对应的所述业务量总和。
结合第二方面， 在第二方面的第一种可能的实现方式中， 所述根据所述 数据上报参数， 对漫游用户和非漫游用户的业务量进行统计， 得到用户业务 数据信息之前， 还包括：
接收深度包解析设备发送的至少一条用户业务量信息， 每条用户业务量 信息包括用户的用户标识、 所述用户的单次业务量、 所述用户的归属地标识 及产生所述单次业务量的地理区域标识；
所述根据所述数据上报参数， 对漫游用户和非漫游用户的业务量进行统 计， 得到用户业务数据信息， 包括：
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识不 一致， 则确定所述用户为漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述漫游用户 的业务量信息；
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识一 致， 则确定所述用户为非漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述非漫游用 户的业务量； 根据所有非漫游用户的业务量确定所述满足第一条件参数的非 漫游用户的业务量信息。
结合第二方面， 在第二方面的第二种可能的实现方式中， 所述数据上报 参数包括如下中的任一或其组合： 需统计的业务类型参数、 统计时间段参数、 所述第一条件参数；
若所述数据上报参数包括需统计的业务类型参数， 则所述根据所述数据 上报参数， 对漫游用户和非漫游用户的业务量进行统计， 得到用户业务数据 信息包括： 对漫游用户和非漫游用户对应所述需统计的业务类型参数的业务 量进行统计， 得到用户业务数据信息；
若所述数据上报参数包括统计时间段参数， 则所述根据所述数据上报参 数， 对漫游用户和非漫游用户的业务量进行统计， 得到用户业务数据信息包 括： 对漫游用户和非漫游用户对应所述统计时间段参数的业务量进行统计， 得到用户业务数据信息。
结合第二方面、 第二方面的第一种或第二种任一种可能的实现方式， 在 第二方面的第三种可能的实现方式中， 所述第一条件参数为业务量大于第一 预设阈值的条件参数， 或业务量在所有非漫游用户的业务量中排在第一预设 排名之前的条件参数；
所述第二条件参数为业务量总和大于第二预设阈值的条件参数， 或业务 量总和在所有用户的业务量总和中排在第二预设排名之前的条件参数。
结合第二方面、 第二方面的第一种至第三种任一种可能的实现方式， 在 第二方面的第四种可能的实现方式中， 所述获取与所述数据请求消息关联的 数据上报参数包括：
根据预定的所述数据请求消息与数据上报参数的映射关系， 获取与所述 数据请求消息关联的数据上报参数；
或者， 如果所述数据请求消息中携带数据上报参数， 则所述获取与所述 数据请求消息关联的数据上报参数包括：
从所述数据请求消息中提取出携带的数据上报参数。
第三方面， 本发明实施例提供一种中央联机分析处理服务器， 包括： 发送模块， 用于向至少一个子联机分析处理 OLAP服务器发送数据请求 消息；
接收模块， 用于接收所述至少一个子 OLAP服务器发送的用户业务数据 信息， 所述用户业务数据信息包括漫游用户的业务量信息以及满足第一条件 参数的非漫游用户的业务量信息， 所述业务量信息包括用户标识和对应的业 务量；
处理模块，用于基于所述用户标识及所述对应的业务量进行业务量求和， 得到所述用户标识对应的业务量总和满足第二条件参数的各用户的业务总量 信息， 所述业务总量信息包括所述用户标识和对应的所述业务量总和。
结合第三方面， 在第三方面的第一种可能的实现方式中， 所述处理模块 具体用于，
基于所述用户标识及所述对应的业务量统计所述用户标识对应的用户作 为漫游用户和非漫游用户的业务量总和；
根据各所述用户的业务量总和， 确定业务量总和满足第二条件参数的各 用户的业务总量信息。
结合第三方面的第一种可能的实现方式， 在第三方面的第二种可能的实 现方式中， 所述发送模块具体用于： 向至少一个子 OLAP服务器发送携带有 数据上报参数的数据请求消息， 所述数据上报参数包括如下中的任一或其组 合： 需统计的业务类型参数、 统计时间段参数、 所述第一条件参数。
结合第三方面、 第三方面的第一种或第二种任一种可能的实现方式， 在 第三方面的第三种可能的实现方式中， 所述处理模块还用于： 根据所述满足 第二条件参数的各用户的业务总量信息， 生成多维业务量图表。
第四方面， 本发明实施例提供一种子联机分析处理服务器， 其特征在于， 包括：
接收模块， 用于接收中央联机分析处理 OLAP服务器发送的数据请求消 息， 并获取与所述数据请求消息关联的数据上报参数；
处理模块， 用于根据所述数据上报参数， 对漫游用户和非漫游用户的业 务量进行统计， 得到用户业务数据信息， 所述用户业务数据信息包括漫游用 户的业务量信息以及满足第一条件参数的非漫游用户的业务量信息， 所述业 务量信息包括用户标识和对应的业务量；
发送模块， 用于向所述中央 OLAP服务器发送所述用户业务数据信息， 以使所述中央 OLAP服务器基于所述用户标识及所述对应的业务量进行业务 量求和， 得到所述用户标识对应的业务量总和满足第二条件参数的各用户的 业务总量信息， 所述业务总量信息包括所述用户标识和对应的所述业务量总 和。
结合第四方面， 在第四方面的第一种可能的实现方式中， 接收深度包解 析设备发送的至少一条用户业务量信息， 每条用户业务量信息包括用户的用 户标识、 所述用户的单次业务量、 所述用户的归属地标识及产生所述单次业 务量的地理区域标识；
所述处理模块具体用于：
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识不 一致， 则确定所述用户为漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述漫游用户 的业务量信息；
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识一 致， 则确定所述用户为非漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述非漫游用 户的业务量； 根据所有非漫游用户的业务量确定所述满足第一条件参数的非 漫游用户的业务量信息。
结合第四方面， 在第四方面的第二种可能的实现方式中， 所述数据上报 参数包括如下中的任一或其组合： 需统计的业务类型参数、 统计时间段参数、 所述第一条件参数； 所述处理模块具体用于： 若所述数据上报参数包括需统 计的业务类型参数， 对漫游用户和非漫游用户对应所述需统计的业务类型参 数的业务量进行统计， 得到用户业务数据信息， 所述用户业务数据信息包括 漫游用户的业务量信息以及满足第一条件参数的非漫游用户的业务量信息， 所述业务量信息包括用户标识和对应的业务量；
或者， 具体用于： 若所述数据上报参数包括统计时间段参数， 对漫游用 户和非漫游用户对应统计时间段参数的业务量进行统计， 得到用户业务数据 信息， 所述用户业务数据信息包括漫游用户的业务量信息以及满足第一条件 参数的非漫游用户的业务量信息， 所述业务量信息包括用户标识和对应的业 务量。
结合第四方面， 第四方面的第一种或第二种可能的实现方式， 在第四方 面的第三种可能的实现方式中， 所述接收模块具体用于接收中央联机分析处 理 OLAP服务器发送的数据请求消息， 根据预定的所述数据请求消息与数据 上报参数的映射关系， 获取与所述数据请求消息关联的数据上报参数；
或者， 具体用于： 接收中央联机分析处理 OLAP服务器发送的数据请求 消息， 如果所述数据请求消息中携带数据上报参数， 从所述数据请求消息中 提取出携带的数据上报参数。 第五方面， 本发明实施例提供一种联机处理数据系统， 包括中央联机分 析处理 OLAP服务器和至少一个子联机分析处理 OLAP服务器， 其中：
所述中央 OLAP服务器用于： 向至少一个子 OLAP服务器发送数据请求 消息； 接收所述至少一个子 OLAP服务器发送的用户业务数据信息， 所述用 户业务数据信息包括漫游用户的业务量信息以及满足第一条件参数的非漫游 用户的业务量信息， 所述业务量信息包括用户标识和对应的业务量； 并基于 用户标识及所述对应的业务量进行业务量求和， 得到所述用户标识对应的业 务量总和满足第二条件参数的各用户的业务总量信息， 所述业务总量信息包 括用户标识和对应的业务量总和；
所述子 OLAP服务器用于： 接收所述中央 OLAP服务器发送的数据请求 消息， 并获取与所述数据请求消息对应的数据上报参数； 根据所述数据上报 参数， 对漫游用户和非漫游用户的业务量进行统计， 得到用户业务数据信息； 并向所述中央 OLAP服务器发送所述用户业务数据信息， 所述用户业务数据 信息包括漫游用户的业务量信息以及满足第一条件参数的非漫游用户的业务 量信息， 所述业务量信息包括用户标识和对应的业务量。
结合第五方面，在第五方面的第一种可能的实现方式中，所述中央 OLAP 服务器具体用于：
向至少一个子 OLAP服务器发送数据请求消息； 接收所述至少一个子 OLAP服务器发送的用户业务数据信息， 所述用户业务数据信息包括漫游用 户的业务量信息以及满足第一条件参数的非漫游用户的业务量信息， 所述业 务量信息包括用户标识和对应的业务量；
基于所述用户标识及所述对应的业务量统计所述用户标识对应的用户作 为漫游用户和非漫游用户的业务量总和；
根据各所述用户的业务量总和， 确定业务量总和满足第二条件参数的各 用户的业务总量信息，所述业务总量信息包括用户标识和对应的业务量总和。
结合第五方面， 在第五方面的第二种可能的实现方式中， 所述子 OLAP 服务器具体用于：
接收所述中央 OLAP服务器发送的数据请求消息；
根据预定的所述数据请求消息与数据上报参数的映射关系， 获取与所述 数据请求消息关联的数据上报参数； 或者， 如果所述数据请求消息中携带数据上报参数， 从所述数据请求消 息中提取出携带的数据上报参数；
接收深度包解析设备发送的至少一条用户业务量信息， 每条用户业务量 信息包括用户的用户标识、 所述用户的单次业务量、 所述用户的归属地标识 及产生所述单次业务量的地理区域标识；
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识不 一致， 则确定所述用户为漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述漫游用户 的业务量信息， 所述业务量信息包括用户标识和对应的业务量；
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识一 致， 则确定所述用户为非漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述非漫游用 户的业务量； 根据所有非漫游用户的业务量确定所述满足第一条件参数的非 漫游用户的业务量信息， 所述业务量信息包括用户标识和对应的业务量； 向所述中央 OLAP服务器发送所述用户业务数据信息， 以使所述中央
OLAP服务器基于所述用户标识及所述对应的业务量进行业务量求和， 得到 所述用户标识对应的业务量总和满足第二条件参数的各用户的业务总量信 息， 所述业务总量信息包括所述用户标识和对应的所述业务量总和。
结合第五方面， 在第五方面的第三种可能的实现方式中， 所述子 OLAP 服务器具体用于：
接收所述中央 OLAP服务器发送的数据请求消息；
根据预定的所述数据请求消息与数据上报参数的映射关系， 获取与所述 数据请求消息关联的数据上报参数；
或者， 如果所述数据请求消息中携带数据上报参数， 从所述数据请求消 息中提取出携带的数据上报参数；
所述数据上报参数包括如下中的任一或其组合：需统计的业务类型参数、 统计时间段参数、 所述第一条件参数；
若所述数据上报参数包括需统计的业务类型参数， 对漫游用户和非漫游 用户对应所述需统计的业务类型参数的业务量进行统计， 得到用户业务数据 信息， 所述用户业务数据信息包括漫游用户的业务量信息以及满足第一条件 参数的非漫游用户的业务量信息， 所述业务量信息包括用户标识和对应的业 务量； 或者，
若所述数据上报参数包括统计时间段参数， 对漫游用户和非漫游用户对 应所述统计时间段参数的业务量进行统计， 得到用户业务数据信息， 所述用 户业务数据信息包括漫游用户的业务量信息以及满足第一条件参数的非漫游 用户的业务量信息， 所述业务量信息包括用户标识和对应的业务量；
向所述中央 OLAP服务器发送所述用户业务数据信息， 以使所述中央 OLAP服务器基于所述用户标识及所述对应的业务量进行业务量求和， 得到 所述用户标识对应的业务量总和满足第二条件参数的各用户的业务总量信 息， 所述业务总量信息包括所述用户标识和对应的所述业务量总和。
本发明实施例提供一种联机处理数据的方法、 设备及系统， 其中， 通过 中央 OLAP服务器向至少一个子 OLAP服务器发送数据请求消息，中央 OLAP 服务器接收至少一个子 OLAP服务器发送的用户业务数据信息， 用户业务数 据信息包括漫游用户的业务量信息以及满足第一条件参数的非漫游用户的业 务量信息， 即子 OLAP服务器对非漫游用户进行筛选， 中央 OLAP服务器仅 接收部分非漫游用户的业务量信息； 中央 OLAP服务器按用户进行业务量求 和，得到业务量总和满足第二条件参数的各用户的业务总量信息，中央 OLAP 月良务器只需对经过子 OLAP服务器上报的漫游用户的业务量以及满足第一条 件参数的非漫游用户的业务量进行求和处理， 即子 OLAP服务器先进行初步 统计，中央 OLAP服务器再基于子 OLAP服务器初步统计的结果进一步统计， 中央 OLAP服务器的数据处理量减少， 数据处理效率提高。 附图说明
为了更清楚地说明本发明实施例或现有技术中的技术方案， 下面将对实 施例或现有技术描述中所需要使用的附图作一筒单地介绍， 显而易见地， 下 面描述中的附图是本发明的一些实施例， 对于本领域普通技术人员来讲， 在 不付出创造性劳动性的前提下， 还可以根据这些附图获得其他的附图。
图 1为本发明联机处理数据的方法实施例一的流程图；
图 2为本发明联机处理数据的方法实施例二的流程图；
图 3为本发明联机处理数据的方法实施例三的流程图； 图 4为本发明联机处理数据的方法实施例四的流程图
图 5为本发明中央联机分析处理服务器实施例一的结构示意图； 图 6为本发明子联机分析处理服务器实施例一的结构示意图；
图 7为本发明中央联机分析处理服务器实施例二的结构示意图； 图 8为本发明子联机分析处理服务器实施例二的结构示意图；
图 9为本发明联机处理数据系统实施例一的结构示意图；
图 10为本发明联机处理数据系统的应用示意图。 具体实施方式
为使本发明实施例的目的、 技术方案和优点更加清楚， 下面将结合本发 明实施例中的附图， 对本发明实施例中的技术方案进行清楚、 完整地描述， 显然， 所描述的实施例是本发明一部分实施例， 而不是全部的实施例。 基于 本发明中的实施例， 本领域普通技术人员在没有作出创造性劳动前提下所获 得的所有其他实施例， 都属于本发明保护的范围。
图 1为本发明联机处理数据的方法实施例一的流程图。 本实施的执行主 体为中央联机分析处理（On-Line Transaction Processing, 筒称 OLAP )服务 器， 该中央联机分析处理服务器可以通过软件和 /或硬件实现。 如图 1所示， 本实施例的方法可以包括：
步骤 101: 向至少一个子 OLAP服务器发送数据请求消息。
当运营商的决策人员需要了解网络的实际运营情况， 并根据运营情况作 出相关决策时， 可以向中央 OLAP服务器触发查询请求， 同时， 该查询请求 中可以携带中央 OLAP服务器需要统计的数据参数， 即数据统计参数。 数据 统计参数通常可以包括需统计的业务类型参数、 统计时间段参数、 第一条件 参数中的任一或其组合。 该数据统计参数可以由查询请求携带， 还可以为预 设的默认参数， 还可以根据查询请求中携带的部分参数与预设的部分参数以 及其他参数的映射关系确定全部参数。 例如， 查询请求中携带的数据统计参 数为需统计的业务类型参数， 预设的部分参数为统计时间段参数， 则中央 OLAP服务器可根据该需统计的业务类型参数与统计时间段参数的映射关 系， 确定统计时间段参数。 中央 OLAP服务器接收该查询请求后， 会向至少 一个子 OLAP服务器发送数据请求消息，以使子 OLAP服务器进行数据统计， 并将统计得到的用户业务数据信息上报给中央 OLAP服务器。 本领域技术人 员可以理解， 该数据请求消息中可以携带数据上报参数， 也可以不携带数据 上报参数， 该数据上报参数可以与数据统计参数相同， 也可以与数据统计参 数不同。 本领域技术人员可以理解， 本实施例中的统计包括有关的数据的搜 集、 整理、 计算和分析等活动。
子 OLAP服务器可以根据数据上报参数进行数据统计。 在具体实现过程 中， 子 OLAP服务器先获取与数据请求消息关联的数据上报参数， 具体可通 过以下两种方式实现， 一种可能的实现方式为根据预定的数据请求消息与数 据上报参数的映射关系， 获取与数据请求消息关联的数据上报参数， 即子 OLAP服务器， 接收到数据请求消息后， 根据该映射关系， 获取数据上报参 数。 另一种可能的实现方式为如果数据请求消息中携带数据上报参数， 从数 据请求消息中提取出携带的数据上报参数。
本领域技术人员可以理解， 数据请求消息中还可以携带部分数据上报参 数， 子 OLAP服务器根据预定的数据请求消息与部分数据上报参数的映射关 系， 确定全部数据上报参数。
其中， 数据上报参数包括如下中的任一或其组合： 需统计的业务类型参 数、 统计时间段参数、 第一条件参数。 其中， 需统计的业务类型参数可以包 括流量业务， 视频业务， 语音业务等； 统计时间段参数中包括统计时间的起 点和终点，例如 2012-12-18日晚 7时至晚 9时，对于具体的统计时间段参数， 本实施例在此不作特别限制； 第一条件参数可以为子 OLAP服务器返回给中 央 OLAP服务器的非漫游用户的业务量具体满足的条件参数。 本实施例中通 过数据请求消息中携带数据上报参数， 可以由中央 OLAP服务器对数据统计 进行统一管理， 子 OLAP服务器中不需存储数据上报参数， 可以减少各子 OLAP服务器的数据存储量。
步骤 102: 接收所述至少一个子 OLAP服务器发送的用户业务数据信息， 所述用户业务数据信息包括漫游用户的业务量信息以及满足第一条件参数的 非漫游用户的业务量信息， 所述业务量信息包括用户标识和对应的业务量。
在具体应用过程中， 子 OLAP服务器可以分布在运营商在不同地理区域 部署的子网中， 该子网可以以城市为单位， 用户可以为使用移动终端的用户。 当各个子 OLAP服务器根据数据请求消息， 统计到用户的业务量信息之后， 便向中央 OLAP服务器发送用户业务数据信息。 中央 OLAP接收至少一个子 OLAP服务器发送的用户业务数据信息。 其中， 用户标识可以为移动终端的 各种标识符， 例如国际移动用户识别码或手机号码等， 业务量为与该用户标 识对应的业务量。
以子 OLAP服务器位于广州， 需统计的业务类型参数为流量业务， 统计 时间段参数为第三季度， 第一条件参数为流量大于第一预设阈值的条件参数 为例， 对用户业务数据信息进行详细说明。 用户业务数据信息中包括： 漫游 用户的流量信息， 如归属地为深圳的用户， 当该用户在第三季度漫游到广州 时， 作为漫游用户在广州使用流量业务并产生流量的流量信息。 本领域技术 人员可以理解， 在具体的实现过程中， 每一个漫游到广州的用户在广州本地 使用流量业务并产生流量的流量信息都属于漫游用户的流量信息。
用户业务数据信息中还包括满足第一条件参数的非漫游用户的业务量信 息， 即归属地属于广州的用户， 在广州本地使用流量业务并产生流量的流量 信息。 但由于归属地属于广州的用户相对较多， 而一些用户在第三季度使用 流量业务的频率较少， 或产生的流量较少， 对该些用户进行统计， 获得的统 计结果对于运营商了解网络的实际运营情况的贡献不大， 同时， 大量的数据 会增加中央 OLAP服务器的处理负担， 因此， 子 OLAP服务器对非漫游用户 进行筛选， 得到满足第一条件参数的非漫游用户， 例如当非漫游用户的流量 大于第一预设阈值时， 该非漫游用户即为满足第一条件参数的漫游用户。
除了上述列举的第一条件参数外， 第一条件参数还可以为业务量在所有 非漫游用户的业务量中排在第一预设排名之前的条件参数。 例如， 当第一预 设排名为 1000时， 在第三季度流量总量在前 1000名的非漫游用户， 即为满 足第一条件参数的非漫游用户。
本领域技术人员可以理解， 中央 OLAP服务器接收的业务量统计信息为 多个子 OLAP服务器发送的业务量统计信息， 且每一个子 OLAP服务器发送 的业务量统计信息均与上述子 OLAP服务器位于广州的实施例类似， 本实施 例在此不再举例。
步骤 103: 基于所述用户标识及所述对应的业务量进行业务量求和， 得 到所述用户标识对应的业务量总和满足第二条件参数的各用户的业务总量信 息， 所述业务总量信息包括所述用户标识和对应的所述业务量总和。 中央 OLAP服务器接收到至少一个子 OLAP服务器发送的用户业务数据 信息之后， 基于用户标识对各用户的业务量进行业务量求和， 得到各用户的 业务量总和， 进而得到满足第二条件参数的各用户的业务总量信息。
本领域技术人员可以理解， 在统计时间段参数内， 当用户既在归属地使 用业务又漫游到多个其它地理区域使用业务时， 中央 OLAP服务器将接收到 该用户漫游到的多个地理区域对应的多个子 OLAP服务器分别发送的该用户 作为漫游用户的业务量信息。 同时， 中央 OLAP服务器还将接收到该用户的 归属地对应的子 OLAP服务器发送的该用户作为非漫游用户的业务量信息。 因此， 若要获得该用户对应统计时间段参数， 即发生在统计时间段内的业务 总量信息， 可基于该用户的用户标识， 统计该用户作为漫游用户和非漫游用 户的业务量总和， 即将同一个用户标识对应的所有业务量求和， 得到该用户 的业务总量。
对于在统计时间段内， 没有漫游到其它地理区域并使用业务的用户， 基 于该用户的用户标识进行业务量求和时， 该用户的业务量总和即该用户作为 非漫游用户的业务量。
在得到各用户的业务量总和之后， 根据各用户的业务量总和， 确定业务 量总和满足第二条件参数的各用户的业务总量信息。 其中第二条件参数可以 为预设的第二条件参数， 还可以为运营商触发查询请求时， 查询请求中携带 的第二条件参数。 对于第二条件参数的具体获取方式， 本实施例在此不作特 别限制。
在一种可能的实现方式中， 第二条件参数为业务量总和大于第二预设阈 值的条件参数， 或业务量总和在所有用户的业务量总和中排在第二预设排名 之前的条件参数。 具体地， 中央 OLAP服务器进一步对用户进行筛选， 以需 统计的业务类型参数为流量业务参数为例， 当各用户的流量总和大于第二预 设阈值时， 或用户的流量总和排在第二预设排名之前时， 该用户为满足第二 条件参数的用户， 并存储记录满足第二条件参数的用户的业务总量信息， 该 业务总量信息包括用户标识和与该用户标识对应的业务量总和。
本发明实施例提供的联机处理数据的方法， 通过中央 OLAP服务器向至 少一个子 OLAP服务器发送数据请求消息， 中央 OLAP服务器接收至少一个 子 OLAP服务器发送的用户业务数据信息， 用户业务数据信息包括漫游用户 的业务量信息以及满足第一条件参数的非漫游用户的业务量信息， 即子
OLAP服务器对非漫游用户进行筛选， 中央 OLAP服务器仅接收部分非漫游 用户的业务量信息； 中央 OLAP服务器按用户进行业务量求和， 得到业务量 总和满足第二条件参数的各用户的业务总量信息， 中央 OLAP服务器只需对 经过子 OLAP服务器上报的漫游用户的业务量以及满足第一条件参数的非漫 游用户的业务量进行求和处理， 即子 OLAP服务器先进行初步统计， 中央 OLAP服务器再基于子 OLAP服务器初步统计的结果进一步统计，中央 OLAP 服务器的数据处理量减少， 数据处理效率提高。
进一步地， 在上述图 1所示的实施例中， 在中央 OLAP服务器基于所述 用户标识及所述对应的业务量进行业务量求和， 得到所述用户标识对应的业 务量总和满足第二条件参数的各用户的业务总量信息之后， 还包括：
根据满足第二条件参数的各用户的业务总量信息，生成多维业务量图表。 在具体实现过程中， 中央 OLAP服务器， 可以仿照决策人员的多角度思 考模式， 根据满足第二条件参数的各用户的业务总量信息， 生成多维业务量 图表， 其中， 维指分析角度。 例如， 统计时间段参数是一个维度， 业务类型 参数、 用户标识也分别是一个维度。
本实施提供的联机处理数据方法， 决策人员可以根据多维业务量图表快 速地从各个分析角度获取数据， 也能动态的在各个角度之间切换或者进行多 角度综合分析， 具有极大的分析灵活性。
图 2为本发明联机处理数据的方法实施例二的流程图。 本实施例的执行 主体为子 OLAP服务器， 该子 OLAP服务器可以通过软件和 /或硬件实现。 如 图 2所示， 本实施例的方法可以包括：
步骤 201: 接收中央 OLAP服务器发送的数据请求消息， 并获取与所述 数据请求消息关联的数据上报参数。
子 OLAP服务器接收中央 OLAP服务器发送的数据请求消息， 进行数据 统计。 子 OLAP服务器在进行数据统计之前， 需要获取与数据请求消息关联 的数据上报参数。 子 OLAP服务器获取与数据请求消息关联的数据上报参数 的方式包括以下可能的实现方式， 一种可能的实现方式为根据预定的数据请 求消息与数据上报参数的映射关系， 获取与数据请求消息关联的数据上报参 数， 即子 OLAP服务器， 接收到数据请求消息后， 根据该映射关系， 获取数 据上报参数。 另一种可能的实现方式为如果数据请求消息中携带数据上报参 数， 从数据请求消息中提取出携带的数据上报参数。
步骤 202: 根据所述数据上报参数， 对漫游用户和非漫游用户的业务量 进行统计， 得到用户业务数据信息， 所述用户业务数据信息包括漫游用户的 业务量信息以及满足第一条件参数的非漫游用户的业务量信息， 所述业务量 信息包括用户标识和对应的业务量。
子 OLAP服务器根据数据上报参数对漫游用户和非漫游用户的业务量进 行统计， 得到漫游用户的业务量信息以及满足第一预设条件参数的非漫游用 户的业务量信息。
其中， 数据上报参数包括如下中的任一或其组合： 需统计的业务类型参 数、 统计时间段^ t、 第一条件参数。
子 OLAP服务器可根据数据上报参数的具体内容， 进行统计。 例如， 若 数据上报参数包括需统计的业务类型参数， 则步骤 202包括： 根据数据上报 参数， 对漫游用户和非漫游用户对应需统计的业务类型参数的业务量进行统 计， 得到用户业务数据信息； 或者
若数据上报参数包括统计时间段参数， 则步骤 202包括： 根据数据上报 参数， 对漫游用户和非漫游用户对应统计时间段参数的业务量进行统计， 得 到用户业务数据信息。
本领域技术人员可以理解， 在实际操作过程中， 具体还可以将统计时间 段参数、 业务类型参数结合起来， 统计漫游用户和非漫游用户在统计时间段 内、 特定业务类型的业务量。
为了提高中央 OLAP服务器的处理效率， 子 OLAP服务器还必须确定满 足第一条件参数的非漫游用户。 在一个可行的实施例中， 该第一条件参数为 业务量大于第一预设阈值的条件参数， 或业务量在所有非漫游用户的业务量 中排在第一预设排名之前的条件参数。
步骤 203: 向所述中央 OLAP服务器发送所述用户业务数据信息， 以使 所述中央 OLAP服务器基于所述用户标识及所述对应的业务量进行业务量求 和， 得到所述用户标识对应的业务量总和满足第二条件参数的各用户的业务 总量信息， 所述业务总量信息包括所述用户标识和对应的所述业务量总和。
在一个可行的实施例中， 第二条件参数为业务量总和大于第二预设阈值 的条件参数， 或业务量总和在所有用户的业务量总和中排在第二预设排名之 前的条件参数。
本发明实施例提供的联机处理数据的方法， 通过子 OLAP服务器接收中 央 OLAP服务器发送的数据请求消息， 对漫游用户和非漫游用户的业务量进 行统计， 得到用户业务数据信息， 用户业务数据信息包括漫游用户的业务量 信息以及满足第一条件参数的非漫游用户的业务量信息， 业务量信息包括用 户标识和业务量， 向中央 OLAP服务器发送用户业务数据信息， 即子 OLAP 服务器对非漫游用户进行筛选， 子 OLAP服务器仅向中央 OLAP服务器发送 部分非漫游用户的业务量信息， 以使中央 OLAP服务器只需对经过子 OLAP 服务器上报的漫游用户的业务量以及满足第一条件参数的非漫游用户的业务 量进行求和处理， 即子 OLAP服务器先进行初步统计， 中央 OLAP服务器再 基于子 OLAP服务器初步统计的结果进一步统计， 中央 OLAP服务器的数据 处理量减少， 数据处理效率提高。
图 3为本发明联机处理数据的方法实施例三的流程图。 本实施例在图 2 实施例的基础上， 对图 2实施例中的步骤 202进行详细说明。
在步骤 202之前， 还包括步骤 301。 在步骤 301中， 子 OLAP服务器接 收深度包解析设备发送的至少一条用户业务量信息， 每条用户业务量信息包 括用户的用户标识、 所述用户的单次业务量、 用户的归属地标识及产生单次 业务量的地理区域标识。
深度包解析（ Deep Packet Inspection , 筒称 DPI )设备能够感知网络应用， 能够基于应用层对流量进行检测。 在具体实现过程中， 一方面， DPI设备可 以为具有 DPI功能的服务器， 与设置在各地理区域的网关设备连接， 另一方 面， 因为各个地理区域的用户的移动终端的接入最终都汇聚到网关设备上， 所以， 可以将 DPI模块可以设置在网关中， 使网关具有 DPI能力、 作为 DPI 设备。 同时， 每一个子 OLAP服务器都有一个与之相连的网关， 当 DPI设备 获知到用户在该网关对应的区域内使用业务时， DPI设备会向子 OLAP服务 器发送至少一条用户业务量信息， 该业务量信息包括用户的用户标识、 单次 业务量、 归属地标识以及产生单次业务量的地理区域标识。 务量的地理区域标识可以为用户在使用业务时， 产生单次业务量的发生地的 标识； 用户的单次业务量可以为用户使用一次业务所产的业务量， 例如， 用 户使用一次流量业务所产生的流量， 也可以为用户使用一次通话业务所产生 的通话时长等， 对于单次业务量的具体方式， 本实施例此处不作特别限制。 特别地， 归属地标识和产生单次业务量的地理区域标识可以为对应的 DPI设 备的设备编号。 例如表一所示， 位于不同地理区域的子 OLAP服务器都有与 之对应的 DPI设备， 位于深圳的子 OLAP服务器对应的 DPI设备的设备编号 为 1001、 位于广州的子 OLAP服务器对应的 DPI设备的设备编号为 1002、 位于珠海的子 OLAP服务器对应的 DPI设备的设备编号为 1003、位于东莞子 OLAP服务器对应的 DPI设备的设备编号为 1004。 表一中的映射信息可以作 为元数据， 由各个 DPI设备来维护。
表一
Figure imgf000019_0001
以一个具体实施例为例，当归属地属于深圳的用户（归属地标识为 1001 ), 漫游到广州时， 在广州使用业务， 并产生相应的流量时 （产生单次业务量的 地理区域标识 1002 ) , 在广州的 DPI设备感知到用户的此行为， 向与之相连 的子 OLAP服务器发送用户业务量信息， 该信息包括用户的手机号码、 单次 业务量、 归属地标识 1001、 产生单次业务量的地理区域标识 1002。 本领域技 术人员可以理解，子 OLAP服务器在接收 DPI设备发送的用户业务量信息时， 可以一条一条的实时接收， 也可以大批量的同时接收多条用户业务量信息， 对于子 OLAP服务器接收的具体实现方式， 本实施例在此不再赘述。
在一个可行的实施例中， 子 OLAP服务器在接收到 DPI设备发送的用户 业务量信息后， 对该用户业务量信息进行保存， 具体实现过程中， 可以新创 建一个用户信息表， 该用户信息表用于存储用户业务量信息， 例如用户的标 识， 归属地标识、 产生单次业务量的地理区域标识以及业务量。 当 DPI设备 向子 OLAP服务器发送用户业务量信息时， 子 OLAP服务器可在该用户信息 表中插入该用户业务量信息， 为了区分用户的每条用户业务量信息以及确定 产生的业务量的时间， 还可在用户信息表中增加产生单次业务量的时间点字 段， 用于记录产生单次业务量的时间。
相应地， 步骤 202具体包括：
步骤 2021 : 确定用户的归属地标识与产生单次业务量的地理区域标识是 否一致， 若否， 执行步骤 2022, 若是， 执行步骤 2023;
步骤 2022: 确定用户为漫游用户， 并根据数据上报参数对包含用户标识 的所有用户业务量信息中的单次业务量进行统计， 得到漫游用户的业务量信 步骤 2023: 确定用户为非漫游用户， 并根据数据上报参数对包含用户标 识的所有用户业务量信息中的单次业务量进行统计， 得到非漫游用户的业务 量； 根据非漫游用户的业务量确定满足第一条件参数的非漫游用户的业务量 信息。
在具体实现过程中， 子 OLAP服务器可直接从用户信息表中获取相关信 息。 例如， 在步骤 2021中， 子 OLAP服务器可以根据该用户信息表中的归属 地标识和产生所述单次业务量的地理区域标识， 确定该用户为漫游用户或非 漫游用户。 如表二所示， 表二仅列出了用户信息表中的部分字段： 用户标识、 归属 识、 产生单次业务量的地理区域标识。
Figure imgf000020_0001
子 OLAP服务器确定归属地标识与产生所述单次业务量的地理区域标识 是否一致， 即子 OLAP服务器确定表二中的同一用户产生单次业务量时， 用 户的归属地标识和产生单次业务量的地理区域标识是否一致。 例如， 对于用 户 13512345678,其归属地标识 1001和产生单次业务量的地理区域标识 1002 不一致， 则确定该用户为漫游用户， 进行步骤 2022, 对于用户 13222345678, 其归属地标识 1002和产生单次业务量的地理区域标识 1002—致， 则确定该 用户为非漫游用户， 进行步骤 2023。
在一种可行的实施例中， 在确定用户为漫游用户或非漫游用户后， 可根 据用户信息表新建漫游信息表和非漫游信息表。 其中， 漫游信息表可仅包括 漫游用户的用户标识、漫游用户的单次业务量以及产生该单次业务量的时间； 对应地， 非漫游信息表也可仅包括非漫游用户的用户标识、 漫游用户的单次 业务量以及产生该单次业务量的时间。 本领域技术人员可以理解， 本实施例 的建表方式有多种， 本实施例对具体的建表方式， 不作特别限制。
在步骤 2022中， 确定了当前用户为漫游用户时， 根据数据上报参数对包 含用户标识的所有用户业务信息中的单次业务量进行统计， 得到漫游用户的 业务量。 具体地， 可根据数据上报参数中的各参数进行统计， 例如， 统计时 间段参数指示统计时间段为五月的第二周， 需统计的业务类型参数为流量业 务参数时， 则将该用户在该时间段内产生的所有属于流量业务的单次业务量 累加。
在步骤 2023中， 确定了当前用户为非漫游用户时， 根据数据上报参数对 包含用户标识的所有用户业务量信息中的单次业务量进行统计， 得到非漫游 用户的业务量， 根据所有非漫游用户的业务量确定满足所述第一条件参数的 非漫游用户的用户标识和业务量， 具体地， 可根据数据上报参数中的各参数 进行统计。 例如， 统计出各非漫游用户在统计时间段晚 7点至 8点的属于流 量业务的业务量， 并根据各非漫游用户的流量业务的单次业务量， 确定满足 第一条件参数的非漫游用户的用户标识和业务量。 第一条件参数可以为业务 量大于第一预设阈值的条件参数。
本实例的联机处理数据方法， 通过采用基于漫游用户确定业务量信息， 以及基于满足第一条件参数的非漫游用户确定业务量信息， 具有很强的针对 性， 避免没有意义的系统资源浪费， 使联机处理数据方法的性能得到很大提 升。
图 4为本发明联机处理数据的方法实施例四的流程图。 如图 4所示， 以 两个子 OLAP服务器为例， 即当运营商决策人员触发查询请求后， 本实施例 的联机处理数据方法包括以下步骤：
步骤 401、 决策人员向中央 OLAP服务器触发查询请求；
步骤 402、 中央 OLAP服务器向子 OLAP服务器 1发送数据请求消息； 步骤 403、 中央 OLAP服务器向子 OLAP服务器 2发送数据请求消息； 本领域技术人员可以理解， 步骤 402和步骤 403没有严格的时序关系， 二 者可同时进行。 步骤 404、子 OLAP服务器 1获取与数据请求消息关联的数据上报参数，根 据数据上报参数， 对漫游用户和非漫游用户的业务量进行统计， 得到用户业 务数据信息；
步骤 405、子 OLAP服务器 2获取与数据请求消息关联的数据上报参数，根 据数据上报参数， 对漫游用户和非漫游用户的业务量进行统计， 得到用户业 务数据信息；
本领域技术人员可以理解， 步骤 404与步骤 405没有严格的时序关系， 二者可同时进行。 具体的实施例可参照图 2和图 3所示实施例， 本实施例在 此不再赘述。
步骤 406、 子 OLAP服务器 1向中央 OLAP服务器发送用户业务数据信息； 步骤 407、 子 OLAP服务器 2向中央 OLAP服务器发送用户业务数据信息； 本领域技术人员可以理解， 步骤 406和步骤 407没有严格的时序关系， 二 者可同时进行。
步骤 408、 中央 OLAP服务器基于用户标识进行业务量求和， 得到业务量 总和满足第二条件参数的各用户的业务总量信息；
步骤 409、 中央 OLAP服务器根据满足第二条件参数的各用户的业务总量 信息， 生成多维业务量图表。
对于步骤 408和步骤 409, 具体的实施例可参照图 1所示实施例， 本实 施例在此不再赘述。
本实施例中仅以两个子 OLAP服务器为例，在具体应用过程中，子 OLAP 服务器的数量可以更多， 每个子 OLAP服务器进行的联机处理数据方法可参 照图 2和图 3所示实施例。 中央 OLAP服务器进行的联机处理数据方法可参 照图 1所示实施例。
应用图 4所示实施例， 在一个具体的实施例中， 当子 OLAP服务器的数 量为 4, 每个子 OLAP服务器包括 100万用户， 即总用户为 400万时， 假设 总用户中 15%的用户漫游到其它三个区域， 总用户中 20%的用户漫游到其它 两个区域， 总用户中 25%的用户漫游到其它一个区域， 总用户中其它 40%的 用户无漫游行为。 当需统计业务类型为流量业务、 统计时间段为 2012年 1月 1 日至 2012年 1月 31 日时， 采用本实施例的联机数据处理方法， 中央 OLAP 服务器最终统计的用户业务量信息的条数约为 237,000条， 中央 OLAP服务 器生成多维业务量图表的时间为 121秒， 而采用现有技术的生成方法， 在相 同的场景和条件下， 中央 OLAP服务器最终统计的记录约为 400,000条， 最 终生成多维业务量图表的时间为 517秒， 相对于现有技术， 本实施例提供的 联机处理数据方法， 性能提升 76.6%。
图 5为本发明中央联机分析处理服务器实施例一的结构示意图。 如图 5 所示，本实施例提供的中央 OLAP服务器 50包括发送模块 501、接收模块 502、 处理模块 503。
其中， 发送模块 501用于向至少一个子联机分析处理 OLAP服务器发送 数据请求消息；
接收模块 502用于接收所述至少一个子 OLAP服务器发送的用户业务数 据信息， 所述用户业务数据信息包括漫游用户的业务量信息以及满足第一条 件参数的非漫游用户的业务量信息， 所述业务量信息包括用户标识和对应的 业务量；
处理模块 503用于基于所述用户标识及所述对应的业务量进行业务量求 和， 得到所述用户标识对应的业务量总和满足第二条件参数的各用户的业务 总量信息， 所述业务总量信息包括所述用户标识和对应的所述业务量总和。
本实施例的中央联机分析处理服务器可以用于执行图 1所示实施例的技 术方案， 其实现原理和技术效果类似， 此处不再赘述。
进一步地， 所述处理模块 503具体用于：
基于所述用户标识及所述对应的业务量统计所述用户标识对应的用户作 为漫游用户和非漫游用户的业务量总和；
根据各所述用户的业务量总和， 确定业务量总和满足第二条件参数的各 用户的业务总量信息。
进一步地， 所述发送模块 501具体用于： 向至少一个子 OLAP服务器发 送携带有数据上报参数的数据请求消息， 所述数据上报参数包括如下中的任 一或其组合： 需统计的业务类型参数、 统计时间段参数、 所述第一条件参数。
进一步地， 所述第一条件参数为业务量大于第一预设阈值的条件参数， 或业务量在所有非漫游用户的业务量中排在第一预设排名之前的条件参数； 所述第二条件参数为业务量总和大于第二预设阈值的条件参数， 或业务 量总和在所有用户的业务量总和中排在第二预设排名之前的条件参数。 进一步地， 所述处理模块 503还用于：
根据所述满足第二条件参数的各用户的业务总量信息， 生成多维业务量 图表。
进一步地， 各所述子 OLAP服务器设置在不同地理区域。
本实施例的中央联机分析处理服务器可以用于执行上述联机处理数据的 方法实施例的技术方案， 其实现原理和技术效果类似， 此处不再赘述。
图 6为本发明子联机分析处理服务器实施例一的结构示意图。 如图 6所 示， 本实施例提供的子 OLAP服务器 60包括接收模块 601、 处理模块 602、 发送模块 603。
其中， 接收模块 601用于接收中央联机分析处理 OLAP服务器发送的数 据请求消息， 并获取与所述数据请求消息关联的数据上报参数；
处理模块 602用于根据所述数据上报参数， 对漫游用户和非漫游用户的 业务量进行统计， 得到用户业务数据信息， 所述用户业务数据信息包括漫游 用户的业务量信息以及满足第一条件参数的非漫游用户的业务量信息， 所述 业务量信息包括用户标识和对应的业务量；
发送模块 603用于向所述中央 OLAP服务器发送所述用户业务数据信息， 以使所述中央 OLAP服务器基于所述用户标识及所述对应的业务量进行业务 量求和， 得到所述用户标识对应的业务量总和满足第二条件参数的各用户的 业务总量信息， 所述业务总量信息包括所述用户标识和对应的所述业务量总 和。
本实施例的子联机分析处理服务器可以用于执行图 2 实施例的技术方 案， 其实现原理和技术效果类似， 此处不再赘述。
进一步地， 所述接收模块 601还用于：
接收深度包解析设备发送的至少一条用户业务量信息， 每条用户业务量 信息包括用户的用户标识、 所述用户的单次业务量、 所述用户的归属地标识 及产生所述单次业务量的地理区域标识；
所述处理模块 602具体用于：
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识不 一致， 则确定所述用户为漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述漫游用户 的业务量信息；
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识一 致， 则确定所述用户为非漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述非漫游用 户的业务量； 根据所有非漫游用户的业务量确定所述满足第一条件参数的非 漫游用户的业务量信息。
进一步地， 所述数据上报参数包括如下中的任一或其组合： 需统计的业 务类型参数、 统计时间段参数、 所述第一条件参数；
所述处理模块 602具体用于： 若所述数据上报参数包括需统计的业务类 型参数， 对漫游用户和非漫游用户对应所述需统计的业务类型参数的业务量 进行统计， 得到用户业务数据信息， 所述用户业务数据信息包括漫游用户的 业务量信息以及满足第一条件参数的非漫游用户的业务量信息， 所述业务量 信息包括用户标识和对应的业务量；
或者， 具体用于： 若所述数据上报参数包括统计时间段参数， 对漫游用 户和非漫游用户对应所述统计时间段参数的业务量进行统计， 得到用户业务 数据信息， 所述用户业务数据信息包括漫游用户的业务量信息以及满足第一 条件参数的非漫游用户的业务量信息， 所述业务量信息包括用户标识和对应 的业务量。
进一步地， 所述第一条件参数为业务量大于第一预设阈值的条件参数， 或业务量在所有非漫游用户的业务量中排在第一预设排名之前的条件参数； 所述第二条件参数为业务量总和大于第二预设阈值的条件参数， 或业务 量总和在所有用户的业务量总和中排在第二预设排名之前的条件参数。
进一步地， 所述接收模块 601具体用于接收中央联机分析处理 OLAP服 务器发送的数据请求消息， 根据预定的所述数据请求消息与数据上报参数的 映射关系， 获取与所述数据请求消息关联的数据上报参数；
或者， 具体用于： 接收中央联机分析处理 OLAP服务器发送的数据请求 消息， 如果所述数据请求消息中携带数据上报参数， 从所述数据请求消息中 提取出携带的数据上报参数。
本实施例的子联机分析处理服务器可以用于执行上述联机处理数据的方 法实施例的技术方案， 其实现原理和技术效果类似， 此处不再赘述。 图 7为本发明中央联机分析处理服务器实施例二的结构示意图。 如图 7 所示， 该中央 OLAP服务器 70包括： 至少一个处理器 701 , 例如 CPU, 至少 一个网络接口 704或者其他用户接口 703, 存储器 705, 至少一个通信总线 702。通信总线 702用于实现这些组件之间的连接通信。该中央 OLAP服务器 70可选的包含用户接口 703, 包括显示器， 键盘或者点击设备（例如， 鼠标， 轨迹球（ trackball ), 触感板或者触感显示屏）。存储器 705可能包含高速 RAM 存储器， 也可能还包括非不稳定的存储器（non-volatile memory ) , 例如至少 一个磁盘存储器。 存储器 705可选的可以包含至少一个位于远离前述处理器 701的存储装置。
在一些实施方式中， 存储器 705存储了如下的元素， 可执行模块或者数 据结构， 或者他们的子集， 或者他们的扩展集：
操作系统 7051 , 包含各种系统程序， 用于实现各种基础业务以及处理基 于硬件的任务；
应用模块 7052, 包含各种应用程序， 用于实现各种应用业务。
应用模块 7052中包括但不限于发送模块 501、 接收模块 502、 处理模块
703。
应用模块 7052中各模块的具体实现参见图 5所示实施例中的相应模块， 在此不赘述。
具体地， 处理器 701用于： 向至少一个子联机分析处理 OLAP服务器发 送数据请求消息；
接收所述至少一个子 OLAP服务器发送的用户业务数据信息， 所述用户 业务数据信息包括漫游用户的业务量信息以及满足第一条件参数的非漫游用 户的业务量信息， 所述业务量信息包括用户标识和对应的业务量；
基于所述用户标识及所述对应的业务量进行业务量求和， 得到所述用户 标识对应的业务量总和满足第二条件参数的各用户的业务总量信息， 所述业 务总量信息包括所述用户标识和对应的所述业务量总和
进一步地，所述基于所述用户标识及所述对应的业务量进行业务量求和， 得到所述用户标识对应的业务量总和满足第二条件参数的各用户的业务总量 信息， 包括：
基于所述用户标识及所述对应的业务量统计所述用户标识对应的用户作 为漫游用户和非漫游用户的业务量总和；
根据各所述用户的业务量总和， 确定业务量总和满足第二条件参数的各 用户的业务总量信息。
进一步地， 所述数据请求消息中携带数据上报参数， 所述数据上报参数 包括如下中的任一或其组合： 需统计的业务类型参数、 统计时间段参数、 所 述第一条件参数。
进一步地， 所述第一条件参数为业务量大于第一预设阈值的条件参数， 或业务量在所有非漫游用户的业务量中排在第一预设排名之前的条件参数； 所述第二条件参数为业务量总和大于第二预设阈值的条件参数， 或业务 量总和在所有用户的业务量总和中排在第二预设排名之前的条件参数。
进一步地，所述基于所述用户标识及所述对应的业务量进行业务量求和， 得到所述用户标识对应的业务量总和满足第二条件参数的各用户的业务总量 信息之后， 还包括：
根据所述满足第二条件参数的各用户的业务总量信息， 生成多维业务量 图表。
本实施例的中央联机分析处理服务器可以用于执行上述联机处理数据的 方法实施例的技术方案， 其实现原理和技术效果类似， 此处不再赘述。
图 8为本发明子联机分析处理服务器实施例二的结构示意图。 如图 8所 示， 该子 OLAP 良务器 80包括： 至少一个处理器 801 , 例如 CPU, 至少一个 网络接口 804或者其他用户接口 803 , 存储器 805 , 至少一个通信总线 802。 通信总线 802用于实现这些组件之间的连接通信。该子 OLAP服务器 80可选 的包含用户接口 803 , 包括显示器， 键盘或者点击设备（例如， 鼠标， 轨迹 球（trackball ) , 触感板或者触感显示屏） 。 存储器 805可能包含高速 RAM 存储器， 也可能还包括非不稳定的存储器（non-volatile memory ) , 例如至少 一个磁盘存储器。 存储器 805可选的可以包含至少一个位于远离前述处理器 801的存储装置。
在一些实施方式中， 存储器 805存储了如下的元素， 可执行模块或者数 据结构， 或者他们的子集， 或者他们的扩展集：
操作系统 8051 , 包含各种系统程序， 用于实现各种基础业务以及处理基 于硬件的任务； 应用模块 8052, 包含各种应用程序， 用于实现各种应用业务。
应用模块 8052中包括但不限于接收模块 601、 处理模块 602、 发送模块
603。
应用模块 8052中各模块的具体实现参见图 6所示实施例中的相应模块， 在此不赞述。
具体地， 处理器 801用于： 接收中央 OLAP发送的数据请求消息， 并获 取与所述数据请求消息关联的数据上报参数；
根据所述数据上报参数， 对漫游用户和非漫游用户的业务量进行统计， 得到用户业务数据信息， 所述用户业务数据信息包括漫游用户的业务量信息 以及满足第一条件参数的非漫游用户的业务量信息， 所述业务量信息包括用 户标识和对应的业务量；
向所述中央 OLAP服务器发送所述用户业务数据信息， 以使所述中央 OLAP服务器基于所述用户标识及所述对应的业务量进行业务量求和， 得到 所述用户标识对应的业务量总和满足第二条件参数的各用户的业务总量信 息， 所述业务总量信息包括所述用户标识和对应的所述业务量总和。
进一步地， 所述根据所述数据上报参数， 对漫游用户和非漫游用户的业 务量进行统计， 得到用户业务数据信息之前， 还包括：
接收深度包解析设备发送的至少一条用户业务量信息， 每条用户业务量 信息包括用户的用户标识、 所述用户的单次业务量、 所述用户的归属地标识 及产生所述单次业务量的地理区域标识；
所述根据所述数据上报参数， 对漫游用户和非漫游用户的业务量进行统 计， 得到用户业务数据信息， 包括：
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识不 一致， 则确定所述用户为漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述漫游用户 的业务量信息；
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识一 致， 则确定所述用户为非漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述非漫游用 户的业务量； 根据所有非漫游用户的业务量确定所述满足第一条件参数的非 漫游用户的业务量信息。
进一步地， 所述数据上报参数包括如下中的任一或其组合： 需统计的业 务类型参数、 统计时间段参数、 所述第一条件参数；
若所述数据上报参数包括需统计的业务类型参数， 则所述根据所述数据 上报参数， 对漫游用户和非漫游用户的业务量进行统计， 得到用户业务数据 信息包括： 对漫游用户和非漫游用户对应所述需统计的业务类型参数的业务 量进行统计， 得到用户业务数据信息；
若所述数据上报参数包括统计时间段参数， 则所述根据所述数据上报参 数， 对漫游用户和非漫游用户的业务量进行统计， 得到用户业务数据信息包 括： 对漫游用户和非漫游用户对应所述统计时间段参数的业务量进行统计， 得到用户业务数据信息。
进一步地， 所述第一条件参数为业务量大于第一预设阈值的条件参数， 或业务量在所有非漫游用户的业务量中排在第一预设排名之前的条件参数； 所述第二条件参数为业务量总和大于第二预设阈值的条件参数， 或业务 量总和在所有用户的业务量总和中排在第二预设排名之前的条件参数。
进一步地， 所述获取与所述数据请求消息关联的数据上报参数包括： 根据预定的所述数据请求消息与数据上报参数的映射关系， 获取与所述 数据请求消息关联的数据上报参数；
或者， 如果所述数据请求消息中携带数据上报参数， 则所述获取与所述 数据请求消息关联的数据上报参数包括：
从所述数据请求消息中提取出携带的数据上报参数。
本实施例的子联机分析处理服务器可以用于执行上述联机处理数据的方 法实施例的技术方案， 其实现原理和技术效果类似， 此处不再赘述。
图 9为本发明联机处理数据系统实施例一的结构示意图。 本实施例提供 的联机处理数据系统 90包括中央 OLAP服务器和至少一个子 OLAP服务器。
以四个子 OLAP服务器为例，本实施例提供的联机处理系统 90包括中央 OLAP服务器 901 , 第一子 OLAP服务器 902, 第二子 OLAP服务器 903, 第 三子 OLAP服务器 904, 第四子 OLAP服务器 905。
需要说明的是， 本发明实施例的系统中的 OLAP个数可扩展； OLAP级 数也是可扩展的； 而且单 OLAP负载也能均衡的扩展。 在各子 OLAP服务器中， 还可以内置或外接磁盘阵列， 该磁盘阵列用于 存储各种用户信息表。
在一种实现方式中，中央 OLAP服务器 901可为如图 5所示的中央 OLAP 服务器。 各子 OLAP服务器可为如图 6所示的子 OLAP服务器的结构。
在又一种实现方式中， 中央 OLAP服务器 901用于向至少一个子 OLAP 服务器发送数据请求消息； 接收所述至少一个子 OLAP服务器发送的用户业 务数据信息， 所述用户业务数据信息包括漫游用户的业务量信息以及满足第 一条件参数的非漫游用户的业务量信息， 所述业务量信息包括用户标识和对 应的业务量； 并基于用户标识及所述对应的业务量进行业务量求和， 得到所 述用户标识对应的业务量总和满足第二条件参数的各用户的业务总量信息， 所述业务总量信息包括用户标识和对应的业务量总和；
所述子 OLAP服务器用于： 接收中央 OLAP服务器 901发送的数据请求 消息， 并获取与所述数据请求消息对应的数据上报参数； 根据所述数据上报 参数， 对漫游用户和非漫游用户的业务量进行统计， 得到用户业务数据信息； 并向中央 OLAP服务器 901发送所述用户业务数据信息， 所述用户业务数据 信息包括漫游用户的业务量信息以及满足第一条件参数的非漫游用户的业务 量信息， 所述业务量信息包括用户标识和对应的业务量。
进一步地， 中央 OLAP服务器 901具体用于：
向至少一个子 OLAP服务器发送数据请求消息； 接收所述至少一个子 OLAP服务器发送的用户业务数据信息， 所述用户业务数据信息包括漫游用 户的业务量信息以及满足第一条件参数的非漫游用户的业务量信息， 所述业 务量信息包括用户标识和对应的业务量；
基于所述用户标识及所述对应的业务量统计所述用户标识对应的用户作 为漫游用户和非漫游用户的业务量总和；
根据各所述用户的业务量总和， 确定业务量总和满足第二条件参数的各 用户的业务总量信息，所述业务总量信息包括用户标识和对应的业务量总和。
进一步地， 所述子 OLAP服务器具体用于：
接收中央 OLAP服务器 901发送的数据请求消息；
根据预定的所述数据请求消息与数据上报参数的映射关系， 获取与所述 数据请求消息关联的数据上报参数； 或者， 如果所述数据请求消息中携带数据上报参数， 从所述数据请求消 息中提取出携带的数据上报参数；
接收深度包解析设备发送的至少一条用户业务量信息， 每条用户业务量 信息包括用户的用户标识、 所述用户的单次业务量、 所述用户的归属地标识 及产生所述单次业务量的地理区域标识；
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识不 一致， 则确定所述用户为漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述漫游用户 的业务量信息， 所述业务量信息包括用户标识和对应的业务量；
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识一 致， 则确定所述用户为非漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述非漫游用 户的业务量； 根据所有非漫游用户的业务量确定所述满足第一条件参数的非 漫游用户的业务量信息， 所述业务量信息包括用户标识和对应的业务量； 向中央 OLAP服务器 901发送所述用户业务数据信息， 以使中央 OLAP 服务器 901基于所述用户标识及所述对应的业务量进行业务量求和， 得到所 述用户标识对应的业务量总和满足第二条件参数的各用户的业务总量信息， 所述业务总量信息包括所述用户标识和对应的所述业务量总和。
进一步地， 所述子 OLAP服务器具体用于：
接收中央 OLAP服务器 901发送的数据请求消息；
根据预定的所述数据请求消息与数据上报参数的映射关系， 获取与所述 数据请求消息关联的数据上报参数；
或者， 如果所述数据请求消息中携带数据上报参数， 从所述数据请求消 息中提取出携带的数据上报参数；
所述数据上报参数包括如下中的任一或其组合：需统计的业务类型参数、 统计时间段参数、 所述第一条件参数；
若所述数据上报参数包括需统计的业务类型参数， 对漫游用户和非漫游 用户对应所述需统计的业务类型参数的业务量进行统计， 得到用户业务数据 信息， 所述用户业务数据信息包括漫游用户的业务量信息以及满足第一条件 参数的非漫游用户的业务量信息， 所述业务量信息包括用户标识和对应的业 务量； 或者，
若所述数据上报参数包括统计时间段参数， 对漫游用户和非漫游用户对 应所述统计时间段参数的业务量进行统计， 得到用户业务数据信息， 所述用 户业务数据信息包括漫游用户的业务量信息以及满足第一条件参数的非漫游 用户的业务量信息， 所述业务量信息包括用户标识和对应的业务量；
向中央 OLAP服务器 901发送所述用户业务数据信息， 以使中央 OLAP 服务器 901基于所述用户标识及所述对应的业务量进行业务量求和， 得到所 述用户标识对应的业务量总和满足第二条件参数的各用户的业务总量信息， 所述业务总量信息包括所述用户标识和对应的所述业务量总和。
在上述实现方式中， 中央 OLAP服务器 901可通过如图 7所示的结构实 现， 各子 OLAP服务器可通过如图 8所示的结构实现。
本实施例的联机处理数据系统可以用于执行上述联机处理数据的方法实 施例的技术方案， 其实现原理和技术效果类似， 此处不再赘述。
本实施例的联机处理数据系统可以用于执行上述联机处理数据的方法实 施例的技术方案， 其实现原理和技术效果类似， 此处不再赘述。
图 10为本发明联机处理数据系统的应用示意图。 在具体应用过程中， 子 OLAP服务器还可以与 DPI设备连接。 如图 10所示， 第一子 OLAP服务器
1102, 第二子 OLAP服务器 1103, 第三子 OLAP服务器 1104, 第四子 OLAP 服务器 1105分别与编号为 1001、 1002、 1003、 1004的 DPI设备连接。 当 DPI 设备获知到用户在该网关对应的地理区域内使用业务时， DPI 设备会向子 OLAP发送至少一条用户业务量信息。 以编号为 1002的 DPI设备为例， 该 DPI设备将广州地区本地用户的用户业务量信息发送给第二子 OLAP服务器
1103 , 还将漫游到广州地区的， 归属地为深圳地区的用户的用于业务量信息 发送给第二子 OLAP服务器 1103。
各子 OLAP服务器接收 DPI设备发送的至少一条用户业务量信息， 特别 地， 在各子联机 OLAP服务器中， 还可以内置或外接存储设备， 如磁盘阵列， 该磁盘阵列用于存储包括用户的业务量信息的各种用户信息表。
当各子 OLAP服务器接收中央 OLAP服务器 1101发送的数据请求消息 时，各子 OLAP服务器根据该数据请求消息，根据存储的用户的业务量信息， 得到漫游用户的业务量信息和满足第一条件参数的非漫游用户的业务量信 息。 具体的实现过程， 可参见图 3所示， 本实施例在此不再赘述。
各子 OLAP服务器向中央 OLAP服务器 1101发送用户业务数据信息， 包括漫游用户的业务量信息以及满足第一条件参数的非漫游用户的业务量信 中央 OLAP服务器 1101基于用户标识及所述对应的业务量进行业务量求 和， 得到所述用户标识对应的业务量总和满足第二条件参数的各用户的业务 总量信息， 所述业务总量信息包括用户标识和业务量总和。
本实施例提供的联机处理数据系统， 通过中央 OLAP服务器向至少一个 子 OLAP服务器发送数据请求消息，中央 OLAP服务器接收至少一个子 OLAP 服务器发送的用户业务数据信息， 用户业务数据信息包括漫游用户的业务量 信息以及满足第一条件参数的非漫游用户的业务量信息， 即子 OLAP服务器 对非漫游用户进行筛选， 中央 OLAP服务器仅接收部分非漫游用户的业务量 信息； 中央 OLAP服务器按用户进行业务量求和， 得到业务量总和满足第二 条件参数的各用户的业务总量信息， 中央 OLAP服务器只需对经过子 OLAP 服务器上报的漫游用户的业务量以及满足第一条件参数的非漫游用户的业务 量进行求和处理， 即子 OLAP服务器先进行初步统计， 中央 OLAP服务器再 基于子 OLAP服务器初步统计的结果进一步统计， 中央 OLAP服务器的数据 处理量减少， 数据处理效率提高。
本领域普通技术人员可以理解： 实现上述各方法实施例的全部或部分步 骤可以通过程序指令相关的硬件来完成。 前述的程序可以存储于一计算机可 读取存储介质中。 该程序在执行时， 执行包括上述各方法实施例的步骤； 而 前述的存储介质包括： ROM, RAM, 磁碟或者光盘等各种可以存储程序代码 的介质。
最后应说明的是： 以上各实施例仅用以说明本发明的技术方案， 而非对 其限制； 尽管参照前述各实施例对本发明进行了详细的说明， 本领域的普通 技术人员应当理解：其依然可以对前述各实施例所记载的技术方案进行修改， 或者对其中部分或者全部技术特征进行等同替换； 而这些修改或者替换， 并 不使相应技术方案的本质脱离本发明各实施例技术方案的范围。

Claims

权 利 要 求 书
1、 一种联机处理数据的方法， 其特征在于， 包括：
向至少一个子联机分析处理 OLAP服务器发送数据请求消息； 接收所述至少一个子 OLAP服务器发送的用户业务数据信息， 所述用户 业务数据信息包括漫游用户的业务量信息以及满足第一条件参数的非漫游用 户的业务量信息， 所述业务量信息包括用户标识和对应的业务量；
基于所述用户标识及所述对应的业务量进行业务量求和， 得到所述用户 标识对应的业务量总和满足第二条件参数的各用户的业务总量信息， 所述业 务总量信息包括所述用户标识和对应的所述业务量总和。
2、 根据权利要求 1所述的方法， 其特征在于， 所述基于所述用户标识及 所述对应的业务量进行业务量求和， 得到所述用户标识对应的业务量总和满 足第二条件参数的各用户的业务总量信息， 包括：
基于所述用户标识及所述对应的业务量统计所述用户标识对应的用户作 为漫游用户和非漫游用户的业务量总和；
根据各所述用户的业务量总和， 确定业务量总和满足第二条件参数的各 用户的业务总量信息。
3、 根据权利要求 2所述的方法， 其特征在于， 所述数据请求消息中携带 数据上报参数， 所述数据上报参数包括如下中的任一或其组合： 需统计的业 务类型参数、 统计时间段参数、 所述第一条件参数。
4、 根据权利要求 1至 3中任一项所述的方法， 其特征在于， 所述第一条 件参数为业务量大于第一预设阈值的条件参数， 或业务量在所有非漫游用户 的业务量中排在第一预设排名之前的条件参数；
所述第二条件参数为业务量总和大于第二预设阈值的条件参数， 或业务 量总和在所有用户的业务量总和中排在第二预设排名之前的条件参数。
5、 根据权利要求 1至 4中任一项所述的方法， 其特征在于， 所述基于所 述用户标识及所述对应的业务量进行业务量求和， 得到所述用户标识对应的 业务量总和满足第二条件参数的各用户的业务总量信息之后， 还包括：
根据所述满足第二条件参数的各用户的业务总量信息， 生成多维业务量 图表。
6、 根据权利要求 1至 5中任一项所述的方法， 其特征在于， 各所述子联 机分析处理 OLAP服务器设置在不同地理区域。
7、 一种联机处理数据的方法， 其特征在于， 包括：
接收中央联机分析处理 OLAP服务器发送的数据请求消息， 并获取与所 述数据请求消息关联的数据上报参数；
根据所述数据上报参数， 对漫游用户和非漫游用户的业务量进行统计， 得到用户业务数据信息， 所述用户业务数据信息包括漫游用户的业务量信息 以及满足第一条件参数的非漫游用户的业务量信息， 所述业务量信息包括用 户标识和对应的业务量；
向所述中央 OLAP服务器发送所述用户业务数据信息， 以使所述中央 OLAP服务器基于所述用户标识及所述对应的业务量进行业务量求和， 得到 所述用户标识对应的业务量总和满足第二条件参数的各用户的业务总量信 息， 所述业务总量信息包括所述用户标识和对应的所述业务量总和。
8、 根据权利要求 7所述的方法， 其特征在于， 所述根据所述数据上报参 数， 对漫游用户和非漫游用户的业务量进行统计， 得到用户业务数据信息之 前， 还包括：
接收深度包解析设备发送的至少一条用户业务量信息， 每条用户业务量 信息包括用户的用户标识、 所述用户的单次业务量、 所述用户的归属地标识 及产生所述单次业务量的地理区域标识；
所述根据所述数据上报参数， 对漫游用户和非漫游用户的业务量进行统 计， 得到用户业务数据信息， 包括：
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识不 一致， 则确定所述用户为漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述漫游用户 的业务量信息；
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识一 致， 则确定所述用户为非漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述非漫游用 户的业务量； 根据所有非漫游用户的业务量确定所述满足第一条件参数的非 漫游用户的业务量信息。
9、 根据权利要求 7所述的方法， 其特征在于， 所述数据上报参数包括如 下中的任一或其组合： 需统计的业务类型参数、 统计时间段参数、 所述第一 条件参数；
若所述数据上报参数包括需统计的业务类型参数， 则所述根据所述数据 上报参数， 对漫游用户和非漫游用户的业务量进行统计， 得到用户业务数据 信息包括： 对漫游用户和非漫游用户对应所述需统计的业务类型参数的业务 量进行统计， 得到用户业务数据信息；
若所述数据上报参数包括统计时间段参数， 则所述根据所述数据上报参 数， 对漫游用户和非漫游用户的业务量进行统计， 得到用户业务数据信息包 括： 对漫游用户和非漫游用户对应所述统计时间段参数的业务量进行统计， 得到用户业务数据信息。
10、 根据权利要求 7至 9中任一项所述的方法， 其特征在于， 所述第一 条件参数为业务量大于第一预设阈值的条件参数， 或业务量在所有非漫游用 户的业务量中排在第一预设排名之前的条件参数；
所述第二条件参数为业务量总和大于第二预设阈值的条件参数， 或业务 量总和在所有用户的业务量总和中排在第二预设排名之前的条件参数。
11、 根据权利要求 7至 10中任一项所述的方法， 其特征在于， 所述获取 与所述数据请求消息关联的数据上报参数包括：
根据预定的所述数据请求消息与数据上报参数的映射关系， 获取与所述 数据请求消息关联的数据上报参数；
或者， 如果所述数据请求消息中携带数据上报参数， 则所述获取与所述 数据请求消息关联的数据上报参数包括：
从所述数据请求消息中提取出携带的数据上报参数。
12、 一种中央联机分析处理 OLAP服务器， 其特征在于， 包括： 发送模块， 用于向至少一个子联机分析处理 OLAP服务器发送数据请求 消息；
接收模块， 用于接收所述至少一个子 OLAP服务器发送的用户业务数据 信息， 所述用户业务数据信息包括漫游用户的业务量信息以及满足第一条件 参数的非漫游用户的业务量信息， 所述业务量信息包括用户标识和对应的业 务量；
处理模块，用于基于所述用户标识及所述对应的业务量进行业务量求和， 得到所述用户标识对应的业务量总和满足第二条件参数的各用户的业务总量 信息， 所述业务总量信息包括所述用户标识和对应的所述业务量总和。
13、 根据权利要求 12所述的中央 OLAP服务器， 其特征在于， 所述处理 模块具体用于，
基于所述用户标识及所述对应的业务量统计所述用户标识对应的用户作 为漫游用户和非漫游用户的业务量总和；
根据各所述用户的业务量总和， 确定业务量总和满足第二条件参数的各 用户的业务总量信息。
14、 根据权利要求 13所述的中央 OLAP服务器， 其特征在于， 所述发送 模块具体用于： 向至少一个子 OLAP服务器发送携带有数据上报参数的数据 请求消息， 所述数据上报参数包括如下中的任一或其组合： 需统计的业务类 型参数、 统计时间段参数、 所述第一条件参数。
15、 根据权利要求 12至 14中任一项所述的中央 OLAP服务器， 其特征 在于， 所述处理模块还用于： 根据所述满足第二条件参数的各用户的业务总 量信息， 生成多维业务量图表。
16、 一种子联机分析处理 OLAP服务器， 其特征在于， 包括：
接收模块， 用于接收中央联机分析处理 OLAP服务器发送的数据请求消 息， 并获取与所述数据请求消息关联的数据上报参数；
处理模块， 用于根据所述数据上报参数， 对漫游用户和非漫游用户的业 务量进行统计， 得到用户业务数据信息， 所述用户业务数据信息包括漫游用 户的业务量信息以及满足第一条件参数的非漫游用户的业务量信息， 所述业 务量信息包括用户标识和对应的业务量；
发送模块， 用于向所述中央 OLAP服务器发送所述用户业务数据信息， 以使所述中央 OLAP服务器基于所述用户标识及所述对应的业务量进行业务 量求和， 得到所述用户标识对应的业务量总和满足第二条件参数的各用户的 业务总量信息， 所述业务总量信息包括所述用户标识和对应的所述业务量总 和。
17、 根据权利要求 16所述的子 OLAP服务器， 其特征在于， 所述接收模 块还用于：
接收深度包解析设备发送的至少一条用户业务量信息， 每条用户业务量 信息包括用户的用户标识、 所述用户的单次业务量、 所述用户的归属地标识 及产生所述单次业务量的地理区域标识；
所述处理模块具体用于：
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识不 一致， 则确定所述用户为漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述漫游用户 的业务量信息；
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识一 致， 则确定所述用户为非漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述非漫游用 户的业务量； 根据所有非漫游用户的业务量确定所述满足第一条件参数的非 漫游用户的业务量信息。
18、 根据权利要求 16所述的子 OLAP服务器， 其特征在于， 所述数据上 报参数包括如下中的任一或其组合： 需统计的业务类型参数、 统计时间段参 数、 所述第一条件参数；
所述处理模块具体用于： 若所述数据上报参数包括需统计的业务类型参 数， 对漫游用户和非漫游用户对应所述需统计的业务类型参数的业务量进行 统计， 得到用户业务数据信息， 所述用户业务数据信息包括漫游用户的业务 量信息以及满足第一条件参数的非漫游用户的业务量信息， 所述业务量信息 包括用户标识和对应的业务量；
或者， 具体用于： 若所述数据上报参数包括统计时间段参数， 对漫游用 户和非漫游用户对应统计时间段参数的业务量进行统计， 得到用户业务数据 信息， 所述用户业务数据信息包括漫游用户的业务量信息以及满足第一条件 参数的非漫游用户的业务量信息， 所述业务量信息包括用户标识和对应的业 务量。
19、 根据权利要求 16至 18中任一项所述的子 OLAP服务器， 其特征在 于， 所述接收模块具体用于接收中央联机分析处理 OLAP服务器发送的数据 请求消息， 根据预定的所述数据请求消息与数据上报参数的映射关系， 获取 与所述数据请求消息关联的数据上报参数；
或者， 所述接收模块具体用于： 接收中央联机分析处理 OLAP服务器发 送的数据请求消息， 如果所述数据请求消息中携带数据上报参数， 从所述数 据请求消息中提取出携带的数据上报参数。
20、一种联机处理数据系统，其特征在于， 包括中央联机分析处理 OLAP 服务器和至少一个子联机分析处理 OLAP服务器， 其中：
所述中央 OLAP服务器用于： 向至少一个子 OLAP服务器发送数据请求 消息； 接收所述至少一个子 OLAP服务器发送的用户业务数据信息， 所述用 户业务数据信息包括漫游用户的业务量信息以及满足第一条件参数的非漫游 用户的业务量信息， 所述业务量信息包括用户标识和对应的业务量； 并基于 用户标识及所述对应的业务量进行业务量求和， 得到所述用户标识对应的业 务量总和满足第二条件参数的各用户的业务总量信息， 所述业务总量信息包 括用户标识和对应的业务量总和；
所述子 OLAP服务器用于： 接收所述中央 OLAP服务器发送的数据请求 消息， 并获取与所述数据请求消息对应的数据上报参数； 根据所述数据上报 参数， 对漫游用户和非漫游用户的业务量进行统计， 得到用户业务数据信息； 并向所述中央 OLAP服务器发送所述用户业务数据信息， 所述用户业务数据 信息包括漫游用户的业务量信息以及满足第一条件参数的非漫游用户的业务 量信息， 所述业务量信息包括用户标识和对应的业务量。
21、 根据权利要求 20所述的联机处理数据系统， 其特征在于， 所述中央 OLAP服务器具体用于：
向至少一个子 OLAP服务器发送数据请求消息； 接收所述至少一个子
OLAP服务器发送的用户业务数据信息， 所述用户业务数据信息包括漫游用 户的业务量信息以及满足第一条件参数的非漫游用户的业务量信息， 所述业 务量信息包括用户标识和对应的业务量；
基于所述用户标识及所述对应的业务量统计所述用户标识对应的用户作 为漫游用户和非漫游用户的业务量总和；
根据各所述用户的业务量总和， 确定业务量总和满足第二条件参数的各 用户的业务总量信息，所述业务总量信息包括用户标识和对应的业务量总和。
22、 根据权利要求 20或 21所述的联机处理数据系统， 其特征在于， 所 述子 OLAP服务器具体用于：
接收所述中央 OLAP服务器发送的数据请求消息； 根据预定的所述数据请求消息与数据上报参数的映射关系， 获取与所述 数据请求消息关联的数据上报参数；
或者， 如果所述数据请求消息中携带数据上报参数， 从所述数据请求消 息中提取出携带的数据上报参数；
接收深度包解析设备发送的至少一条用户业务量信息， 每条用户业务量 信息包括用户的用户标识、 所述用户的单次业务量、 所述用户的归属地标识 及产生所述单次业务量的地理区域标识；
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识不 一致， 则确定所述用户为漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述漫游用户 的业务量信息， 所述业务量信息包括用户标识和对应的业务量；
若所述用户的归属地标识与所述产生所述单次业务量的地理区域标识一 致， 则确定所述用户为非漫游用户， 并根据所述数据上报参数对包含所述用 户标识的所有用户业务量信息中的单次业务量进行统计， 得到所述非漫游用 户的业务量； 根据所有非漫游用户的业务量确定所述满足第一条件参数的非 漫游用户的业务量信息， 所述业务量信息包括用户标识和对应的业务量； 向所述中央 OLAP服务器发送所述用户业务数据信息， 以使所述中央 OLAP服务器基于所述用户标识及所述对应的业务量进行业务量求和， 得到 所述用户标识对应的业务量总和满足第二条件参数的各用户的业务总量信 息， 所述业务总量信息包括所述用户标识和对应的所述业务量总和。
23、 根据权利要求 20或 21所述的联机处理数据系统， 其特征在于， 所 述子 OLAP服务器具体用于：
接收所述中央 OLAP服务器发送的数据请求消息；
根据预定的所述数据请求消息与数据上报参数的映射关系， 获取与所述 数据请求消息关联的数据上报参数；
或者， 如果所述数据请求消息中携带数据上报参数， 从所述数据请求消 息中提取出携带的数据上报参数；
所述数据上报参数包括如下中的任一或其组合：需统计的业务类型参数、 统计时间段参数、 所述第一条件参数；
若所述数据上报参数包括需统计的业务类型参数， 对漫游用户和非漫游 用户对应所述需统计的业务类型参数的业务量进行统计， 得到用户业务数据 信息， 所述用户业务数据信息包括漫游用户的业务量信息以及满足第一条件 参数的非漫游用户的业务量信息， 所述业务量信息包括用户标识和对应的业 务量； 或者，
若所述数据上报参数包括统计时间段参数， 对漫游用户和非漫游用户对 应所述统计时间段参数的业务量进行统计， 得到用户业务数据信息， 所述用 户业务数据信息包括漫游用户的业务量信息以及满足第一条件参数的非漫游 用户的业务量信息， 所述业务量信息包括用户标识和对应的业务量；
向所述中央 OLAP服务器发送所述用户业务数据信息， 以使所述中央 OLAP服务器基于所述用户标识及所述对应的业务量进行业务量求和， 得到 所述用户标识对应的业务量总和满足第二条件参数的各用户的业务总量信 息， 所述业务总量信息包括所述用户标识和对应的所述业务量总和。
PCT/CN2013/084374 2013-04-01 2013-09-27 联机处理数据的方法、设备及系统 Ceased WO2014161281A1 (zh)

Priority Applications (5)

Application Number Priority Date Filing Date Title
JP2015524630A JP6100900B2 (ja) 2013-04-01 2013-09-27 データのオンライン処理のための方法、デバイスおよびシステム
KR1020157001746A KR20150023857A (ko) 2013-04-01 2013-09-27 데이터의 온라인 처리를 위한 방법, 장치 및 시스템
RU2015105984A RU2612570C2 (ru) 2013-04-01 2013-09-27 Способ, устройство и система обработки данных в режиме реального времени
EP13881196.3A EP2857992A4 (en) 2013-04-01 2013-09-27 METHOD, DEVICE AND SYSTEM FOR PROCESSING ONLINE DATA
US14/868,000 US20160020982A1 (en) 2013-04-01 2015-09-28 Method, device and system for online processing of data

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
CN201310111060.6 2013-04-01
CN2013101110606A CN103235793A (zh) 2013-04-01 2013-04-01 联机处理数据的方法、设备及系统

Related Child Applications (1)

Application Number Title Priority Date Filing Date
US14/868,000 Continuation US20160020982A1 (en) 2013-04-01 2015-09-28 Method, device and system for online processing of data

Publications (1)

Publication Number Publication Date
WO2014161281A1 true WO2014161281A1 (zh) 2014-10-09

Family

ID=48883835

Family Applications (1)

Application Number Title Priority Date Filing Date
PCT/CN2013/084374 Ceased WO2014161281A1 (zh) 2013-04-01 2013-09-27 联机处理数据的方法、设备及系统

Country Status (7)

Country Link
US (1) US20160020982A1 (zh)
EP (1) EP2857992A4 (zh)
JP (1) JP6100900B2 (zh)
KR (1) KR20150023857A (zh)
CN (1) CN103235793A (zh)
RU (1) RU2612570C2 (zh)
WO (1) WO2014161281A1 (zh)

Families Citing this family (8)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN103235793A (zh) * 2013-04-01 2013-08-07 华为技术有限公司 联机处理数据的方法、设备及系统
CN104572740B (zh) * 2013-10-23 2019-09-13 华为技术有限公司 一种存储数据的方法和装置
CN103995879B (zh) * 2014-05-27 2017-12-15 华为技术有限公司 基于olap系统的数据查询方法、装置及系统
CN105138691B (zh) * 2015-09-18 2018-10-02 北京百度网讯科技有限公司 分析用户业务量的方法和系统
CN105553690A (zh) * 2015-12-07 2016-05-04 北京奇虎科技有限公司 业务访问信息的统计方法、装置及系统
CN105677698B (zh) * 2015-12-11 2019-03-05 重庆川仪自动化股份有限公司 一种报表数据导出方法
CN113285816B (zh) 2020-02-19 2022-10-28 华为技术有限公司 一种基于键值配置的控制请求发送方法、装置和系统
CN112579287B (zh) * 2020-12-16 2024-07-30 跬云(上海)信息科技有限公司 一种基于读写分离及自动伸缩的云编排系统及方法

Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN1688998A (zh) * 2002-10-18 2005-10-26 国际商业机器公司 用于联机分析处理的方法和系统
US20070022120A1 (en) * 2005-07-25 2007-01-25 Microsoft Corporation Caching and modifying portions of a multi-dimensional database on a user device
CN102938097A (zh) * 2012-09-28 2013-02-20 用友软件股份有限公司 用于联机分析处理系统的数据处理装置和数据处理方法
CN103235793A (zh) * 2013-04-01 2013-08-07 华为技术有限公司 联机处理数据的方法、设备及系统

Family Cites Families (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US6385604B1 (en) * 1999-08-04 2002-05-07 Hyperroll, Israel Limited Relational database management system having integrated non-relational multi-dimensional data store of aggregated data elements
US7007020B1 (en) * 2000-03-10 2006-02-28 Hewlett-Packard Development Company, L.P. Distributed OLAP-based association rule generation method and system
JP2002108899A (ja) * 2000-09-27 2002-04-12 Hitachi Kokusai Electric Inc データベースアクセス方法及び多次元データベースアクセスシステム
US7506046B2 (en) * 2001-07-31 2009-03-17 Hewlett-Packard Development Company, L.P. Network usage analysis system and method for updating statistical models
US7627555B2 (en) * 2004-06-22 2009-12-01 Microsoft Corporation Combining multidimensional expressions and data mining extensions to mine OLAP cubes
CN1588358A (zh) * 2004-08-26 2005-03-02 陈红 对mdx多维数据查询语句的处理方法和系统

Patent Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN1688998A (zh) * 2002-10-18 2005-10-26 国际商业机器公司 用于联机分析处理的方法和系统
US20070022120A1 (en) * 2005-07-25 2007-01-25 Microsoft Corporation Caching and modifying portions of a multi-dimensional database on a user device
CN102938097A (zh) * 2012-09-28 2013-02-20 用友软件股份有限公司 用于联机分析处理系统的数据处理装置和数据处理方法
CN103235793A (zh) * 2013-04-01 2013-08-07 华为技术有限公司 联机处理数据的方法、设备及系统

Non-Patent Citations (1)

* Cited by examiner, † Cited by third party
Title
See also references of EP2857992A4 *

Also Published As

Publication number Publication date
US20160020982A1 (en) 2016-01-21
EP2857992A1 (en) 2015-04-08
RU2612570C2 (ru) 2017-03-09
KR20150023857A (ko) 2015-03-05
JP2015527657A (ja) 2015-09-17
RU2015105984A (ru) 2016-09-10
JP6100900B2 (ja) 2017-03-22
EP2857992A4 (en) 2015-07-15
CN103235793A (zh) 2013-08-07

Similar Documents

Publication Publication Date Title
WO2014161281A1 (zh) 联机处理数据的方法、设备及系统
CN107547633B (zh) 一种用户常驻点的处理方法、装置和存储介质
CN111263409B (zh) 提供网络功能服务的元数据信息的方法、系统以及相关设备
CN103605791B (zh) 信息推送系统和信息推送方法
CN102577494B (zh) 支持通信网络中的社交网络分析的方法和装置
CN104598557B (zh) 数据栅格化、用户行为分析的方法和装置
CN104424229A (zh) 一种多维度拆分的计算方法及系统
CN103902636B (zh) 基于过滤聚类法推送信息的方法和服务器
WO2017067505A1 (zh) 网络扩容方法及装置
WO2012106861A1 (zh) 终端分布信息获取方法、数据获取装置以及通信系统
WO2019137195A1 (zh) 一种获取业务数据的方法及装置
CN101951623B (zh) 一种基于用户事件的用户行为统计方法及装置
CN105049298A (zh) 一种云资源监控方法和系统
CN105550248A (zh) 用户信息挖掘方法及装置
CN110727752B (zh) 位置指纹库处理方法、设备及计算机可读存储介质
CN104486769B (zh) 一种价值小区的选取方法及装置
WO2023045434A1 (zh) 访问检测方法、系统及装置
CN102905236A (zh) 一种垃圾短消息监控方法、装置及系统
CN106027692B (zh) 信息获取方法、装置及服务器
CN116723339B (zh) 内容数据的分发方法和装置、存储介质及电子设备
JP7823624B2 (ja) ネットワークノード、情報処理システム、情報処理方法、およびコンピュータプログラム
CN107481154A (zh) 社交网络人际关系的分析方法及装置
CN116016651B (zh) 一种经纬度校正方法、装置、电子设备及存储介质
CN111510940A (zh) 信令分析方法及设备
CN117768183A (zh) 一种识别移动网络资产的方法、装置、设备及存储介质

Legal Events

Date Code Title Description
121 Ep: the epo has been informed by wipo that ep was designated in this application

Ref document number: 13881196

Country of ref document: EP

Kind code of ref document: A1

REEP Request for entry into the european phase

Ref document number: 2013881196

Country of ref document: EP

WWE Wipo information: entry into national phase

Ref document number: 2013881196

Country of ref document: EP

ENP Entry into the national phase

Ref document number: 20157001746

Country of ref document: KR

Kind code of ref document: A

ENP Entry into the national phase

Ref document number: 2015524630

Country of ref document: JP

Kind code of ref document: A

ENP Entry into the national phase

Ref document number: 2015105984

Country of ref document: RU

Kind code of ref document: A

NENP Non-entry into the national phase

Ref country code: DE