Data synchronization in a cloud infrastructure

• US 9,015,114 B2
• Filed: 03/15/2013
• Issued: 04/21/2015
• Est. Priority Date: 09/07/2012
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Chatterjee, Ramkrishna, Vasudevan, Ramesh, Prathipati, Anjani Kalyan, Arun, Gopalan
• Primary Examiner(s): Coby, Frantz
• Application Number:
  US13/842,833
• Publication Number:
  US 20140074788A1
• Time in Patent Office: 767 Days
• Field of Search: 707610-613, 707/617, 707/620, 709/204, 713/400, 717/177
• US Class Current: 707/610
• CPC Class Codes: G06F 16/122 using management policies backup systems G06F11/1446; file migration policies for HSM systems G06F16/185
• CPC Class Codes: G06F 16/178 Techniques for file synchronisation in file systems
• CPC Class Codes: G06F 16/2282 Tablespace storage structures; Management thereof
• CPC Class Codes: G06F 16/2308 Concurrency control transaction processing G06F9/466
• CPC Class Codes: G06F 16/2365 Ensuring data consistency and integrity
• CPC Class Codes: G06F 16/27 Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
• CPC Class Codes: G06F 16/273 Asynchronous replication or reconciliation
• CPC Class Codes: G06F 16/283 Multi-dimensional databases or data warehouses, e.g. MOLAP or ROLAP
• CPC Class Codes: G06F 16/284 Relational databases
• CPC Class Codes: G06Q 10/06315 Needs-based resource requirements planning or analysis
• CPC Class Codes: G06Q 10/0633 Workflow analysis
• CPC Class Codes: G06Q 30/0633 Lists, e.g. purchase orders, compilation or processing
• CPC Class Codes: G06Q 30/0635 Processing of requisition or of purchase orders
• CPC Class Codes: H04L 41/00 Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
• CPC Class Codes: H04L 41/0686 Additional information in the notification, e.g. enhancement of specific meta-data
• CPC Class Codes: H04L 41/50 Network service management, e.g. ensuring proper service fulfilment according to agreements
• CPC Class Codes: H04L 41/5041 characterised by the time relationship between creation and deployment of a service
• CPC Class Codes: H04L 41/5054 Automatic deployment of services triggered by the service manager, e.g. service implementation by automatic configuration of network components
• CPC Class Codes: H04L 41/5064 Customer relationship management
• CPC Class Codes: H04L 43/0876 Network utilisation, e.g. volume of load or congestion level
• CPC Class Codes: H04L 47/70 : Admission control; Resource allocation
• CPC Class Codes: H04L 63/10 : for controlling access to devices or network resources
• CPC Class Codes: H04L 63/20 : for managing network security; network security policies in general filtering policies H04L63/0227
• CPC Class Codes: H04L 67/10 : in which an application is distributed across nodes in the network software deployment G06F8/60; multiprogramming arrangements G06F9/46

Abstract

A synchronization infrastructure that synchronizes data stored between components in a cloud infrastructure system is described. A first component in the cloud infrastructure system may store subscription information related to a subscription order which may in turn be utilized by a second component in the cloud infrastructure system to orchestrate the provisioning of services and resources for the order placed by the customer. The synchronization architecture utilizes transactionally consistent checkpoints that describe the state of the data stored in the components to synchronize the data between these components.

Claims

1. A method comprising:

storing, by a first computing device of one or more computing devices comprising a cloud infrastructure system, a subscription order related to one or more services subscribed to by a customer, the service selected from one or more services provided by the cloud infrastructure system;

identifying, by the first computing device, one or more rows in a first data table having one or more checkpoint numbers that are greater than a first checkpoint number;

identifying, by the first computing device, from the one or more identified rows, a row with the maximum checkpoint number;

storing, by the first computing device, the maximum checkpoint number; and

transferring, by the first computing device, the one or more identified rows to a second computing device in the cloud infrastructure system, wherein information in the one or more identified rows is utilized by the second computing device to process the subscription order for the customer in the cloud infrastructure system.

2. The method of claim 1 wherein the one or more checkpoint numbers are identifiers that identity a state of data stored by the first computing device.

3. The method of claim 1 wherein identifying the one or more rows in the first data table comprises determining if the one or more checkpoint numbers in the one or more rows have changed with respect to a run time stored in the first computing device.

4. The method of claim 3, wherein the run time identifies a time at which a last data synchronization operation was executed in the first computing device.

5. The method of claim 1 wherein transferring the one or more identified rows comprises transferring a new run number and a new run time related to the one or more identified rows to the second computing device.

6. The method of claim 1 further comprising receiving, by the second computing device, the one or more identified rows from the first computing device, wherein the one or more identified rows comprise a new run number and a new run time.

7. The method of claim 6 further comprising updating, by the second computing device, in a first interface table in the second computing device, the one or more identified rows, the new run number and the new run time.

8. A system comprising:

one or more computing devices configurable to provide one or more services;

a memory configurable to store subscription order information related to a subscription order ordering one or more services from the set of services; and

wherein a first computing device from the one or more computing devices is configurable to;

identify one or more rows in a first data table having one or more checkpoint numbers that are greater than a first checkpoint number;

identify from the one or more identified rows, a row with the maximum checkpoint number;

store the maximum checkpoint number; and

transfer the one or more identified rows to a second computing device from the one or more computing devices, wherein information in the one or more identified rows is utilized by the second computing device to process the subscription order for the customer in the cloud infrastructure system.

9. The system of claim 8 wherein the first computing device is configured to identify the one or more rows in the first data table by determining if the one or more checkpoint numbers in the one or more rows have changed with respect to a run time stored in the first computing device.

10. The system of claim 9, wherein the run time identifies a time at which a last data synchronization operation was executed in the first computing device.

11. The system of claim 8 wherein the first computing device is configured to transfer the one or more identified rows by transferring a new run number and a new run time related to the one or more identified rows to the second computing device.

12. The system of claim 8 wherein the second computing device is configured to receive the one or more identified rows from the first computing device, wherein the one or more identified rows comprise a new run number and a new run time and update in a first interface table in the second computing device, the one or more identified rows, the new run number and the new run time.

13. The system of claim 12 wherein the second computing device is configured to identify one or more rows in one or more interface tables having a run number greater than a first run number recorded in a runs table for the first interface table in the second computing device.

14. The system of claim 13 wherein the second computing device is configured to identify a run number with the maximum value and store the run number with the maximum value in the runs table.

15. A computer-readable memory storing a plurality of instructions executable by one or more processors, the plurality of instructions comprising:

instructions that cause at least one processor from the one or more processors to store subscription order information related to a subscription order ordering one or more services from a set of services;

instructions that cause at least one processor from the one or more processors to identify one or more rows in a first data table having one or more checkpoint numbers that are greater than a first checkpoint number;

instructions that cause at least one processor from the one or more processors to identify from the one or more identified rows, a row with the maximum checkpoint number;

instructions that cause at least one processor from the one or more processors to store the maximum checkpoint number; and

instructions that cause at least one processor from the one or more processors to transfer the one or more identified rows to a second computing device, wherein information in the one or more identified rows is utilized by the second computing device to process the subscription order for the customer.

16. The computer-readable memory of claim 15 wherein the one or more checkpoint numbers are identifiers that identity a state of data stored by the first computing device.

17. The computer-readable memory of claim 15 wherein the instructions that cause at least one processor from the one or more processors to identify the one or more rows in the first data table comprise instructions to determine if the one or more checkpoint numbers in the one or more rows have changed with respect to a run time stored in a first computing device.

18. The computer-readable memory of claim 17 wherein the run time identifies a time at which a last data synchronization operation was executed in the first computing device.

19. The computer-readable memory of claim 15 wherein the instructions that cause at least one processor from the one or more processors to transfer the one or more identified rows comprise instructions to transfer a new run number and a new run time related to the one or more identified rows to the second computing device.

20. The computer-readable memory of claim 15 wherein the instructions comprise instructions to receive, by the second computing device, the one or more identified rows from a first computing device, wherein the one or more identified rows comprise a new run number and a new run time.