[go: up one dir, main page]

CN104040539A - Data storage method and apparatus, data operation method and system, and access server - Google Patents

Data storage method and apparatus, data operation method and system, and access server Download PDF

Info

Publication number
CN104040539A
CN104040539A CN201280002589.8A CN201280002589A CN104040539A CN 104040539 A CN104040539 A CN 104040539A CN 201280002589 A CN201280002589 A CN 201280002589A CN 104040539 A CN104040539 A CN 104040539A
Authority
CN
China
Prior art keywords
fragment
identifier
data
data source
user
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.)
Granted
Application number
CN201280002589.8A
Other languages
Chinese (zh)
Other versions
CN104040539B (en
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
Publication of CN104040539A publication Critical patent/CN104040539A/en
Application granted granted Critical
Publication of CN104040539B publication Critical patent/CN104040539B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Classifications

    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/25Integrating or interfacing systems involving database management systems
    • G06F16/256Integrating or interfacing systems involving database management systems in federated or virtual databases
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/90Details of database functions independent of the retrieved data types
    • G06F16/903Querying
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/50Network services
    • H04L67/56Provisioning of proxy services
    • H04L67/563Data redirection of data network streams
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04WWIRELESS COMMUNICATION NETWORKS
    • H04W8/00Network data management
    • H04W8/18Processing of user or subscriber data, e.g. subscribed services, user preferences or user profiles; Transfer of user or subscriber data
    • H04W8/186Processing of subscriber group data

Landscapes

  • Engineering & Computer Science (AREA)
  • Databases & Information Systems (AREA)
  • Theoretical Computer Science (AREA)
  • Data Mining & Analysis (AREA)
  • Physics & Mathematics (AREA)
  • General Engineering & Computer Science (AREA)
  • General Physics & Mathematics (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Computational Linguistics (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)
  • Information Retrieval, Db Structures And Fs Structures Therefor (AREA)

Abstract

数据存储方法和装置,以及数据操作方法、系统及接入服务器,该方法包括:客户订阅了一个业务时,客户成为了业务的用户时,方法包括:确定客户已经开户,获得客户的客户标识中包含的第一分片标识,其中,第一分片标识为客户所属客户分片的分片标识,根据第一分片标识,为用户生成包含第一分片标识的用户标识,用户标识在用户生命周期内唯一标识用户,用户生命周期指的是从用户开户后到用户销户前的期间内;根据第一分片标识,从分片数据源对应关系表,获得第一分片标识对应的数据源标识;并将用户的数据存储在数据源标识对应的数据源中,以便于接入服务器根据用户标识中包含的第一分片标识,从第一分片标识对应的数据源中获取用户的数据。

A data storage method and device, as well as a data operation method, system, and access server. The method includes: when a customer subscribes to a service, and the customer becomes a user of the service, the method includes: determining that the customer has opened an account, and obtaining the customer ID of the customer The ID of the first fragment included, wherein, the ID of the first fragment is the ID of the client segment to which the customer belongs, and according to the ID of the first fragment, a user ID containing the ID of the first fragment is generated for the user, and the user ID is in the user The user is uniquely identified in the life cycle, and the user life cycle refers to the period from the time the user opens an account to the time before the user cancels the account; according to the first shard ID, from the data source correspondence table of the shard, obtain the data corresponding to the first shard ID Data source identifier; and store the user's data in the data source corresponding to the data source identifier, so that the access server can obtain the user from the data source corresponding to the first fragment identifier according to the first fragment identifier contained in the user identifier The data.

Description

Data storage method and apparatus, data operation method and system, and access server
Date storage method and device, data manipulation method, system and access server
The present invention relates to communication technical field, more particularly to date storage method and device, and data manipulation method, system and access server for technical field.Background technology at present, same group customer either domestic customers there may be multiple users or, same individual client may have multiple users, such as:Broadband user, fixed telephone user, cellphone subscriber.And when storing these user data, may be by the storage of these user data into different data sources, under some scenes, when business needs to access the data of multiple users of same group customer or domestic customers, need to conduct interviews across data source, and across data source access can bring very big message related to resources, and the efficiency accessed reduction.The content of the invention
The embodiment of the present invention provides date storage method and device, and data manipulation method, system and access server, to solve the data storage of multiple users of same client in the prior art in different data sources, when carrying out acquisition data, it is necessary to the problem of being accessed across data source.
In order to solve the above-mentioned technical problem, the embodiment of the invention discloses following technical scheme:
In a first aspect, a kind of date storage method, when client have subscribed a business, when client becomes the user of business, this method includes:Data generating device determines that client has opened an account, the first segmental identification included in the customer ID for obtaining client, wherein, first segmental identification is the segmental identification of the affiliated client's burst of client, customer ID unique mark client in customer life cycle, customer life cycle refer to from client open an account after in a period of before client's cancellation;Data generating device is that user of user's generation comprising the first segmental identification identifies according to the first segmental identification, user's mark unique mark user in subscriber lifecycle, subscriber lifecycle refer to from user open an account after in a period of before user's cancellation;Data generating device is according to the first segmental identification, from fragment data source mapping table, obtains the corresponding data source identification of the first segmental identification;And by the data storage of user in the corresponding data source of data source identification, the first segmental identification included in being identified in order to access server according to user, the data of user are obtained from the corresponding data source of the first segmental identification, wherein, the corresponding relation of segmental identification of the fragment data source mapping table comprising client's burst and data source identification.
In the first possible implementation of first aspect, in addition to:Data generating device is according to the resource of user Number, from number segment routing table, searches corresponding second segmental identification of the affiliated number section scope of resource number, wherein, number segment routing table contains the corresponding relation of segmental identification and the affiliated number section scope of resource number;It is determined that searching less than the second segmental identification, or when the second segmental identification found and inconsistent the first segmental identification, the corresponding relation of resource number and the first segmental identification is added in the dispersive number routing table in database by data generating device, wherein, corresponding relation of the dispersive number routing table comprising segmental identification and the resource number for not belonging to number segment routing table.
With reference to the first possible implementation of first aspect or first aspect, in second of possible implementation of first aspect, before client's subscribing service, method also includes:When client is opened an account, client's tenant identification is obtained;Data generating device is according to tenant identification, from the mapping table of fragment data source, obtain a segmental identification in the corresponding segmental identification of tenant identification, it regard get segmental identification as the first segmental identification, wherein, corresponding relation of the fragment data source mapping table also comprising tenant identification and segmental identification;Data generating device is according to the first segmental identification, the customer ID for including the first segmental identification is generated for client, and by the data storage of client in the corresponding data source of the first segmental identification, in order to which access server is according to the first segmental identification included in customer ID, the data of client are obtained from the corresponding data source of the first segmental identification.
With reference to the implementation of first aspect, in the third possible implementation of first aspect, in addition to:When data generating device determines that client does not open an account, according to the resource number of user, from number segment routing table, corresponding second segmental identification of the affiliated number section scope of resource number is searched, wherein, number segment routing table contains the corresponding relation of segmental identification and the affiliated number section scope of resource number;Data generating device is when finding the second segmental identification, according to the second segmental identification, the customer ID for including two segmental identifications is generated for client, and according to the second segmental identification, the user comprising the second segmental identification is generated for user to identify, and by the data of client and the data storage of user in the corresponding data source of the second segmental identification, in order to which access server is according to the second segmental identification included in customer ID and/or user's mark, the data of client and/or the data of user are obtained from the corresponding data source of the second segmental identification.
With reference to the third possible implementation of first aspect, in the 4th kind of possible implementation of first aspect, in addition to:When not finding the second segmental identification, the tenant identification of client's tenant is obtained;Data generating device is according to tenant identification, from the mapping table of fragment data source, obtain a segmental identification in the corresponding segmental identification of tenant identification, it regard get segmental identification as the first segmental identification, wherein, corresponding relation of the fragment data source mapping table also comprising tenant identification and segmental identification;Data generating device, according to the first segmental identification, is the customer ID that client's generation includes the first segmental identification, and is that user of user's generation comprising the first segmental identification identifies according to the first segmental identification;The corresponding relation of resource number and the first segmental identification is added in dispersive number routing table, wherein, corresponding relation of the dispersive number routing table comprising segmental identification and the resource number for not belonging to number segment routing table, and by the data of client and the data storage of user in the corresponding data source of the first segmental identification, in order to which access server is according to the first segmental identification included in customer ID and/or user's mark, from the corresponding data source of the first segmental identification The data of the middle data and/or user for obtaining client.
With reference to the first possible, second of possible, the third possible or the 4th kind of possible implementation of first aspect, first aspect, in the 5th kind of possible implementation of first aspect, method also includes:Data generating device is according to the first data source identification, from the mapping table of fragment data source, obtains the corresponding all segmental identifications of the first data source identification;Required according to resettlement, selection meets more than one segmental identification that resettlement is required from the first data source identification corresponding all segmental identifications, and the state of more than one segmental identification in the mapping table of fragment data source is set as relocation state, in order to forbid the network element in addition to data generating device to access the corresponding data of more than one segmental identification;Data generating device moves the data in corresponding first data source of more than one segmental identification into the second data source;Data generating device deletes the corresponding relation of the first data source identification and more than one segmental identification in the mapping table of fragment data source;Data generating device is in the mapping table of fragment data source, add the corresponding relation of the second data source identification and more than one segmental identification, and the state of more than one segmental identification is set as non-relocation state, in order to allow to access the corresponding data of more than one segmental identification.
Second aspect, a kind of data manipulation method, including:Access server receives the data operation request that data operation request device is sent, and data operation request includes access code;Access server obtains the segmental identification of the corresponding client's burst of access code according to access code;Access server is according to the corresponding segmental identification of access code, from the mapping table of fragment data source, obtains data source identification corresponding with segmental identification, wherein, fragment data source mapping table preserves segmental identification and data source identification;Data operation request is sent in the corresponding data source of the data source identification of acquisition by access server;Access server receives the data manipulation response that data source is sent.
In the first possible implementation of second aspect, according to access code, the corresponding segmental identification of access code is obtained, is specifically included:When access code is customer ID or user's mark, the segmental identification that customer ID or user's mark are included is obtained;When access code is resource number, according to the resource number of user, in dispersive number routing table, the corresponding segmental identification of resource number is searched, when finding the corresponding segmental identification of resource number, segmental identification is obtained;When not finding the corresponding segmental identification of resource number, according to the resource number of user, in number segment routing table, obtain the corresponding segmental identification of the affiliated number section of resource number, wherein, corresponding relation of the dispersive number routing table comprising segmental identification and the resource number for not belonging to number segment routing table, corresponding relation of the number segment routing table comprising segmental identification with the number section scope belonging to resource number.
The third aspect, a kind of data generating device, device includes acquisition module, generation module and memory module, wherein, acquisition module, for when client have subscribed a business, when client becomes the user of business, determine that client has opened an account, the first segmental identification included in the customer ID for obtaining client, wherein, first segmental identification is the segmental identification of the affiliated client's burst of client, customer ID unique mark client in customer life cycle, customer life cycle refer to from client open an account after in a period of before client's cancellation;Acquisition module, is further used for including to generation module transmission User's mark generation request of first segmental identification;Generation module, user's mark generation request comprising the first segmental identification is sent for receiving acquisition module, and according to the first segmental identification, the user comprising the first segmental identification is generated for user to identify, user's mark unique mark user in subscriber lifecycle, subscriber lifecycle refer to from user open an account after in a period of before user's cancellation;Acquisition module, is further used for according to the first segmental identification, from fragment data source mapping table, obtains the corresponding data source identification of the first segmental identification, and data source identification is sent into memory module;Memory module, data source identification for receiving acquisition module transmission, and by the data storage of user in the corresponding data source of data source identification, the first segmental identification included in being identified in order to access server according to user, the data of user are obtained from the corresponding data source of the first segmental identification, wherein, the corresponding relation of segmental identification of the fragment data source mapping table comprising client's burst and data source identification.
In the first possible implementation of the third aspect, acquisition module, it is further used for the resource number according to user, from number segment routing table, search corresponding second segmental identification of the affiliated number section scope of resource number, and Query Result is sent to memory module, wherein, number segment routing table contains the corresponding relation of segmental identification and the affiliated number section scope of resource number;Memory module, it is further used for receiving the Query Result that acquisition module is sent, according to Query Result, it is determined that searching less than the second segmental identification, or when the second segmental identification found and inconsistent the first segmental identification, the corresponding relation of resource number and the first segmental identification is added in the dispersive number routing table in database, wherein, corresponding relation of the dispersive number routing table comprising segmental identification and the resource number for not belonging to number segment routing table.
In second of possible implementation of the third aspect, acquisition module, it is further used for before client's subscribing service, when client also carries out client and opened an account, obtain client's tenant identification, according to tenant identification, from the mapping table of fragment data source, obtain a segmental identification in the corresponding segmental identification of tenant identification, it regard get segmental identification as the first segmental identification, wherein, corresponding relation of the fragment data source mapping table also comprising tenant identification and segmental identification, and the customer ID generation request comprising the first segmental identification is sent to generation module;Generation module, the customer ID comprising the first segmental identification for receiving acquisition module transmission generates request, according to the first segmental identification, is the customer ID that client's generation includes the first segmental identification;Memory module, it is further used for getting the first segmental identification that customer ID is included from generation module, by the data storage of client in the corresponding data source of the first segmental identification, in order to which access server is according to the first segmental identification included in customer ID, the data of client are obtained from the corresponding data source of the first segmental identification.
In the third possible implementation of the third aspect, acquisition module, when being further used for determining that client does not open an account, according to the resource number of user, from number segment routing table, search corresponding second segmental identification of the affiliated number section scope of resource number, and the customer ID generation for sending the second segmental identification for generating request comprising the user's mark for inquiring about the second obtained segmental identification and being obtained comprising inquiry to generation module is asked, wherein, number segment routing table contains the corresponding relation of segmental identification and the affiliated number section scope of resource number;Generation module, is further used for receiving the bag that acquisition module is sent User's mark generation request containing the second segmental identification and the customer ID generation request comprising the second segmental identification, are the customer ID that client's generation includes the second segmental identification according to the second segmental identification;Acquisition module, is further used for according to the second segmental identification, from fragment data source mapping table, obtains the corresponding data source identification of the second segmental identification, and data source identification is sent into memory module;Memory module, is further used for by the data storage of client in the corresponding data source of the second segmental identification, and in order to which access server is according to the second segmental identification included in customer ID, the data of client are obtained from the corresponding data source of the second segmental identification.
In the 4th kind of possible implementation of the third aspect, acquisition module, when being further used for determining that client does not open an account, according to the resource number of user, from number segment routing table, corresponding second segmental identification of the affiliated number section scope of resource number is searched, wherein, number segment routing table contains the corresponding relation of segmental identification and the affiliated number section scope of resource number, when not inquiring the second segmental identification, obtains the tenant identification of client's tenant;And according to tenant identification, from the mapping table of fragment data source, obtain a segmental identification in the corresponding segmental identification of tenant identification, it regard get segmental identification as the first segmental identification, wherein, corresponding relation of the fragment data source mapping table also comprising tenant identification and segmental identification, and asked to user mark generation request of the generation module transmission comprising the first segmental identification and the customer ID generation comprising the first segmental identification;Generation module, it is further used for receiving the mark generation request of the user comprising the first segmental identification of acquisition module transmission and the customer ID generation comprising the first segmental identification is asked, it is the customer ID that client's generation includes the first segmental identification according to the first segmental identification;Memory module, it is further used for the corresponding relation of resource number and the first segmental identification being added in dispersive number routing table, wherein, corresponding relation of the dispersive number routing table comprising segmental identification and the resource number for not belonging to number segment routing table, and by the data storage of client in the corresponding data source of the first segmental identification, in order to which access server is according to the first segmental identification included in customer ID, the data of client are obtained from the corresponding data source of the first segmental identification.
In the 5th kind of possible implementation of the third aspect, in addition to:Module is moved, for according to the first data source identification, from the mapping table of fragment data source, the corresponding all segmental identifications of the first data source identification are obtained;Required according to resettlement, selection meets more than one segmental identification that resettlement is required from the first data source identification corresponding all segmental identifications, and the state of more than one segmental identification in the mapping table of fragment data source is set as relocation state, in order to forbid the network element in addition to data generating device to access the corresponding data of more than one segmental identification;Data in corresponding first data source of more than one segmental identification are moved into the second data source;In the mapping table of fragment data source, the corresponding relation of the first data source identification and more than one segmental identification is deleted;In the mapping table of fragment data source, the corresponding relation of the second data source identification of addition and more than one segmental identification, and the state of more than one segmental identification is set as non-relocation state, in order to allow to access the corresponding data of more than one segmental identification.
Fourth aspect, a kind of access server, including:Transceiver and processor, wherein, transceiver, the data operation request for receiving the transmission of data operation request device, data operation request includes access code, and is sent out to processor Send access code;Processor, the access code for receiving transceiver transmission, according to access code, obtains the segmental identification of the corresponding client's burst of access code;And according to the corresponding segmental identification of access code, from the mapping table of fragment data source, data source identification corresponding with segmental identification is obtained, and data source identification is sent to transceiver, wherein, fragment data source mapping table preserves segmental identification and data source identification;Transceiver, is further used for the data source identification of reception processing device transmission, and data operation request is sent in the corresponding data source of data source identification, and receives the data manipulation response that data source is sent.
In the first possible implementation of fourth face, processor is specifically for when access code is customer ID or user's mark, obtaining the segmental identification that customer ID or user's mark are included;When access code is resource number, according to the resource number of user, in dispersive number routing table, the corresponding segmental identification of resource number is searched, when finding the corresponding segmental identification of resource number, segmental identification is obtained;When not finding the corresponding segmental identification of resource number, according to the resource number of user, in number segment routing table, obtain the corresponding segmental identification of the affiliated number section of resource number, wherein, corresponding relation of the dispersive number routing table comprising segmental identification and the resource number for not belonging to number segment routing table, corresponding relation of the number segment routing table comprising segmental identification with the number section scope belonging to resource number.
5th aspect, a kind of data operation system, including such as fourth aspect or fourth aspect, the first may, second may, the third may, the 4th kind may or the 5th kind of possible implementation any data generating means and such as the first possible any access server in terms of the 5th or in terms of the 5th.
In the embodiment of the present invention, the first segmental identification that the first segmental identification and customer ID included due to user's mark that data generating device is generated is included is identical, and same segmental identification has corresponded to identical data source, therefore the data storage of different user of same client can be just realized in identical data source, solved the problem of data source is accessed.Brief description of the drawings
In order to illustrate more clearly about the embodiment of the present invention or technical scheme of the prior art, the required accompanying drawing used in embodiment or description of the prior art will be briefly described below, apparently, drawings in the following description are only some embodiments of the present invention, for those of ordinary skill in the art, without having to pay creative labor, other accompanying drawings can also be obtained according to these accompanying drawings.
Figure 1A is the scene framework schematic diagram that a kind of embodiment of the present invention is applied;
Figure 1B is one embodiment flow chart of date storage method of the present invention:
Fig. 2 is another embodiment flow chart of date storage method of the present invention;
Fig. 3 is another embodiment flow chart of date storage method of the present invention;
Fig. 4 is one embodiment flow chart of data conveying method of the present invention; Fig. 5 is one embodiment flow chart of data manipulation method of the present invention;
Fig. 6 is one embodiment block diagram of data generating device of the present invention;
Fig. 7 is another embodiment block diagram of data generating device of the present invention;
Fig. 8 is one embodiment block diagram of access server of the present invention;
Fig. 9 is another embodiment block diagram of access server of the present invention;
Figure 10 is one embodiment block diagram of data operation system of the present invention.Embodiment
Following examples of the present invention provide date storage method and device, data manipulation method, system and access server.
In order that those skilled in the art more fully understand the technical scheme in the embodiment of the present invention, and enable the above-mentioned purpose of the embodiment of the present invention, feature and advantage more obvious understandable, technical scheme in the embodiment of the present invention is described in further detail below in conjunction with the accompanying drawings.
Several technical terms in the embodiment of the present invention, tenant are introduced first(Tenant) refer in some region there is provided the operator of communication service, such as:Beijing Telecom is tenant 1, and Beijing movement is tenant 2, and Beijing UNICOM is tenant 3.Client(Customer) refer to subscribing to the agreement with tenant, have subscribed to or may order individual, group or the corporate body of the products & services that tenant provides, client can be individual client(Consumer customer), such as natural person;Client can also be group customer(Group customer), such as:Domestic customers or corporate client;One tenant contains multiple clients, when client opens an account, data generating device is that the client generates customer ID, customer ID unique mark client in customer life cycle, customer life cycle refer to from client open an account after in during whole before client's cancellation, the customer ID contains the segmental identification of the affiliated client's burst of the client.After client have subscribed a product or service at tenant, the client becomes the user (subscriber) of tenant, after client has handled multiple products or service, the client becomes multiple users of tenant, that is a client can correspond to multiple users, each unique corresponding resource number of user, such as:Broadband user's one broadband number of correspondence, cellphone subscriber's one phone number of correspondence, when user opens an account, client determines that a resource number or tenant distribute a resource number to the client, data generating device is user generation user's mark, user's mark unique mark user in subscriber lifecycle, subscriber lifecycle refer to from user open an account after in during whole before user's cancellation, the segmental identification that user mark is included and the segmental identification identical that the customer ID of the affiliated client of the user is included.Such as:Some domestic customers, can include broadband user, fixed telephone user and cellphone subscriber.Data source, for storing customer data and user data, such as:Can be database, database Diagrams() or database table Schema(table).In embodiments of the present invention, one client of predefined point Piece, each client's burst can correspond to a number of client, and the segmental identification of client's burst is referred to as client partitions prefix(Customer Partition Index, CPI), then can be respectively that each client's burst distributes a data source, the user's mark and/or the corresponding data of customer ID of segmental identification of such subsequent packet containing client's burst are stored in the corresponding data source of the segmental identification.Wherein, each data source can correspond at least one client's burst.Client's burst has mapping relations between tenant, client and data source simultaneously, and a tenant has corresponded to more than one client's burst, and each corresponding data source of client's burst be probably it is different, such as:The corresponding data source 1 of client's burst 1, the corresponding data source 2 of client's burst 2.
In the embodiment of the present invention, also describe several relation tables, fragment data source mapping table based on the relation generation between client's burst and data source, the fragment data source mapping table is used to preserve the segmental identification of client's burst and the corresponding relation of data source identification, and the corresponding relation between segmental identification and the tenant identification of tenant, wherein each at least one corresponding segmental identification of data source identification, and each at least one corresponding segmental identification of tenant identification, further the fragment data source mapping table further comprises segmental identification state and migration target data source mark, used when being moved for system to route data according to client's burst, wherein, segmental identification state can be the state for indicating whether resettlement, if segmental identification state is the 0 non-relocation state of expression, segmental identification state is 1 expression relocation state;Migration target data source is designated;The mark for the target data source that route data is moved to.Number segment routing table is used for the corresponding relation for preserving the number section scope that segmental identification is belonged to resource number, number section scope is represented by initial number and cut-off number, resource number i.e. between initial number and cut-off number belongs to the number section scope, here resource number can be phone number, broadband number or fixed number etc..The entry-into-force time and out-of-service time of tenant identification corresponding with segmental identification, and number segment routing table can also be further included in the number segment routing table.When dispersive number routing table is initial for sky, subsequently generate route data during, dispersive number routing table by for preserve segmental identification and do not belong to number segment routing table resource number corresponding relation;Dispersive number routing table further contains access style and access code, access style includes the type accessed by customer ID, the type of access is identified by user, or the type accessed by resource number, access code can be customer ID, user identifies or resource number, and dispersive number routing table further also includes the entry-into-force time and out-of-service time of dispersive number routing table.Above-mentioned fragment data source mapping table, dispersive number routing table and number segment routing table can be stored in the local of data generating device, also can individually be stored in the database outside data generating device.
It is a kind of scene framework schematic diagram of application of the embodiment of the present invention referring to Figure 1A:
Right side shows the network entity being related in data storage procedure, including data generating device, and database in Figure 1A;The network entity being related in process operation data, including Gateway GPRS Support Node(Gateway GPRS Support Node, GGSN), Session Description Protocol(Session Description Protocol, SDP) control point, access server and database. Wherein, data generating device can be generally arranged in the business hall of operator;Above-mentioned fragment data source mapping table, number segment routing table and dispersive number routing table are provided with database.
For data storage procedure:Data generating device can be according to the client's burst planned in advance, by segmental identification and data source identification, and the corresponding relation between segmental identification and the tenant identification of tenant is saved in the fragment data source mapping table in database, and the corresponding relation of segmental identification and the number section scope of resource number home is saved in the number segment routing table in database;When client opens an account, or the user of client opens an account, or client and its user are while when opening an account, data generating device can be that client generation client represents and be that user generation user identifies by the fragment data source mapping table in searching data storehouse, or number segment routing table;The corresponding relation for dissipating number resource number and segmental identification obtained during generation route data can be saved in dispersive number routing table by data generating device.The data of the data of client or user, can also be sent in the corresponding data source of segmental identification by the data maintenance module of data generating device.
GGSN or SDP are received after data operation request, the data operation request is sent to access server, the data operation request can inquire about request of data, or increase request of data, or delete request of data etc., when access server gets data operation request, the access code included to the data operation request, carry out analysis and obtain segmental identification, and according to the segmental identification searching data storehouse, the corresponding data source identification of the segmental identification is obtained, and the corresponding business of access code is routed to the corresponding data source of the data source identification.
Database can be one, or multiple, if database is multiple, various data and the uniformity of routing table that each database is kept by data syn-chronization.Database can include multiple data sources, and data source can also be independent, can be with position outside database, such as:The data source of storage customer data and user data can be located at the independent database outside database.
The embodiment of date storage method of the present invention and acquisition data method is described in detail with reference to the above.
It is one embodiment flow chart of date storage method of the present invention referring to Figure 1B, when client have subscribed a business, when the client becomes the user of the business, including:
Step 101:Data generating device determines that client has opened an account, the first segmental identification included in the customer ID for obtaining client, wherein, first segmental identification is the segmental identification of the affiliated client's burst of client, customer ID unique mark client in customer life cycle, customer life cycle refer to from client open an account after in a period of before client's cancellation;Client in the present embodiment has opened an account, and generated the customer ID of the client, now when client have subscribed some business, the client can select the resource number of one or tenant to distribute a resource number to the client, now data generating device obtains the first segmental identification included in customer ID, and the first segmental identification can be the prefix of customer ID, or the suffix of customer ID, it can also be the number of specific several positions in customer ID The preceding five digit number of such as 18 customer IDs is the first segmental identification.
Optionally:Before client's subscribing service, method also includes:When client is opened an account, client's tenant identification is obtained;Data generating device is according to tenant identification, from the mapping table of fragment data source, obtain a segmental identification in the corresponding segmental identification of tenant identification, it regard get segmental identification as the first segmental identification, wherein, corresponding relation of the fragment data source mapping table also comprising tenant identification and segmental identification;Data generating device is according to the first segmental identification, the customer ID for including the first segmental identification is generated for client, and by the data storage of client in the corresponding data source of the first segmental identification, in order to which access server is according to the first segmental identification included in customer ID, the data of client are obtained from the corresponding data source of the first segmental identification.
Step 102:Data generating device is that user of user's generation comprising the first segmental identification identifies according to the first segmental identification, user's mark unique mark user in subscriber lifecycle, subscriber lifecycle refer to from user open an account after in a period of before user's cancellation.
Step 103:Data generating device is according to the first segmental identification, from fragment data source mapping table, obtains the corresponding data source identification of the first segmental identification;And by the data storage of user in the corresponding data source of data source identification, the first segmental identification included in being identified in order to access server according to user, the data of user are obtained from the corresponding data source of the first segmental identification, wherein, the corresponding relation of segmental identification of the fragment data source mapping table comprising client's burst and data source identification.
Optionally, data generating device from number segment routing table, searches corresponding second segmental identification of the affiliated number section scope of resource number according to the resource number of user, wherein, number segment routing table contains the corresponding relation of segmental identification and the affiliated number section scope of resource number;It is determined that searching less than the second segmental identification, or when the second segmental identification found and inconsistent the first segmental identification, the corresponding relation of resource number and the first segmental identification is added in the dispersive number routing table in database by data generating device, wherein, corresponding relation of the dispersive number routing table comprising segmental identification and the resource number for not belonging to number segment routing table.
Optionally, when data generating device determines that client does not open an account, according to the resource number of user, from number segment routing table, search corresponding second segmental identification of the affiliated number section scope of resource number, wherein, number segment routing table contains the corresponding relation of segmental identification and the affiliated number section scope of resource number;Data generating device is when finding the second segmental identification, according to the second segmental identification, the customer ID for including the second segmental identification is generated for client, and according to the second segmental identification, the user comprising the second segmental identification is generated for user to identify, and by the data of client and the data storage of user in the corresponding data source of the second segmental identification, in order to which access server is according to the second segmental identification included in customer ID and/or user's mark, the data of client and/or the data of user are obtained from the corresponding data source of the second segmental identification.
Optionally, when not finding the second segmental identification, the tenant identification of client's tenant is obtained;Data are generated Device is according to tenant identification, from the mapping table of fragment data source, obtain a segmental identification in the corresponding segmental identification of tenant identification, it regard get segmental identification as the first segmental identification, wherein, corresponding relation of the fragment data source mapping table also comprising tenant identification and segmental identification;Data generating device, according to the first segmental identification, is the customer ID that client's generation includes the first segmental identification, and is that user of user's generation comprising the first segmental identification identifies according to the first segmental identification;The corresponding relation of resource number and the first segmental identification is added in dispersive number routing table, wherein, corresponding relation of the dispersive number routing table comprising segmental identification and the resource number for not belonging to number segment routing table, and by the data of client and the data storage of user in the corresponding data source of the first segmental identification, in order to which access server is according to the first segmental identification included in customer ID and/or user's mark, the data of client and/or the data of user are obtained from the corresponding data source of the first segmental identification.
Optionally, data generating device is according to the first data source identification, from the mapping table of fragment data source, obtains the corresponding all segmental identifications of the first data source identification;Required according to resettlement, selection meets more than one segmental identification that resettlement is required from the first data source identification corresponding all segmental identifications, and the state of more than one segmental identification in the mapping table of fragment data source is set as relocation state, in order to forbid the network element in addition to data generating device to access the corresponding data of more than one segmental identification;Data generating device moves the data in corresponding first data source of more than one segmental identification into the second data source;Data generating device deletes the corresponding relation of the first data source identification and more than one segmental identification in the mapping table of fragment data source;Data generating device is in the mapping table of fragment data source, add the corresponding relation of the second data source identification and more than one segmental identification, and the state of more than one segmental identification is set as non-relocation state, in order to allow to access the corresponding data of more than one segmental identification.
It is another embodiment flow chart of date storage method of the present invention referring to Fig. 2, including:
Step 201:When client opens an account, data generating device obtains the tenant identification of client's tenant;Client is selected after a tenant, and client is carried out under the tenant and is opened an account, therefore data generating device obtains the tenant identification of client's tenant naturally.
Step 202:Data generating device obtains a segmental identification in the corresponding segmental identification of tenant identification, regard get segmental identification as the first segmental identification.
Data generating device can be at random from all segmental identifications select a segmental identification, can also be according to the attribute of client, it is determined that the requirement to data source, then a satisfactory data source is selected, and from the mapping table of fragment data source, determine the corresponding segmental identification of data source identification of the data source.For example:Data generating device recognizes that the client is Very Important Person, the grade of the security requirement of its customer data is the superlative degree, the data source of five-star security is then selected to store the data of the corresponding client of the segmental identification or the data of user from multiple data sources, and from the mapping table of fragment data source, determine the corresponding segmental identification of data source identification of the data source.
Step 203:Data generating device is generated comprising the first segmental identification according to the first segmental identification for the client Customer ID, and by the data storage of the client in the corresponding data source of the first segmental identification, the customer ID is unique mark client in the customer life cycle, customer life cycle is interior to the whole period before client's cancellation after being opened an account from client.
In various embodiments of the present invention, the first segmental identification can as customer ID prefix, can also as customer ID suffix, be also used as specific several bit digitals of customer ID, such as:Customer ID is 18 numbers, and 1-4 are the first segmental identification, and the 5th is type code, such as, and type code position 0 represents customer ID, and 6-18 are the sequence number generated by certain rule.
Here the data of client can be customer ID, the customer name left when client opens an account, customer households address, Client Work unit etc..
After client has opened an account, the data storage procedure when user of the client opens an account includes:
Step 204:When client subscribes to some business, i.e., the client becomes the user of the business constantly, and data generating device obtains the first segmental identification included in the customer ID of the client.
When client subscribes to some business, client can select one resource number of a resource number or tenant's burst to be used to user, for example:Phone number, broadband number or client identification module(Subscriber Identity Module, SIM) card number etc..
Step 205:According to the first segmental identification data generating device of acquisition, the user comprising first segmental identification is generated for user to identify, and the data of user are stored in the corresponding data source of the first segmental identification, the first segmental identification included in being identified in order to access server according to user, obtains the data of user from the corresponding data source of the first segmental identification.
The data of user can include resource number, the type of service of user, the rate type of business, term of validity of business of user etc..
In various embodiments of the present invention, the first segmental identification can be the prefix of user's mark or the suffix of user's mark, can also be specific several bit digitals of user's mark, such as:User is designated 18 numbers, and 1-4 are the first segmental identification, and the 5th is type code, such as, and type code position 1 represents user's mark, and 6-18 is by the resource numbers of the sequence number of certain rule generation, or the user.
Step 206:According to the resource number of user, from number segment routing table, data generating device searches corresponding second segmental identification of the affiliated number section scope of resource number.
Step 207:If data generating device is searched less than the second segmental identification, or if when the second segmental identification for finding of data generating device and inconsistent the first segmental identification, data generating device will preserve resource number and the corresponding relation of the first segmental identification in dispersive number routing table.
For example when user's number of taking turns net, and another tenant is gone to from a tenant, any one number section in number segment routing table Scope does not all include the resource number.Or when the number section scope of some in number segment routing table contains the resource number, then obtain corresponding second segmental identification of the number section scope, i.e. the 2nd CPI.Due to when progress client opens an account, first segmental identification of selection and the second segmental identification found according to resource number there may be difference, therefore data generating device also needs to judge whether the second segmental identification found is consistent with the first segmental identification, if when the second segmental identification that data generating device is found and inconsistent the first segmental identification, data generating device will preserve resource number and the corresponding relation of the first segmental identification in dispersive number routing table, hereafter the corresponding segmental identification of resource number is exactly the first segmental identification, therefore follow-up access server is searching the corresponding segmental identification of user by resource number, need to be searched from dispersive number routing table first, secondly just searched from number segment routing table, if the second segmental identification that data generating device is found is consistent with the first segmental identification, the corresponding relation of the number section scope and the first segmental identification belonging to the resource number has been pre-saved due to number segment routing table, therefore data generating device need not just preserve the corresponding relation of the number section scope and the first segmental identification belonging to the resource number in number segment routing table.
It is another embodiment flow chart of date storage method of the present invention referring to Fig. 3, it is when have subscribed some business of the client simultaneously to be opened an account this example show client, i.e., the client becomes the user of the business, data storage procedure:
Step 301:According to the resource number of user, from number segment routing table, corresponding second segmental identification of the affiliated number section scope of resource number is searched.
Step 302:Judge whether to find the second segmental identification, when finding the second segmental identification, perform step 303, when not finding the second segmental identification, perform step 304.
Step 303:When finding the second segmental identification, according to the second segmental identification, the customer ID for including the second segmental identification is generated for client, and according to the second segmental identification, the user comprising the second segmental identification is generated for user to identify, and by the data of client and the data storage of user in the corresponding data source of the second segmental identification, in order to which access server is according to the second segmental identification included in customer ID and/or user's mark, the data of client and/or the data of user are obtained from the corresponding data source of the second segmental identification.
Step 304:When not finding the second segmental identification, the tenant identification of client's tenant is obtained.
For example when user's number of taking turns net, and another tenant is gone to from a tenant, any one number section scope does not all include the resource number in number segment routing table.
Step 305- steps 307:It is identical with step 202-204 respectively, it will not be repeated here.
Step 308:Data generating device is according to the first segmental identification, the user comprising the first segmental identification is generated for user to identify, and resource number and the corresponding relation of the first segmental identification are preserved in dispersive number routing table, and by the data storage of user in the corresponding data source of the first segmental identification, the first segmental identification included in being identified in order to access server according to user, obtains the data of user from the corresponding data source of the first segmental identification. From the embodiment shown in above-mentioned figure IB to Fig. 3, because customer ID and user's mark contain the segmental identification of identical client's burst, and it is a data source that a burst is corresponding, therefore the data of the data of client and user can be stored in identical data source.And can be according to the attribute of client, it is determined that the requirement to data source, so as to the satisfactory data source of distribution for client and user flexibility.
Referring to Fig. 4, the either method embodiment of the data storage based on Figure 1B -3 is one embodiment flow chart of data migration method of the present invention, and this example show the process that Data Migration is carried out in units of client's burst:Step 401:Data generating device is according to the first data source identification, from the mapping table of fragment data source, obtains the corresponding all segmental identifications of the first data source identification.
For example:When the data for the client that the first data source is included and the data of user are continuously increased, then the basic resource of first data source possibly can not support all clients under it, now need in the partial data resettlement under the first data source to the second data source, due to having carried out burst to client in the embodiment of the present invention, therefore data resettlement migration can be carried out in units of client's burst.
Step 402:Required according to resettlement, selection meets more than one segmental identification that resettlement is required from the first data source identification corresponding all segmental identifications, and the state of more than one segmental identification in the mapping table of fragment data source is set as relocation state, in order to forbid the network element in addition to data generating device to access the corresponding data of more than one segmental identification.
For example:It can require that the occupancy resource for moving the first data source is moved more than the corresponding data of client's burst of the first data source resource 1%, it can either require to move data of Very Important Person in the first data source etc. or can require to move the corresponding data of segmental identification of the half in all segmental identifications at random.
Required when according to resettlement, from the corresponding all segmental identifications of the first data source identification,, it is necessary to which the state of more than one segmental identification in the mapping table of fragment data source is set as into relocation state respectively when selecting one or more satisfactory segmental identifications.
Step 403:Data in corresponding first data source of more than one segmental identification are moved into the second data source.
Step 404:In the mapping table of fragment data source, the corresponding relation of the first data source identification and more than one segmental identification is deleted;In the mapping table of fragment data source, add the corresponding relation of the second data source identification and more than one segmental identification, and the state of more than one segmental identification is set as non-relocation state, in order to allow network element to access the corresponding data of more than one segmental identification.
As seen from the above-described embodiment, when carrying out Data Migration, because the corresponding relation of resource number, customer ID and user mark and segmental identification need not be changed, only need the segmental identification and the mapping relations of data source identification of client's burst of modification resettlement, and the mapping relations data volume very little of segmental identification and data source identification, therefore subtract in resettlement Lack the modification of route data, and the client's burst moved does not influence the business of other client's bursts, therefore reduce the complexity of client's resettlement.
It is the embodiment flow chart of data manipulation method of the present invention, any data storage method embodiment of the embodiment based on earlier figures 1-3 referring to Fig. 5:
Step 501:Access server receives the data operation request that data operation request device is sent, and data operation request includes access code.
Data operation request device can be GGSN, can also be other access devices such as SDP.
Step 502:Access server obtains the segmental identification of the corresponding client's burst of access code according to access code.When access code is customer ID or user's mark, the segmental identification that customer ID or user's mark are included is obtained;
When access code is resource number, according to the resource number of user, in dispersive number routing table, the corresponding segmental identification of resource number is searched, when finding the corresponding segmental identification of resource number, segmental identification is obtained;When not finding the corresponding segmental identification of resource number, according to the resource number of user, in number segment routing table, obtain the corresponding segmental identification of the affiliated number section of resource number, wherein, corresponding relation of the dispersive number routing table comprising segmental identification and the resource number for not belonging to number segment routing table, corresponding relation of the number segment routing table comprising segmental identification with the number section scope belonging to resource number.
Step 503:Access server is according to the corresponding segmental identification of access code, from the mapping table of fragment data source, obtains data source identification corresponding with segmental identification, wherein, fragment data source mapping table preserves segmental identification and data source identification.
Step 504:Data operation request is sent in the corresponding data source of the data source identification of acquisition by access server.
Step 505:Access server receives the data manipulation response that data source is sent.
As seen from the above-described embodiment, when the route data generated according to the embodiment of the present invention is route, the through street of a variety of access codes is realized by improving the flexibility of route.
Embodiment with date storage method of the present invention and data manipulation method is corresponding, and present invention also offers the embodiment of data generating device, system and access server.It is one embodiment block diagram of data generating device of the present invention based on above-mentioned Figure 1B -5 embodiment of the method referring to Fig. 6:
The device includes:Device includes acquisition module 610, generation module 620 and memory module 630, wherein, acquisition module 610, for when client have subscribed a business, when client becomes the user of business, it is determined that Client has opened an account, the first segmental identification included in the customer ID for obtaining client, wherein, first segmental identification is the segmental identification of the affiliated client's burst of client, customer ID unique mark client in customer life cycle, customer life cycle refer to from client open an account after in a period of before client's cancellation;
Acquisition module 610, is further used for sending user's mark generation request comprising the first segmental identification to generation module 620;
Generation module 620, user's mark generation request comprising the first segmental identification is sent for receiving acquisition module 610, and according to the first segmental identification, the user comprising the first segmental identification is generated for user to identify, user's mark unique mark user in subscriber lifecycle, subscriber lifecycle refer to from user open an account after in a period of before user's cancellation;
Acquisition module 610, is further used for according to the first segmental identification, from fragment data source mapping table, obtains the corresponding data source identification of the first segmental identification, and data source identification is sent into memory module 630;
Memory module 630, data source identification for receiving the transmission of acquisition module 610, and by the data storage of user in the corresponding data source of data source identification, the first segmental identification included in being identified in order to access server according to user, the data of user are obtained from the corresponding data source of the first segmental identification, wherein, the corresponding relation of segmental identification of the fragment data source mapping table comprising client's burst and data source identification.
Optionally, acquisition module 610, it is further used for the resource number according to user, from number segment routing table, search corresponding second segmental identification of the affiliated number section scope of resource number, and Query Result is sent to memory module 630, wherein, number segment routing table contains the corresponding relation of segmental identification and the affiliated number section scope of resource number;Accordingly, memory module 630, it is further used for receiving the Query Result that acquisition module 610 is sent, according to Query Result, it is determined that searching less than the second segmental identification, or when the second segmental identification found and inconsistent the first segmental identification, the corresponding relation of resource number and the first segmental identification is added in the dispersive number routing table in database, wherein, corresponding relation of the dispersive number routing table comprising segmental identification and the resource number for not belonging to number segment routing table.
Optionally, acquisition module 610, it is further used for before client's subscribing service, when client also carries out client and opened an account, obtain client's tenant identification, according to tenant identification, from the mapping table of fragment data source, obtain a segmental identification in the corresponding segmental identification of tenant identification, it regard get segmental identification as the first segmental identification, wherein, corresponding relation of the fragment data source mapping table also comprising tenant identification and segmental identification, and the customer ID generation request for including the first segmental identification is sent to generation module 620;Accordingly, generation module 620, the customer ID comprising the first segmental identification for receiving the transmission of acquisition module 610 generates request, according to the first segmental identification, is the customer ID that client's generation includes the first segmental identification;Accordingly, memory module 630, it is further used for getting the first segmental identification that customer ID is included from generation module 620, by the data storage of client in the corresponding data source of the first segmental identification, in order to which access server is according to the first segmental identification included in customer ID, from the first burst Identify the data that client is obtained in corresponding data source.
Optionally, acquisition module 610, when being further used for determining that client does not open an account, according to the resource number of user, from number segment routing table, search corresponding second segmental identification of the affiliated number section scope of resource number, and the customer ID generation for sending the second segmental identification for generating request comprising the user's mark for inquiring about the second obtained segmental identification and being obtained comprising inquiry to generation module 620 is asked, wherein, number segment routing table contains the corresponding relation of segmental identification and the affiliated number section scope of resource number;Accordingly, generation module 620, it is further used for receiving the mark generation request of the user comprising the second segmental identification of acquisition module transmission and the customer ID generation comprising the second segmental identification is asked, according to the second segmental identification, the customer ID for including the second segmental identification is generated for client, and be that user of user's generation comprising the second segmental identification identifies according to the second segmental identification;Acquisition module 610, is further used for according to the second segmental identification, from fragment data source mapping table, obtains the corresponding data source identification of the second segmental identification, and data source identification is sent into memory module 630;Accordingly, memory module 630, it is further used for the data of client and the data storage of user in the corresponding data source of the second segmental identification, in order to which access server is according to the second segmental identification included in customer ID and/or user's mark, the data of client and/or the data of user are obtained from the corresponding data source of the second segmental identification.
Optionally, acquisition module 610, when being further used for determining that client does not open an account, according to the resource number of user, from number segment routing table, corresponding second segmental identification of the affiliated number section scope of resource number is searched, wherein, number segment routing table contains the corresponding relation of segmental identification and the affiliated number section scope of resource number, when not inquiring the second segmental identification, obtains the tenant identification of client's tenant;And according to tenant identification, from the mapping table of fragment data source, obtain a segmental identification in the corresponding segmental identification of tenant identification, it regard get segmental identification as the first segmental identification, wherein, corresponding relation of the fragment data source mapping table also comprising tenant identification and segmental identification, and asked to user mark generation request of the transmission of generation module 620 comprising the first segmental identification and the customer ID generation comprising the first segmental identification;Accordingly, generation module 620, it is further used for receiving the mark generation request of the user comprising the first segmental identification of the transmission of acquisition module 610 and the customer ID generation comprising the first segmental identification is asked, it is the customer ID that client's generation includes the first segmental identification according to the first segmental identification;Accordingly, memory module 630, it is further used for the corresponding relation of resource number and the first segmental identification being added in dispersive number routing table, wherein, corresponding relation of the dispersive number routing table comprising segmental identification and the resource number for not belonging to number segment routing table, and by the data storage of client in the corresponding data source of the first segmental identification, in order to which access server is according to the first segmental identification included in customer ID and/or user's mark, the data of client are obtained from the corresponding data source of the first segmental identification.
Optionally, as shown in fig. 7, data generating device also includes:Module 640 is moved, for according to the first data source identification, from the mapping table of fragment data source, the corresponding all segmental identifications of the first data source identification are obtained;Required according to resettlement, selection meets one for moving and requiring from the first data source identification corresponding all segmental identifications Above segmental identification, and the state of more than one segmental identification in the mapping table of fragment data source is set as relocation state, in order to forbid the network element in addition to data generating device to access the corresponding data of more than one segmental identification;Data in corresponding first data source of more than one segmental identification are moved into the second data source;In the mapping table of fragment data source, the corresponding relation of the first data source identification and more than one segmental identification is deleted;In the mapping table of fragment data source, the corresponding relation of the second data source identification of addition and more than one segmental identification, and the state of more than one segmental identification is set as non-relocation state, in order to allow to access the corresponding data of more than one segmental identification.
It is one embodiment block diagram of access server of the present invention based on above-mentioned Figure 1B -5 embodiment of the method referring to Fig. 8:Including:Transceiver 810 and processor 820, wherein,
Transceiver 810, the data operation request for receiving the transmission of data operation request device, data operation request includes access code, and sends access code to processor 820;
Processor 820, the access code for receiving the transmission of transceiver 810, according to access code, obtains the segmental identification of the corresponding client's burst of access code;And according to the corresponding segmental identification of access code, from the mapping table of fragment data source, data source identification corresponding with segmental identification is obtained, and data source identification is sent to transceiver 810, wherein, fragment data source mapping table preserves segmental identification and data source identification;
Transceiver 810, is further used for the data source identification of the transmission of reception processing device 820, and data operation request is sent in the corresponding data source of data source identification, and receives the data manipulation response that data source is sent.
Optionally, it is characterised in that processor 820 is specifically for when access code is customer ID or user's mark, obtaining the segmental identification that customer ID or user's mark are included;When access code is resource number, according to the resource number of user, in dispersive number routing table, the corresponding segmental identification of resource number is searched, when finding the corresponding segmental identification of resource number, segmental identification is obtained;When not finding the corresponding segmental identification of resource number, according to the resource number of user, in number segment routing table, obtain the corresponding segmental identification of the affiliated number section of resource number, wherein, corresponding relation of the dispersive number routing table comprising segmental identification and the resource number for not belonging to number segment routing table, corresponding relation of the number segment routing table comprising segmental identification with the number section scope belonging to resource number.
It is that the data generating device in the embodiment block diagram of data generating device of the present invention, the embodiment of the present invention can be realized based on computer system, the method shown in Figure 1B -4 can be realized in the data generating device based on computer system referring to Fig. 9.Data generating device can include in the present embodiment:Processor 901, memory 902 and communication interface 903.Memory 902 is used for store program codes.Processor 901 is used to perform the program code stored in memory 902.In one embodiment of the invention, memory 902 is stored with the first program code, and processor 901 is used to perform first program code, including performs following operation:When client have subscribed a business, when client becomes the user of business, method includes:Determine client to have opened an account, obtain the first segmental identification for including in the customer ID of client, wherein, the first segmental identification is the segmental identification of the affiliated client's burst of client, customer ID in customer life cycle only One mark client, customer life cycle refer to from client open an account after in a period of before client's cancellation;Be that user of user's generation comprising the first segmental identification identifies according to the first segmental identification, user's mark unique mark user in subscriber lifecycle, subscriber lifecycle refer to from user open an account after in a period of before user's cancellation;According to the first segmental identification, from fragment data source mapping table, the corresponding data source identification of the first segmental identification is obtained;And by the data storage of user in the corresponding data source of data source identification, the first segmental identification included in being identified in order to access server according to user, the data of user are obtained from the corresponding data source of the first segmental identification, wherein, the corresponding relation of segmental identification of the fragment data source mapping table comprising client's burst and data source identification.Communication interface 903, is used for and external device communication, is such as communicated with access server.The message interacted between data generating device and access server(As shown in embodiment of the method Figure 1B -5)Sent and received by communication interface 903.Wherein, the message that program code of the processor 901 in memory 902 is received to communication interface 903 is handled, and is interacted by communication interface 903 with external equipment.Processor 901 can be central processing unit(Central processing unit, CPU), application specific integrated circuit (application-specific integrated circuit, ASIC) etc..Wherein, the device of the processing ICE addresses in the present embodiment can include bus 904.It can connect and communicate by bus 904 between processor 901, memory 902 and communication interface 903.Wherein, memory 902 can include:Random access memory (random access memory, RAM), read-only storage(Read-only memory, ROM), disk etc. has the entity of store function.Call context in the embodiment of the present invention can be buffered in RAM.
It is that the access server in the embodiment block diagram of access server of the present invention, the embodiment of the present invention can be realized based on computer system, the method shown in Fig. 5 can be realized in the access server based on computer system referring still to Fig. 9.Access server can include in the present embodiment:Processor 901, memory 902 and communication interface 903.Memory 902 is used for store program codes.Processor 901 is used to perform the program code stored in memory 902.In one embodiment of the invention, memory 902 is stored with the first program code, and processor 901 is used to perform first program code, including performs following operation:The data operation request that data operation request device is sent is received, data operation request includes access code;According to access code, the segmental identification of the corresponding client's burst of access code is obtained;According to the corresponding segmental identification of access code, from the mapping table of fragment data source, data source identification corresponding with segmental identification is obtained, wherein, fragment data source mapping table preserves segmental identification and data source identification;Data operation request is sent in the corresponding data source of the data source identification of acquisition;Receive the data manipulation response that data source is sent.Communication interface 903, is used for and external device communication, is such as communicated with data generation module.The message interacted between data generating device and access server(As shown in embodiment of the method Figure 1B -5)Sent and received by communication interface 903.Wherein, the message that program code of the processor 901 in memory 902 is received to communication interface 903 is handled, and is interacted by communication interface 903 with external equipment.Processor 901 can be central processing unit(Central processing unit, CPU), application specific integrated circuit (application-specific integrated circuit, ASIC) etc.. Wherein, the device of the processing ICE addresses in the present embodiment can include bus 904.It can connect and communicate by bus 904 between processor 901, memory 902 and communication interface 903.Wherein, memory 902 can include:Random access memory(Random access memory, RAM), read-only storage(Read-only memory, ROM), disk etc. has the entity of store function.Call context in the embodiment of the present invention can be buffered in RAM.
As seen from the above-described embodiment, the embodiment of the present invention contains the segmental identification of identical client's burst due to customer ID and user's mark, and it is a data source that a burst is corresponding, therefore the data of the data of client and user can be stored in identical data source.And can be according to the attribute of client, it is determined that the requirement to data source, so as to the satisfactory data source of distribution for client and user flexibility.
As shown in Figure 10, the structural representation of a kind of data operation system of the embodiment of the present invention, including the data generating device 1010 as shown in Fig. 6,7 or 9 and the access server 1020 such as Fig. 8 or Fig. 9.
Those skilled in the art can be understood that the technology in the embodiment of the present invention can add the mode of required general hardware platform to realize by software.Understood based on such, the part that technical scheme in the embodiment of the present invention substantially contributes to prior art in other words can be embodied in the form of software product, the computer software product can be stored in storage medium, such as ROM/RAM, magnetic disc, CD, including some instructions are to cause a computer equipment(Can be personal computer, server, or network equipment etc.)Perform the method described in some parts of each embodiment of the invention or embodiment.
Each embodiment in this specification is described by the way of progressive, and identical similar part is mutually referring to what each embodiment was stressed is the difference with other embodiment between each embodiment.For system embodiment, because it is substantially similar to embodiment of the method, so description is fairly simple, the relevent part can refer to the partial explaination of embodiments of method.
The embodiments of the present invention described above are not intended to limit the scope of the present invention.Any modifications, equivalent substitutions and improvements made within the spirit and principles in the present invention etc., should be included in the scope of the protection.

Claims (1)

权 利 要 求 Rights request 1、 一种数据存储方法, 其特征在于, 客户订阅了一个业务时, 所述客户成 为了所述业务的用户时, 所述方法包括: 1. A data storage method, characterized in that when a customer subscribes to a service and the customer becomes a user of the service, the method includes: 数据生成装置确定所述客户已经开户,获得所述客户的客户标识中包含的第 一分片标识, 其中, 所述第一分片标识为所述客户所属客户分片的分片标识, 所 述客户标识在客户生命周期内唯一标识所述客户,所述客户生命周期指的是从客 户开户后到客户销户前的期间内; The data generation device determines that the customer has opened an account, and obtains a first fragment identifier contained in the customer identifier of the customer, wherein the first fragment identifier is the fragment identifier of the client fragment to which the client belongs, and the The customer identifier uniquely identifies the customer within the customer life cycle, which refers to the period from the customer opening an account to the customer closing the account; 所述数据生成装置根据所述第一分片标识,为所述用户生成包含所述第一分 片标识的用户标识, 所述用户标识在用户生命周期内唯一标识所述用户, 所述用 户生命周期指的是从用户开户后到用户销户前的期间内; The data generation device generates, for the user, a user ID including the first segment ID for the user according to the first segment ID, the user ID uniquely identifies the user within the user life cycle, and the user life Period refers to the period from the time the user opens an account to the time before the user closes the account; 所述数据生成装置根据所述第一分片标识, 从分片数据源对应关系表, 获得 所述第一分片标识对应的数据源标识;并将所述用户的数据存储在所述数据源标 识对应的数据源中, 以便于接入服务器根据所述用户标识中包含的第一分片标 识, 从所述第一分片标识对应的数据源中获取所述用户的数据, 其中, 所述分片 数据源对应关系表包含客户分片的分片标识与数据源标识的对应关系。 The data generation device obtains the data source identifier corresponding to the first fragment identifier from the fragment data source correspondence table according to the first fragment identifier; and stores the user's data in the data source In the data source corresponding to the identification, so that the access server obtains the data of the user from the data source corresponding to the first fragment identification according to the first fragment identification included in the user identification, wherein, the The shard data source correspondence table contains the correspondence between the shard identifier of the client shard and the data source identifier. 2、 根据权利要求 1所述的方法, 其特征在于, 还包括: 2. The method according to claim 1, further comprising: 所述数据生成装置根据所述用户的资源号码, 从号段路由表中, 查找所述资 源号码所属号段范围对应的第二分片标识, 其中, 所述号段路由表包含了所述分 片标识与资源号码所属号段范围的对应关系; According to the resource number of the user, the data generation device searches the number segment routing table for the second fragment identifier corresponding to the number segment range to which the resource number belongs, wherein the number segment routing table includes the segment The corresponding relationship between the fragment identifier and the range of the number segment to which the resource number belongs; 确定查找不到所述第二分片标识,或者查找到的所述第二分片标识与所述第 一分片标识不一致时,所述数据生成装置将所述资源号码与所述第一分片标识的 对应关系添加到数据库中的散号路由表中, 其中, 所述散号路由表包含分片标识 与不归属于号段路由表的资源号码的对应关系。 When it is determined that the second fragment identifier cannot be found, or the found second fragment identifier is inconsistent with the first fragment identifier, the data generation device compares the resource number with the first fragment identifier. The corresponding relationship of the fragment identification is added to the bulk number routing table in the database, wherein the bulk number routing table includes the correspondence between the fragment identification and the resource numbers that do not belong to the number segment routing table. 3、 根据权利要求 1或 2所述的方法, 其特征在于, 在客户订阅业务之前, 所述方法还包括: 3. The method according to claim 1 or 2, characterized in that, before the customer subscribes to the service, the method further comprises: 所述客户进行开户时, 获得所述客户所属租户标识; When the client opens an account, obtain the tenant ID to which the client belongs; 所述数据生成装置根据所述租户标识, 从所述分片数据源对应关系表中, 获 取所述租户标识对应的分片标识中一个分片标识,将获取到的所述一个分片标识 作为第一分片标识, 其中, 所述分片数据源对应关系表还包含租户标识与分片标 识的对应关系; The data generation device obtains one of the fragment identifiers corresponding to the tenant identifier from the slice data source correspondence table according to the tenant identifier, and uses the acquired one of the fragment identifiers as The first shard ID, wherein the shard data source correspondence table further includes the correspondence between the tenant ID and the shard ID; 所述数据生成装置根据所述第一分片标识,为所述客户生成包含所述第一分 片标识的客户标识,并将所述客户的数据存储在所述第一分片标识对应的数据源 中, 以便于所述接入服务器根据所述客户标识中包含的第一分片标识, 从所述第 一分片标识对应的数据源中获取所述客户的数据。 The data generation device generates, for the customer, a the client identifier of the fragment identifier, and store the data of the client in the data source corresponding to the first fragment identifier, so that the access server can, according to the first fragment identifier contained in the client identifier, from The data of the customer is obtained from the data source corresponding to the first fragment identifier. 4、 根据权利要求 1所述的方法, 其特征在于, 还包括: 4. The method according to claim 1, further comprising: 所述数据生成装置确定所述客户未开户时, 根据所述用户的资源号码, 从号 段路由表中, 查找所述资源号码所属号段范围对应的第二分片标识, 其中, 所述 号段路由表包含了所述分片标识与资源号码所属号段范围的对应关系; When the data generation device determines that the customer has not opened an account, according to the user's resource number, from the number segment routing table, look up the second fragment identifier corresponding to the number segment range to which the resource number belongs, wherein the number The segment routing table includes the corresponding relationship between the fragment identifier and the number segment range to which the resource number belongs; 所述数据生成装置当查找到所述第二分片标识时, 根据所述第二分片标识, 为所述客户生成包含所述二分片标识的客户标识, 以及根据所述第二分片标识, 为所述用户生成包含所述第二分片标识的用户标识,以及将客户的数据和用户的 数据存储在所述第二分片标识对应的数据源中,以便于所述接入服务器根据所述 客户标识和 /或用户标识中包含的第二分片标识, 从所述第二分片标识对应的数 据源中获取所述客户的数据和 /或用户的数据。 When the data generation device finds the second fragment identifier, according to the second fragment identifier, generate a customer identifier including the second fragment identifier for the customer, and according to the second fragment identifier , generating a user ID that includes the second fragment ID for the user, and storing the customer's data and the user's data in a data source corresponding to the second fragment ID, so that the access server can The second fragment identifier included in the client identifier and/or user identifier acquires the customer data and/or user data from a data source corresponding to the second fragment identifier. 5、 根据权利要求 4所述的方法, 其特征在于, 还包括: 5. The method according to claim 4, further comprising: 当未查找到所述第二分片标识时, 获得所述客户所属租户的租户标识; 所述数据生成装置根据所述租户标识, 从所述分片数据源对应关系表中, 获 取所述租户标识对应的分片标识中一个分片标识,将获取到的所述一个分片标识 作为第一分片标识, 其中, 所述分片数据源对应关系表还包含租户标识与分片标 识的对应关系; When the second shard ID is not found, obtain the tenant ID of the tenant to which the customer belongs; the data generation device acquires the tenant from the shard data source correspondence table according to the tenant ID Identify one of the corresponding fragment identifiers, and use the acquired fragment identifier as the first fragment identifier, wherein, the fragment data source correspondence table also includes the correspondence between the tenant identifier and the fragment identifier relation; 所述数据生成装置根据所述第一分片标识,为所述客户生成包含所述第一分 片标识的客户标识, 以及根据所述第一分片标识, 为所述用户生成包含所述第一 分片标识的用户标识; The data generation device generates, for the customer, a customer ID that includes the first segment ID based on the first segment ID, and generates, for the user, a customer ID that includes the second segment ID based on the first segment ID. User ID of a shard ID; 将所述资源号码与所述第一分片标识的对应关系添加到散号路由表中, 其 中, 所述散号路由表包含分片标识与不归属于号段路由表的资源号码的对应关 系, 以及将客户的数据和用户的数据存储在所述第一分片标识对应的数据源中, 以便于所述接入服务器根据所述客户标识和 /或用户标识中包含的第一分片标 识, 从所述第一分片标识对应的数据源中获取所述客户的数据和 /或用户的数据。 Adding the correspondence between the resource number and the first fragment identifier to the bulk number routing table, wherein the bulk number routing table includes the correspondence between the fragmentation identifier and the resource number that does not belong to the number segment routing table , and store the customer data and user data in the data source corresponding to the first fragment identifier, so that the access server can , acquiring the customer data and/or user data from the data source corresponding to the first fragment identifier. 6、 根据权利要求 1至 5任意一项所述的方法, 其特征在于, 所述方法还包 括: 6. The method according to any one of claims 1 to 5, further comprising: 所述数据生成装置根据第一数据源标识, 从所述分片数据源对应关系表中, 获得所述第一数据源标识对应的所有的分片标识; The data generation device obtains all fragment identifiers corresponding to the first data source identifier from the slice data source correspondence table according to the first data source identifier; 根据搬迁要求,从所述第一数据源标识对应的所有的分片标识中选择符合所 述搬迁要求的一个以上分片标识,并将在所述分片数据源对应关系表中所述一个 以上分片标识的状态均设定为搬迁状态,以便于禁止除所述数据生成装置之外的 网元访问所述一个以上分片标识对应的数据; According to the relocation requirements, select from all the shard identifiers corresponding to the first data source identifier One or more fragment identifiers required by the relocation, and set the states of the more than one fragment identifiers in the fragment data source correspondence table as the relocation state, so as to prohibit The network element accesses the data corresponding to the one or more fragment identifiers; 所述数据生成装置将所述一个以上分片标识对应的所述第一数据源中的数 据搬迁到所述第二数据源中; The data generation device relocates the data in the first data source corresponding to the one or more fragment identifiers to the second data source; 所述数据生成装置在所述分片数据源对应关系表中,删除所述第一数据源标 识与所述一个以上分片标识的对应关系; The data generation device deletes the correspondence between the first data source identifier and the one or more fragment identifiers in the fragment data source correspondence table; 所述数据生成装置在所述分片数据源对应关系表中,添加所述第二数据源标 识与所述一个以上分片标识的对应关系,并将所述一个以上分片标识的状态设定 为非搬迁状态, 以便于允许访问所述一个以上分片标识对应的数据。 The data generating device adds the corresponding relationship between the second data source identifier and the one or more fragment identifiers in the slice data source correspondence table, and sets the state of the one or more fragment identifiers to It is in a non-relocation state, so as to allow access to the data corresponding to the one or more fragment identifiers. 7、 一种数据操作方法, 其特征在于, 包括: 7. A data manipulation method, comprising: 接入服务器接收数据操作请求装置发送的数据操作请求,所述数据操作请求 包含接入号码; The access server receives the data operation request sent by the data operation requesting device, and the data operation request includes an access number; 所述接入服务器根据所述接入号码,获得所述接入号码对应的客户分片的分 片标识; The access server obtains, according to the access number, the segment identifier of the client segment corresponding to the access number; 所述接入服务器根据所述接入号码对应的分片标识,从分片数据源对应关系 表中, 获得与所述分片标识对应的数据源标识, 其中, 所述分片数据源对应关系 表保存分片标识与数据源标识; The access server obtains the data source identifier corresponding to the fragment identifier from the fragment data source correspondence table according to the fragment identifier corresponding to the access number, wherein the fragment data source correspondence The table saves the shard ID and data source ID; 所述接入服务器将所述数据操作请求发送到获得的所述数据源标识对应的 数据源中; The access server sends the data operation request to the obtained data source corresponding to the data source identifier; 所述接入服务器接收所述数据源发送的数据操作响应。 The access server receives the data operation response sent by the data source. 8、 根据权利要求 7所述的方法, 其特征在于, 所述根据所述接入号码, 获 得所述接入号码对应的分片标识, 具体包括: 8. The method according to claim 7, wherein the obtaining the fragment identifier corresponding to the access number according to the access number specifically includes: 当所述接入号码为客户标识或用户标识时,获得所述客户标识或用户标识包 含的分片标识; When the access number is a client identifier or a user identifier, obtain the fragmentation identifier contained in the client identifier or user identifier; 当所述接入号码为资源号码时,根据所述用户的资源号码,在散号路由表中, 查找所述资源号码对应的分片标识, 当查找到所述资源号码对应的分片标识时, 获得所述分片标识; 当未查找到所述资源号码对应的分片标识时, 根据所述用户 的资源号码,在所述号段路由表中,获得所述资源号码所属号段对应的分片标识, 其中,所述散号路由表包含所述分片标识与不归属于所述号段路由表的资源号码 的对应关系,所述号段路由表包含所述分片标识与所述资源号码所属的号段范围 的对应关系。 9、 一种数据生成装置, 其特征在于, 所述装置包括获取模块、 生成模块和 存储模块, 其中, When the access number is a resource number, according to the resource number of the user, search for the fragment identifier corresponding to the resource number in the bulk number routing table, and when the fragment identifier corresponding to the resource number is found , obtaining the fragment identifier; when the fragment identifier corresponding to the resource number is not found, according to the resource number of the user, in the number segment routing table, obtain the Fragment identifiers, wherein the bulk number routing table includes the correspondence between the fragment identifiers and resource numbers that do not belong to the number segment routing table, and the number segment routing table includes the fragment identifiers and the Corresponding relationship of the number segment range to which the resource number belongs. 9. A data generation device, characterized in that the device includes an acquisition module, a generation module and a storage module, wherein, 所述获取模块, 用于当客户订阅了一个业务时, 所述客户成为了所述业务的 用户时, 确定所述客户已经开户, 获得所述客户的客户标识中包含的第一分片标 识, 其中, 所述第一分片标识为所述客户所属客户分片的分片标识, 所述客户标 识在客户生命周期内唯一标识所述客户,所述客户生命周期指的是从客户开户后 到客户销户前的期间内; The acquiring module is configured to determine that the customer has opened an account when the customer subscribes to a service and the customer becomes a user of the service, and obtain the first fragment identifier included in the customer identifier of the customer, Wherein, the first shard ID is the shard ID of the customer shard to which the customer belongs, and the customer ID uniquely identifies the customer within the customer life cycle, and the customer life cycle refers to the customer from opening an account to During the period before the client closes the account; 所述获取模块,进一步用于向所述生成模块发送包含所述第一分片标识的用 户标识生成请求; The acquiring module is further configured to send a user ID generation request including the first fragment ID to the generating module; 所述生成模块,用于接收所述获取模块发送包含所述第一分片标识的用户标 识生成请求, 并根据所述第一分片标识, 为所述用户生成包含所述第一分片标识 的用户标识, 所述用户标识在用户生命周期内唯一标识所述用户, 所述用户生命 周期指的是从用户开户后到用户销户前的期间内; The generating module is configured to receive a user ID generation request including the first fragment ID sent by the acquiring module, and generate a request for the user including the first fragment ID according to the first fragment ID. a user identifier, the user identifier uniquely identifies the user within the user life cycle, and the user life cycle refers to the period from the user opening an account to the user canceling the account; 所述获取模块, 进一步用于根据所述第一分片标识, 从分片数据源对应关系 表, 获得所述第一分片标识对应的数据源标识, 并将所述数据源标识发送给所述 存储模块; The obtaining module is further configured to obtain the data source identifier corresponding to the first fragment identifier from the fragment data source correspondence table according to the first fragment identifier, and send the data source identifier to the the storage module; 所述存储模块, 用于接收获取模块发送的所述数据源标识, 并将所述用户的 数据存储在所述数据源标识对应的数据源中,以便于接入服务器根据所述用户标 识中包含的第一分片标识,从所述第一分片标识对应的数据源中获取所述用户的 数据, 其中, 所述分片数据源对应关系表包含客户分片的分片标识与数据源标识 的对应关系。 The storage module is configured to receive the data source identifier sent by the acquisition module, and store the user's data in the data source corresponding to the data source identifier, so that the access server can use the The first shard ID of the first shard ID, and obtain the user's data from the data source corresponding to the first shard ID, wherein, the shard data source correspondence table includes the shard ID and the data source ID of the customer segment corresponding relationship. 10、 根据权利要求 9所述的装置, 其特征在于, 所述获取模块, 进一步用于 根据所述用户的资源号码, 从号段路由表中, 查找所述资源号码所属号段范围对 应的第二分片标识, 并向所述存储模块发送查询结果, 其中, 所述号段路由表包 含了所述分片标识与资源号码所属号段范围的对应关系; 10. The device according to claim 9, wherein the obtaining module is further configured to, according to the resource number of the user, search the number segment routing table for the number corresponding to the range of the number segment to which the resource number belongs. two fragment identifiers, and send a query result to the storage module, wherein the number segment routing table contains the corresponding relationship between the fragment identifier and the number segment range to which the resource number belongs; 所述存储模块, 进一步用于接收所述获取模块发送的查询结果, 根据所述查 询结果, 确定查找不到所述第二分片标识, 或者查找到的所述第二分片标识与所 述第一分片标识不一致时,将所述资源号码与所述第一分片标识的对应关系添加 到数据库中的散号路由表中, 其中, 所述散号路由表包含分片标识与不归属于号 段路由表的资源号码的对应关系。 The storage module is further configured to receive the query result sent by the acquisition module, and determine according to the query result that the second fragment identifier cannot be found, or that the found second fragment identifier is the same as the When the first fragment identifier is inconsistent, add the corresponding relationship between the resource number and the first fragment identifier to the hash routing table in the database, wherein the hash routing table includes the fragment identifier and non-attribution The corresponding relationship between resource numbers in the number segment routing table. 11、 根据权利要求 9或 10所述的装置, 其特征在于, 所述获取模块, 进一 步用于在客户订阅业务之前, 客户还进行客户开户时, 获得客户所属租户标识, 根据所述租户标识, 从所述分片数据源对应关系表中, 获取所述租户标识对应的 分片标识中一个分片标识, 将获取到的所述一个分片标识作为第一分片标识, 其 中, 所述分片数据源对应关系表还包含租户标识与分片标识的对应关系, 并向所 述生成模块发送包含所述第一分片标识的客户标识生成请求; 11. The device according to claim 9 or 10, wherein the acquisition module is further used to obtain the tenant identifier of the customer when the customer opens an account before the customer subscribes to the service, According to the tenant identifier, from the shard data source correspondence table, obtain one of the shard identifiers corresponding to the tenant identifier, and use the acquired one of the shard identifiers as the first shard identifier , wherein, the shard data source correspondence table further includes the correspondence between the tenant ID and the shard ID, and sends a client ID generation request including the first shard ID to the generation module; 所述生成模块,用于接收获取模块发送的包含所述第一分片标识的客户标识 生成请求, 根据所述第一分片标识, 为所述客户生成包含所述第一分片标识的客 户标识; The generation module is configured to receive the customer identification generation request that includes the first fragment identification sent by the acquisition module, and generate a customer identification that includes the first fragment identification for the customer according to the first fragment identification. logo; 所述存储模块,进一步用于从生成模块获取到所述客户标识包含的第一分片 标识, 将所述客户的数据存储在所述第一分片标识对应的数据源中, 以便于所述 接入服务器根据所述客户标识中包含的第一分片标识,从所述第一分片标识对应 的数据源中获取所述客户的数据。 The storage module is further configured to obtain the first fragment identifier contained in the customer identifier from the generation module, and store the customer's data in the data source corresponding to the first fragment identifier, so that the The access server acquires the client's data from a data source corresponding to the first fragment identifier according to the first fragment identifier included in the client identifier. 12、 根据权利要求 9所述的装置, 其特征在于, 所述获取模块, 进一步用于 确定所述客户未开户时, 根据所述用户的资源号码, 从号段路由表中, 查找所述 资源号码所属号段范围对应的第二分片标识,并向所述生成模块发送包含查询得 到的所述第二分片标识的用户标识生成请求和包含查询得到的所述第二分片标 识的客户标识生成请求, 其中, 所述号段路由表包含了所述分片标识与资源号码 所属号段范围的对应关系; 12. The device according to claim 9, wherein the acquisition module is further configured to, when it is determined that the customer has not opened an account, search for the resource from the number segment routing table according to the resource number of the user The second fragment identification corresponding to the range of the number segment to which the number belongs, and sending to the generation module a user identification generation request containing the second fragment identification obtained by query and a customer identification including the second fragment identification obtained by query An identifier generation request, wherein the number segment routing table includes the correspondence between the fragment identifier and the range of the number segment to which the resource number belongs; 所述生成模块,进一步用于接收所述获取模块发送的包含所述第二分片标识 的用户标识生成请求和包含所述第二分片标识的客户标识生成请求,根据所述第 二分片标识, 为所述客户生成包含所述第二分片标识的客户标识; The generation module is further configured to receive the user ID generation request containing the second fragment ID and the customer ID generation request containing the second fragment ID sent by the acquisition module, and according to the second fragment an identification, generating a customer identification including the second fragment identification for the customer; 所述获取模块, 进一步用于根据所述第二分片标识, 从分片数据源对应关系 表, 获得所述第二分片标识对应的数据源标识, 并将所述数据源标识发送给所述 存储模块; The obtaining module is further configured to obtain the data source identifier corresponding to the second fragment identifier from the fragment data source correspondence table according to the second fragment identifier, and send the data source identifier to the the storage module; 所述存储模块,进一步用于将客户的数据存储在所述第二分片标识对应的数 据源中, 以便于所述接入服务器根据所述客户标识中包含的第二分片标识, 从所 述第二分片标识对应的数据源中获取所述客户的数据。 The storage module is further configured to store the customer's data in the data source corresponding to the second fragment identifier, so that the access server can obtain the data from the The data of the customer is obtained from the data source corresponding to the second fragment identifier. 13、 根据权利要求 9所述的装置, 其特征在于, 所述获取模块, 进一步用于 确定所述客户未开户时, 根据所述用户的资源号码, 从号段路由表中, 查找所述 资源号码所属号段范围对应的第二分片标识, 其中, 所述号段路由表包含了所述 分片标识与资源号码所属号段范围的对应关系, 当未查询到所述第二分片标识 时, 获得所述客户所属租户的租户标识; 并根据所述租户标识, 从所述分片数据 源对应关系表中, 获取所述租户标识对应的分片标识中一个分片标识, 将获取到 的所述一个分片标识作为第一分片标识, 其中, 所述分片数据源对应关系表还包 含租户标识与分片标识的对应关系,以及向所述生成模块发送包含所述第一分片 标识的用户标识生成请求和包含所述第一分片标识的客户标识生成请求; 13. The device according to claim 9, wherein the acquisition module is further configured to, when it is determined that the customer has not opened an account, search for the resource from the number segment routing table according to the resource number of the user The second fragment identifier corresponding to the range of the number segment to which the number belongs, wherein the routing table of the number segment contains the correspondence between the fragment identifier and the range of the number segment to which the resource number belongs, and when the second fragment identifier is not queried , obtain the tenant ID of the tenant to which the customer belongs; and according to the tenant ID, obtain one of the shard IDs corresponding to the tenant ID from the shard data source correspondence table, and obtain The one fragment identifier is used as the first fragment identifier, wherein the fragment data source correspondence table also includes the correspondence between the tenant identifier and the fragment identifier, and sends a message containing the first fragment identifier to the generating module A user ID generation request for the slice ID and a client ID generation request including the first slice ID; 所述生成模块,进一步用于接收所述获取模块发送的包含所述第一分片标识 的用户标识生成请求和包含所述第一分片标识的客户标识生成请求,根据所述第 一分片标识, 为所述客户生成包含所述第一分片标识的客户标识; The generation module is further configured to receive the user ID generation request including the first fragment ID and the customer ID generation request including the first fragment ID sent by the acquisition module, and according to the first fragment ID an identification, generating a customer identification including the first fragment identification for the customer; 所述存储模块,进一步用于将所述资源号码与所述第一分片标识的对应关系 添加到散号路由表中, 其中, 所述散号路由表包含分片标识与不归属于号段路由 表的资源号码的对应关系,以及将客户的数据存储在所述第一分片标识对应的数 据源中, 以便于所述接入服务器根据所述客户标识中包含的第一分片标识, 从所 述第一分片标识对应的数据源中获取所述客户的数据。 The storage module is further configured to add the corresponding relationship between the resource number and the first fragment identifier to the bulk number routing table, wherein the bulk number routing table includes the fragment identifier and the non-belonging number segment The corresponding relationship between the resource numbers of the routing table, and storing the customer data in the data source corresponding to the first fragment identifier, so that the access server can, according to the first fragment identifier contained in the client identifier, Obtain the customer's data from the data source corresponding to the first fragment identifier. 14、 根据权利要求 9至 13任意一项所述的装置, 其特征在于, 还包括: 搬 迁模块, 用于根据第一数据源标识, 从所述分片数据源对应关系表中, 获得所述 第一数据源标识对应的所有的分片标识; 根据搬迁要求, 从所述第一数据源标识 对应的所有的分片标识中选择符合所述搬迁要求的一个以上分片标识,并将在所 述分片数据源对应关系表中所述一个以上分片标识的状态均设定为搬迁状态,以 便于禁止除所述数据生成装置之外的网元访问所述一个以上分片标识对应的数 据;将所述一个以上分片标识对应的所述第一数据源中的数据搬迁到所述第二数 据源中; 在所述分片数据源对应关系表中, 删除所述第一数据源标识与所述一个 以上分片标识的对应关系; 在所述分片数据源对应关系表中, 添加所述第二数据 源标识与所述一个以上分片标识的对应关系,并将所述一个以上分片标识的状态 设定为非搬迁状态, 以便于允许访问所述一个以上分片标识对应的数据。 14. The device according to any one of claims 9 to 13, further comprising: a relocation module, configured to obtain the shard data source correspondence table according to the first data source identifier. All fragment identifiers corresponding to the first data source identifier; According to the relocation requirements, select one or more fragment identifiers that meet the relocation requirements from all the fragment identifiers corresponding to the first data source identifier, and place The states of the one or more fragment identifiers in the fragment data source correspondence table are all set to the relocation state, so as to prohibit network elements other than the data generating device from accessing the data corresponding to the one or more fragment identifiers ; Migrate the data in the first data source corresponding to the one or more shard identifiers to the second data source; In the shard data source correspondence table, delete the first data source identifier Correspondence with the one or more fragment identifiers; In the fragment data source correspondence table, add the correspondence between the second data source identifier and the one or more fragment identifiers, and add the one or more The state of the fragment identifier is set to a non-relocation state, so as to allow access to data corresponding to the one or more fragment identifiers. 15、 一种接入服务器, 其特征在于, 包括: 收发器和处理器, 其中, 所述收发器, 用于接收数据操作请求装置发送的数据操作请求, 所述数据操 作请求包含接入号码, 并向所述处理器发送接入号码; 15. An access server, comprising: a transceiver and a processor, wherein the transceiver is configured to receive a data operation request sent by a data operation request device, the data operation request includes an access number, and sending an access number to said processor; 所述处理器, 用于接收所述收发器发送的接入号码, 根据所述接入号码, 获 得所述接入号码对应的客户分片的分片标识;并根据所述接入号码对应的分片标 识, 从分片数据源对应关系表中, 获得与所述分片标识对应的数据源标识, 并向 所述收发器发送所述数据源标识, 其中, 所述分片数据源对应关系表保存分片标 识与数据源标识; The processor is configured to receive the access number sent by the transceiver, obtain the segment identifier of the client segment corresponding to the access number according to the access number; Fragmentation identifiers, obtaining the data source identifiers corresponding to the fragmentation identifiers from the fragmentation data source correspondence table, and sending the data source identifiers to the transceiver, wherein the fragmentation data source correspondence The table saves the shard ID and data source ID; 收发器, 进一步用于接收所述处理器发送的所述数据源标识, 并将所述数据 操作请求发送到所述数据源标识对应的数据源中,以及接收所述数据源发送的数 据操作响应。 The transceiver is further configured to receive the data source identifier sent by the processor, send the data operation request to the data source corresponding to the data source identifier, and receive the data sent by the data source According to the operation response. 16、 根据权利要求 15所述的接入服务器, 其特征在于, 所述处理器具体用 于, 当所述接入号码为客户标识或用户标识时, 获得所述客户标识或用户标识包 含的分片标识; 当所述接入号码为资源号码时, 根据所述用户的资源号码, 在散 号路由表中, 查找所述资源号码对应的分片标识, 当查找到所述资源号码对应的 分片标识时, 获得所述分片标识; 当未查找到所述资源号码对应的分片标识时, 根据所述用户的资源号码, 在所述号段路由表中, 获得所述资源号码所属号段对 应的分片标识, 其中, 所述散号路由表包含所述分片标识与不归属于所述号段路 由表的资源号码的对应关系,所述号段路由表包含所述分片标识与所述资源号码 所属的号段范围的对应关系。 16. The access server according to claim 15, wherein the processor is specifically configured to, when the access number is a client ID or a user ID, obtain a component contained in the client ID or user ID fragment identification; when the access number is a resource number, according to the resource number of the user, search for the fragmentation identification corresponding to the resource number in the bulk number routing table, and when the resource number corresponding to the resource number is found When the fragment identifier is obtained, the fragment identifier is obtained; when the fragment identifier corresponding to the resource number is not found, according to the resource number of the user, in the number segment routing table, the number to which the resource number belongs is obtained Fragment identifiers corresponding to segments, wherein, the bulk number routing table includes the correspondence between the fragment identifiers and resource numbers that do not belong to the number segment routing table, and the number segment routing table includes the fragment identifiers Corresponding relationship with the number segment range to which the resource number belongs. 17、 一种数据操作系统, 其特征在于, 包括如权利要求 9-14的任一数据生 成装置和如权利要求 15-16的任一接入服务器。 17. A data operating system, comprising any data generating device according to claims 9-14 and any access server according to claims 15-16.
CN201280002589.8A 2012-12-31 2012-12-31 Date storage method and device, data manipulation method, system and access server Active CN104040539B (en)

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
PCT/CN2012/088144 WO2014101240A1 (en) 2012-12-31 2012-12-31 Data storage method and apparatus, data operation method and system, and access server

Publications (2)

Publication Number Publication Date
CN104040539A true CN104040539A (en) 2014-09-10
CN104040539B CN104040539B (en) 2017-06-06

Family

ID=51019822

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201280002589.8A Active CN104040539B (en) 2012-12-31 2012-12-31 Date storage method and device, data manipulation method, system and access server

Country Status (2)

Country Link
CN (1) CN104040539B (en)
WO (1) WO2014101240A1 (en)

Cited By (8)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN109117422A (en) * 2017-06-23 2019-01-01 中国软件与技术服务股份有限公司 Globally unique number rapid generation and system in a kind of extensive high concurrent system
CN110221988A (en) * 2019-05-05 2019-09-10 福建天泉教育科技有限公司 A kind of cache optimization method and system of third party's data
CN110737663A (en) * 2019-10-15 2020-01-31 腾讯科技(深圳)有限公司 data storage method, device, equipment and storage medium
CN110795315A (en) * 2018-08-01 2020-02-14 北京京东尚科信息技术有限公司 Method and apparatus for monitoring services
CN111126537A (en) * 2019-12-17 2020-05-08 北京达佳互联信息技术有限公司 Identification code ID generation method and related product
CN113645304A (en) * 2021-08-13 2021-11-12 恒生电子股份有限公司 Data service processing method and related equipment
CN114116699A (en) * 2020-09-01 2022-03-01 深圳市珍爱捷云信息技术有限公司 Data processing method, apparatus, electronic device and computer-readable storage medium
CN115396275A (en) * 2021-05-06 2022-11-25 华为技术有限公司 Data acquisition method, system and device

Families Citing this family (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
FI20186072A1 (en) 2018-12-12 2020-06-13 Telia Co Ab Access management to user related data

Citations (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN1585548A (en) * 2004-05-25 2005-02-23 中兴通讯股份有限公司 Realizing method for distributed access positioning register VLR
CN101093482A (en) * 2006-06-19 2007-12-26 上海全成通信技术有限公司 Method for storing and retrieving mass information

Family Cites Families (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101551826B (en) * 2009-05-19 2011-10-05 成都市华为赛门铁克科技有限公司 Data retrieval process, set and system
CN102594852B (en) * 2011-01-04 2016-03-30 中国移动通信集团公司 Data access method, node and system

Patent Citations (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN1585548A (en) * 2004-05-25 2005-02-23 中兴通讯股份有限公司 Realizing method for distributed access positioning register VLR
CN101093482A (en) * 2006-06-19 2007-12-26 上海全成通信技术有限公司 Method for storing and retrieving mass information

Cited By (12)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN109117422A (en) * 2017-06-23 2019-01-01 中国软件与技术服务股份有限公司 Globally unique number rapid generation and system in a kind of extensive high concurrent system
CN110795315A (en) * 2018-08-01 2020-02-14 北京京东尚科信息技术有限公司 Method and apparatus for monitoring services
CN110221988A (en) * 2019-05-05 2019-09-10 福建天泉教育科技有限公司 A kind of cache optimization method and system of third party's data
CN110737663A (en) * 2019-10-15 2020-01-31 腾讯科技(深圳)有限公司 data storage method, device, equipment and storage medium
CN110737663B (en) * 2019-10-15 2024-06-11 腾讯科技(深圳)有限公司 Data storage method, device, equipment and storage medium
CN111126537A (en) * 2019-12-17 2020-05-08 北京达佳互联信息技术有限公司 Identification code ID generation method and related product
CN111126537B (en) * 2019-12-17 2024-03-12 北京达佳互联信息技术有限公司 Identification code ID generation method and related product
CN114116699A (en) * 2020-09-01 2022-03-01 深圳市珍爱捷云信息技术有限公司 Data processing method, apparatus, electronic device and computer-readable storage medium
CN115396275A (en) * 2021-05-06 2022-11-25 华为技术有限公司 Data acquisition method, system and device
CN115396275B (en) * 2021-05-06 2023-12-29 华为技术有限公司 A data acquisition method, system and device thereof
CN113645304A (en) * 2021-08-13 2021-11-12 恒生电子股份有限公司 Data service processing method and related equipment
CN113645304B (en) * 2021-08-13 2023-06-16 恒生电子股份有限公司 Data service processing method and related equipment

Also Published As

Publication number Publication date
WO2014101240A1 (en) 2014-07-03
CN104040539B (en) 2017-06-06

Similar Documents

Publication Publication Date Title
CN104040539A (en) Data storage method and apparatus, data operation method and system, and access server
US10419875B2 (en) System and method for determining a subscriber's zone information
US9762449B2 (en) Distributing information
CN103888928B (en) Business strategy control method and system
CN111901132B (en) Group management method, device and system
US20220039003A1 (en) Methods and apparatuses for network function selection in 5g for a user
CN107580360A (en) Method, device and network architecture for network slice selection
US11108832B2 (en) Network component selection based on device identifier
CN107889194B (en) Obtain, provide method, equipment and the medium of wireless access point access information
CN110035040B (en) Method and device for signaling addressing
WO2014075450A1 (en) Resource download method, service server and cellular phone client
CN107231445A (en) A kind of dynamic domain name system DNS reorientation methods, apparatus and system
CN110324291A (en) A kind of communication means and Related product
CN105142189B (en) The roam control method and device of website
CN112217653B (en) Strategy issuing method, device and system
US20090097458A1 (en) Method and System for Agent Redirecting the Terminal Request
US11425208B2 (en) Message delivery based on subsets of network identities
US20220350748A1 (en) Consistent hashing for communication devices
US20240267470A1 (en) Method and system for routing of inbound toll-free communications
CN105429880B (en) Network device and method for routing and forwarding thereof
US11909920B2 (en) Converged voicemail provisioning and FQDN based voicemail call routing
CN104822140B (en) A kind of method and network communicating system of data query
CN115190104B (en) Information transmission method, apparatus, communication device and storage medium
CN102957668B (en) The method and access service router of positional information are obtained in mark net
CN104378395A (en) Method and device for accessing OTT application and server push message

Legal Events

Date Code Title Description
C06 Publication
PB01 Publication
C10 Entry into substantive examination
SE01 Entry into force of request for substantive examination
GR01 Patent grant
GR01 Patent grant