Method and system for implementing a databus in a global ecosystem of interrelated services

• US 7,802,264 B2
• Filed: 03/29/2002
• Issued: 09/21/2010
• Est. Priority Date: 05/22/2000
• Status: Expired due to Term

• Current Assignee: EKMK Limited Liability Company
• Original Assignee: Verizon Business Global LLC (Verizon Communications Inc.)
• Inventors: Wille, Andrew N., Robertson, James A., Greene, William S.
• Primary Examiner(s): Cao; Diem K
• Application Number:
  US10/110,000
• Publication Number:
  US 20020188538A1
• Time in Patent Office: 3,098 Days
• Field of Search: 707 1- 10, 707100-102, 707103-104, 707103 Y-103 Z, 707/104.1, 719310-320, 719328-332, 709200-207, 709217-219, 709223-226, 709/245
• US Class Current: 709/215
• CPC Class Codes: G06Q 10/063112 Skill-based matching of a person or a group to a task
• CPC Class Codes: G06Q 10/06314 Calendaring for a resource
• CPC Class Codes: G06Q 10/06398 Performance of employee with respect to a job function
• CPC Class Codes: G06Q 10/10 Office automation; Time management
• CPC Class Codes: G06Q 10/1093 Calendar-based scheduling for persons or groups
• CPC Class Codes: G06Q 20/3829 involving key management
• CPC Class Codes: G06Q 40/00 Finance; Insurance; Tax strategies; Processing of corporate or income taxes
• CPC Class Codes: H04L 41/0233 Object-oriented techniques, for representation of network management data, e.g. common object request broker architecture [CORBA]
• CPC Class Codes: H04L 41/0661 by reconfiguring faulty entities
• CPC Class Codes: H04L 41/0663 Performing the actions predefined by failover planning, e.g. switching to standby network elements
• CPC Class Codes: H04L 41/0843 based on generic templates
• CPC Class Codes: H04L 41/0856 by backing up or archiving configuration information
• CPC Class Codes: H04L 41/0893 Assignment of logical groups to network elements
• CPC Class Codes: H04L 41/0894 Policy-based network configuration management
• CPC Class Codes: H04L 41/40 using virtualisation of network functions or resources, e.g. SDN or NFV entities
• CPC Class Codes: H04L 41/5041 characterised by the time relationship between creation and deployment of a service
• CPC Class Codes: H04L 41/5058 Service discovery by the service manager
• CPC Class Codes: H04L 61/4553 Object oriented directories, e.g. common object request broker architecture [CORBA] name server
• CPC Class Codes: H04L 63/08 for authentication of entities cryptographic mechanisms or cryptographic arrangements for entity authentication H04L9/32
• CPC Class Codes: H04L 63/102 Entity profiles
• CPC Class Codes: H04L 63/123 : received data contents, e.g. message integrity
• CPC Class Codes: H04L 67/01 : Protocols
• CPC Class Codes: H04L 67/1095 : Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes
• CPC Class Codes: H04L 67/34 : involving the movement of software or configuration parameters network booting or remote initial program loading [RIPL] G06F9/4416
• CPC Class Codes: H04L 67/51 : Discovery or management thereof, e.g. service location protocol [SLP] or web services
• CPC Class Codes: H04L 67/535 : Tracking the activity of the user network monitoring arrangements H04L43/00; recording of computer activity G06F11/34
• CPC Class Codes: H04L 67/54 : Presence management, e.g. monitoring or registration for receipt of user log-on information, or the connection status of the users
• CPC Class Codes: H04L 67/568 : Storing data temporarily at an intermediate stage, e.g. caching
• CPC Class Codes: Y10S 707/99931 : Database or file accessing

Abstract

In accordance with an exemplary embodiment of the present invention, a DataBus data management architecture is presented for the NewWave service platform. It presents an architecture for creating a consistent, enterprise-wide data persistence layer which allows clients to access shared enterprise data. The DataBus achieves this enterprise-wide look by decoupling shared enterprise data from specific applications (breaking down the stovepipes) and opening up the data layer to across-the-enterprise access (given proper authorization). The DataBus architecture is designed from the ground up for global scalability and accommodation of evolving business data models in a highly-distributed physical deployment. Scaling is realized predominantly through the partitioning, while individual partitions are mapped to logical data domains that are defined along more relevant dimensions than entity-type dimensions (e.g., geography, line of business, etc.) and cut across traditional entity boundaries. Central to the DataBus data model is the notion that a data layer represents a shared asset of the corporation that is decoupled from the separate production applications requiring access to this data. The DataBus data architecture combines several main features or facets, such as partitioning, multi-hop finder strategies, externalized associations, object layer mediating access to underlying data storage, support for logical domains and transaction management.

Claims

1. A data processing system implemented method for managing data as a shared asset among clients in an enterprise, said enterprise comprising a plurality of network domains and further comprises a plurality of partitions for holding data, the method comprising:

receiving a request in a local network domain for a data object, wherein the request is from a client and identifies the data object by a unique primary key (PK);

identifying a partition holding the data object based on the unique PK for the data object; and

returning the requested data object to the client, wherein the identifying further comprises;

accessing a plurality of PK-partition maps held in a satellite cache, wherein said satellite cache is in the local network domain, and

looking up a partition identifier for the partition holding the data object in the plurality of PK-partition maps from the satellite cache based on the unique PK for the data object, wherein the looking up the partition identifier in the satellite cache using the plurality of PK-partition maps returns a null set of partition identifiers identifying a partition holding the data object and further comprises;

accessing a plurality of PK-partition maps held in an enterprise repository, wherein said enterprise repository is external to the local network domain; and

looking up the partition identifier for the partition holding the data object in the plurality of PK-partition maps in the enterprise repository based on the unique PK for the data object,

wherein each of the plurality of partitions are object containers for running services and at least one of the plurality of partitions is hosted by a unique host server.

2. The method recited in claim 1, wherein the looking up the partition identifier in the enterprise repository using the plurality of PK-partition maps returns a null set of partition identifiers, identifying a partition holding the data object and further comprises:

issuing a query from a steward to each of the partitions for an identity of the partition holding the data object; and

returning the identity of the partition holding the data object.

3. The method recited in claim 2, wherein the requested data object is an entity type and the steward is an entity manager for said entity type.

4. The method recited in claim 3, wherein prior to receiving a request in a local network domain for a data object the method further comprises:

finding a satellite in the local network domain, wherein the client looks up a satellite with a domain registrar in the local network domain.

5. The method recited in claim 4 further comprises:

receiving a satellite proxy object for the satellite, wherein the client interacts with the satellite through the satellite proxy object.

6. The method recited in claim 4 further comprises:

receiving a satellite proxy object for the satellite, wherein the satellite proxy object performs at least one of receiving a request, identifying a partition, and returning the requested data object local to the client.

7. The method recited in claim 1, wherein the returning the requested data object to the client further comprises:

querying the partition holding the data object to find the data object based on the unique PK, wherein the partition returns a data object instance to the client.

8. The method recited in claim 1, wherein the returning the requested data object to the client further comprises:

receiving a clone of the data object; and

receiving an update to the data object.

9. The method recited in claim 8, wherein the client is substantially Java compliant.

10. The method recited in claim 1, wherein the returning the requested data object to the client further comprises:

receiving a clone of the data object; and

returning an update to the data object to the partition.

11. The method recited in claim 10 further comprising:

receiving a stale data exception in response to the update to the data object returned to the partition.

12. The method recited in claim 1, wherein the returning the requested data object to the client further comprises:

querying, by a satellite in the local domain, the partition holding the data object to find the data object based on the unique PK;

receiving a clone of the data object at the satellite; and

granting accesses to the client of the clone of the data object at the satellite, wherein the client is not Java compliant.

13. The method recited in claim 1, wherein at least some of the plurality of partitions hold a plurality of data objects, each of said plurality of data objects being of a common entity type.

14. The method recited in claim 1, wherein each of the plurality of partitions holds data objects of a common entity type.

15. A system for managing data as a shared asset among clients in an enterprise comprising:

a plurality of servers, said plurality of servers comprising a plurality of groups of servers, each group of servers in said plurality of servers being located at a common physical location;

a plurality of resources, each of said plurality of resources being associated with a server in a group of servers located at a physical location, at least a portion of said plurality of resources allocated for storing data; and

a plurality of services, each service in said of said plurality of services running on a server of the plurality of servers, said plurality of services comprises;

a plurality of container services,

an enterprise repository service for maintaining a plurality of primary keys (PK)-partition maps for identifying a partition by a unique PK,

a steward service for managing PKs, and

a satellite service for maintaining a plurality of PK-partition maps for identifying a partition by a unique PK.

16. The system of claim 15 further comprising:

a plurality of partitions, wherein each partition of said plurality of partitions is defined by one of a container service, a resource allocated for storing data or data of a common entity type.

17. The system of claim 15 further comprising:

a plurality of databases, each database of said plurality of databases being configured to store data of a common entity type, wherein said plurality of databases are allocated from at least one of said plurality of resources allocated for storing data; and

a plurality of partitions, each of said plurality of partitions being associated with a database of the plurality of databases configured to store data of a common entity type.

18. The system of claim 16, wherein said each of said plurality of partitions is further associated with a container service running on a server of the plurality of servers.

19. A data processing system implemented program product embodied on a data processing system readable medium for implementing a method for managing data as a shared asset among clients in an enterprise, said enterprise comprising a plurality of network domains and further comprising a plurality of partitions for holding data, the product comprising:

satellite service instructions for receiving a request from a client for a data object by a unique primary key (PK);

instructions for identifying a partition holding the data object based on the unique PK for the data object, wherein the instructions for identifying a partition holding the data object comprises;

instructions for accessing a plurality of PK-partition maps held in a satellite service cache in a local domain,

instructions for looking up a partition identifier for the partition holding the data object in the plurality of PK-partition maps from the satellite service cache based on the unique PK for the data object,

instructions for determining whether a null set of partition identifiers is returned in response to executing the instructions for looking up the partition identifier in the satellite service cache using the plurality of PK-partition maps,

instructions for accessing a plurality of PK-partition maps held in an enterprise repository, wherein said enterprise repository is external to the local domain, and

instructions for looking up the partition identifier for the partition holding the data object in the plurality of PK-partition maps in the enterprise repository based on the unique PK for the data object; and

instructions for returning the requested data object to the client,

wherein each of the plurality of partitions are object containers for executing instructions for running services and at least one of the plurality of partitions is hosted by a unique host server.

20. The program product recited in claim 19, wherein the instructions identifying a partition holding the data object further comprises:

instructions for determining whether a null set of partition identifiers is returned in response to executing the instructions for looking up the partition identifier in the enterprise repository using the plurality of PK-partition maps;

instructions for issuing a query from a steward service to each partition for an identity of the partition holding the data object; and

instructions for returning the identity of the partition holding the data object.

21. The program product recited in claim 20, wherein the requested data object is an entity type and the steward service is an entity manager for said entity type.

22. The program product recited in claim 19 further comprising:

client instructions for finding a satellite service in the local domain, said instructions, when executed, causes the client to look up the satellite service with a domain registrar in the local domain.

23. The program product recited in claim 22 further comprising:

client instructions for receiving a satellite proxy object for the satellite service, wherein the client interacts with the satellite service through the satellite proxy object.

24. The program product recited in claim 22 further comprising:

client instructions for receiving a satellite proxy object for the satellite service, wherein the satellite proxy object performs at least one of receiving a request, identifying a partition, or returning the requested data object, local to the client.

25. The program product recited in claim 19, wherein the instructions for returning the requested data object to the client further comprises:

instructions for querying the partition holding the data object to find the data object based on the unique PK, wherein the partition returns a data object instance to the client.

26. The program product recited in claim 19, wherein the instructions for returning the requested data object to the client further comprises:

instructions for receiving a clone of the data object; and

instructions for receiving an update to the data object.

27. The program product recited in claim 26, wherein the client is substantially Java compliant.

28. The program product recited in claim 19, wherein the instructions for returning the requested data object to the client further comprises:

instructions for receiving a clone of the data object; and

instructions for returning an update to the data object to the partition.

29. The program product recited in claim 28 further comprising:

instructions for receiving a stale data exception in response to the update to the data object returned to the partition.

30. The program product recited in claim 19, wherein the instructions for returning the requested data object to the client further comprises:

instructions for querying, by a satellite service in a local domain, the partition holding the data object to find the data object based on the unique PK;

instructions for receiving a clone of the data object at the satellite service; and

instructions for granting access to the client of the clone of the data object at the satellite service, wherein the client is not Java compliant.

31. A data processing system implemented method for managing data as a shared asset among clients in an enterprise, said enterprise comprising a plurality of logical network domains and further comprising a plurality of partitions for holding data, the method comprising:

receiving a request in a local domain to create a data object, wherein the request is received by a satellite and sent from a client;

determining whether a unique primary key (PK) is available for the data object;

assigning the unique PK to the data object;

determining a partition in which to create the data object;

returning an instance of the data object to the client;

creating a PK-partition map for mapping the unique PK associated with the data object to a partition identifier of the partition in which the data object was created;

storing a copy of the PK-partition map with the satellite; and

storing a copy of the PK-partition map with an enterprise repository, wherein the enterprise repository is located outside the local domain.

32. The method recited in claim 31, wherein the determining whether a unique PK is available for the data object further comprises:

checking a cache associated with the satellite for an available PK.

33. The method recited in claim 32 further comprising:

requesting a plurality of PKs from a steward in response to a PK not being available in the satellite cache.

34. The method recited in claim 32, wherein the data object is an entity type and the steward is an entity manager for said entity type.

35. The method recited in claim 31, wherein prior to the receiving a request in a local domain to create data object the method further comprises:

finding the satellite in the local domain, wherein the client looks up the satellite with a domain registrar in the local domain.

36. The method recited in claim 35 further comprises:

receiving a satellite proxy object for the satellite, wherein the client interacts with the satellite through the satellite proxy object.

37. The method recited in claim 35 further comprising:

receiving a satellite proxy object for the satellite, wherein at least one of the receiving a request, the determining whether a unique PK is available, the assigning a unique PK to the data object, the determining the partition in which to create the data object, or the returning an instance of the data object, is performed local to the client through the satellite proxy object.

38. A data processing system implemented program product embodied on a data processing system readable medium for implementing a method for managing data as a shared asset among clients in an enterprise, said enterprise comprising a plurality of network domains and further comprising a plurality of partitions for holding data, the program product comprising:

satellite service instructions for receiving a request from a client to create a data object, said satellite service instructions to be executed in a local domain;

instructions for determining whether a unique primary key (PK) is available for the data object;

instructions for assigning the unique PK to the data object;

instructions for determining a partition in which to create the data object;

instructions for returning an instance of the data object to the client;

instructions for creating a PK-partition map for mapping the unique PK associated with the data object to a partition identifier of the partition in which the data object was created;

instructions for storing a copy of the PK-partition map with a satellite; and

instructions for storing a copy of the PK-partition map with an enterprise repository, wherein the enterprise repository is located outside the local domain.

39. The program product recited in claim 38, wherein the instructions for determining whether a unique primary key (PK) is available for the data object further comprises:

instructions for checking a cache associated with a satellite for an available PK.

40. The program product recited in claim 39 further comprising:

instructions for requesting a plurality of PKs from a steward in response to a PK not being available in the satellite service cache.

41. The program product recited in claim 40, wherein the data object is an entity type and the steward service is an entity manager for said entity type.

42. The program product recited in claim 38 further comprising:

client instructions for finding a satellite in the local domain, when executed the client looks up the satellite with a domain registrar service executing in the local domain.

43. The program product recited in claim 42 further comprising:

instructions for receiving a satellite proxy object for the satellite, wherein the client interacts with the satellite through the satellite proxy object.

44. The program product recited in claim 42 further comprising:

instructions for receiving a satellite proxy object for the satellite, wherein at least one of the satellite service instructions for receiving a request, the instructions for determining whether a unique PK is available, the instructions for assigning a unique PK to the data object, the instructions for determining the partition in which to create the data object, or the instructions for returning an instance of the data object, is executed local to the client through the satellite proxy object.

45. A system for managing data as a shared asset among clients in an enterprise comprising:

a plurality of enterprise data resources, at least some of said plurality of enterprise data resources being partitioned into identifiable partitions;

an enterprise repository for maintaining a first plurality of primary keys (PK)-partition maps for identifying a partition by a unique PK;

a steward service for managing PKs;

a plurality of enterprise network domains, wherein each network domain comprises a satellite service for maintaining a second plurality of PK-partition maps for identifying a partition by a unique PK; and

a transaction manager service for managing transactions between a partition and a client,

wherein at least one network domain further comprises;

a first steward service for managing primary keys (PKs) associated with a first entity type and a second steward service for managing primary keys (PKs) associated with a second entity type.

46. A system for managing data as a shared asset among clients in an enterprise comprising:

a plurality of enterprise data resources, at least some of said plurality of enterprise data resources being partitioned into identifiable partitions;

an enterprise repository for maintaining a first plurality of primary keys (PK)-partition maps for identifying a partition by a unique PK;

a steward service for managing PKs;

a plurality of enterprise network domains, wherein each network domain comprises a satellite service for maintaining a second plurality of PK-partition maps for identifying a partition by a unique PK; and

a transaction manager service for managing transactions between a partition and a client, wherein each of the steward, satellite or transaction manager services is operable to run in a container service, the container service being configured to execute on a generic host server.

47. A system for managing data as a shared asset among clients in an enterprise comprising:

a plurality of enterprise data resources, at least some of said plurality of enterprise data resources being partitioned into identifiable partitions;

an enterprise repository for maintaining a plurality of primary keys (PK)-partition maps for identifying a partition by a unique PK;

a steward service for managing PKs;

a plurality of enterprise network domains, wherein each network domain comprises a satellite service for maintaining a plurality of PK-partition maps for identifying a partition by a unique PK and wherein at least one network domain comprises a first steward service for managing primary keys (PKs) associated with a first entity type and a second steward service for managing primary keys (PKs) associated with a second entity type; and

a transaction manager service for managing transactions between a partition and a client; and

a domain registrar service in each of the plurality of enterprise network domains for maintaining a list of services running to the respective enterprise network domain.

48. A system for managing data as a shared asset among clients in an enterprise comprising:

a plurality of enterprise data resources, at least some of said plurality of enterprise data resources being partitioned into identifiable partitions;

an enterprise repository for maintaining a plurality of primary keys (PK)-partition maps for identifying a partition by a unique PK;

a steward service for managing PKs;

a plurality of enterprise network domains, wherein each network domain comprises a satellite service for maintaining a plurality of PK-partition maps for identifying a partition by a unique PK;

a transaction manager service for managing transactions between a partition and a client; and

a domain registrar service in each of the plurality of enterprise network domains for maintaining a list of services running to the respective enterprise network domain, wherein each of the steward, satellite or transaction manager services is operable to run in a container service, which in turn is configured to execute on a generic host server.