Making a copy of a profile store while processing live updates

• US 10,409,780 B1
• Filed: 10/30/2015
• Issued: 09/10/2019
• Est. Priority Date: 10/30/2015
• Status: Active Grant

• Current Assignee: Intuit, Inc.
• Original Assignee: Intuit, Inc.
• Inventors: Ullrich, Tobias, Pfannenschmidt, Lars, Wisniewski, Frank, Lita, Lucian V., Gardner, Brian W., Kruger, Thorsten
• Primary Examiner(s): Syed, Farhan M
• Application Number:
  US14/928,816
• Time in Patent Office: 1,411 Days
• Field of Search: None
• CPC Class Codes: G06F 16/128 Details of file system snapshots on the file-level, e.g. snapshot creation, administration, deletion use of snapshots for error detection or correction G06F11/14, G06F11/16
• CPC Class Codes: G06F 16/178 Techniques for file synchronisation in file systems
• CPC Class Codes: G06F 16/2358 Change logging, detection, and notification replication G06F16/27
• CPC Class Codes: G06F 16/337 Profile generation, learning or modification

Abstract

The disclosed embodiments relate to a system that facilitates making a copy of a profile store while the profile store is being updated. During operation, the system retrieves profiles from a profile snapshot queue, wherein the profile snapshot queue is periodically populated by accessing each profile in the profile store, and recording a snapshot of each accessed profile in the profile snapshot queue. The system then stores the profiles retrieved from the profile snapshot queue into the copy of the profile store. Next, the system retrieves updates to profiles from a live update queue, which contains a sequential list of updates to profiles in the profile store, wherein the updates are retrieved starting with a first update that occurred after the process of sequentially accessing the profiles was commenced up to a most recent update. Finally, the system uses the retrieved updates to update corresponding profiles in the copy of the profile store.

Claims

1. A method for making a copy of a profile store while the profile store is being updated, comprising:

accessing periodically each profile in a first profile store;

recording a profile snapshot of each accessed profile to a profile snapshot queue;

retrieving a plurality of profile snapshots from the profile snapshot queue;

storing the retrieved plurality of profile snapshots from the profile snapshot queue into a second profile store;

retrieving a subset of profile updates from a first live update queue, wherein;

each profile update in the retrieved subset of profile updates corresponds to one profile snapshot of the plurality of profile snapshots stored in the second profile store; and

each profile update in the retrieved subset of profile updates occurred after its corresponding profile snapshot was recorded in the profile snapshot queue;

updating the plurality of profile snapshots in the second profile store with the subset of profile updates; and

keeping the second profile store up to date after a most recent update has been applied to the second profile store by applying subsequent updates from the first live update queue to corresponding profile snapshots in the second profile store.

2. The method of claim 1, wherein the first profile store includes:

personal profiles containing personal attributes associated with people;

or

organizational profiles containing organizational attributes associated with organizations.

3. The method of claim 1, further comprising:

decreasing a period between each profile access in the first profile store during lightly loaded periods for an underlying computer system; and

increasing the period between each profile access in the first profile store during heavily loaded periods for the underlying computer system.

4. The method of claim 1, further comprising:

retrieving updates from a second live update queue,

wherein the first live update queue is associated with a first topic, and

wherein the second live update queue is associated with a second topic.

5. The method of claim 4, further comprising:

entering a profile update of the subset of profile updates into one of the first live update queue or the second live update queue.

6. The method of claim 4, further comprising:

receiving a request to subscribe to one of the first live update queue or the second live update queue.

19. The method of claim 1, wherein accessing periodically each profile in the first profile store comprises:

decrypting each profile with at least a private key and a symmetric key associated with the profile,

wherein the symmetric key associated with the profile is stored in a header of the profile.

20. The method of claim 19, wherein storing the retrieved plurality of profile snapshots from the profile snapshot queue into the second profile store comprises:

encrypting each respective profile snapshot using the symmetric key associated with the profile;

encrypting the symmetric key associated with the profile using a public key; and

storing the encrypted symmetric key in the header of the profile.

7. A non-transitory computer-readable storage medium storing instructions that when executed by a computer cause the computer to perform a method for making a copy of a profile store while the profile store is being updated, the method comprising:

accessing periodically each profile in a first profile store;

recording a profile snapshot of each accessed profile to a profile snapshot queue;

retrieving a plurality of profile snapshots from the profile snapshot queue;

storing the retrieved plurality of profile snapshots from the profile snapshot queue into a second profile store;

retrieving a subset of profile updates from a first live update queue, wherein;

each profile update in the retrieved subset of profile updates corresponds to one profile snapshot of the plurality of profile snapshots stored in the second profile store; and

each profile update in the retrieved subset of profile updates occurred after its corresponding profile snapshot was recorded in the profile snapshot queue;

updating the plurality of profile snapshots in the second profile store with the subset of profile updates, and

keeping the second profile store up to date after a most recent update has been applied to the second profile store by applying subsequent updates from the first live update queue to corresponding profile snapshots in the second profile store.

8. The non-transitory computer-readable storage medium of claim 7, wherein the first profile store includes:

personal profiles containing personal attributes associated with people;

or

organizational profiles containing organizational attributes associated with organizations.

9. The non-transitory computer-readable storage medium of claim 7, wherein the method further comprises:

decreasing a period between each profile access in the first profile store during lightly loaded periods for an underlying computer system; and

increasing the period between each profile access in the first profile store during heavily loaded periods for the underlying computer system.

10. The non-transitory computer-readable storage medium of claim 7, wherein the method further comprises:

retrieving updates from a second live update queue,

wherein the first live update queue is associated with a first topic, and

wherein the second live update queue is associated with a second topic.

11. The non-transitory computer-readable storage medium of claim 10, wherein the method further comprises:

entering a profile update of the subset of profile updates into one of the first live update queue or the second live update queue.

12. The non-transitory computer-readable storage medium of claim 10, wherein the method further comprises:

receiving a request to subscribe to one of the first live update queue or the second live update queue.

21. The non-transitory computer-readable storage medium of claim 7, wherein accessing periodically each profile in the first profile store comprises:

decrypting each profile with at least a private key and a symmetric key associated with the profile,

wherein the symmetric key associated with the profile is stored in a header of the profile.

22. The non-transitory computer-readable storage medium of claim 21, wherein storing the retrieved plurality of profile snapshots from the profile snapshot queue into the second profile store comprises:

encrypting each respective profile snapshot using the symmetric key associated with the profile;

encrypting the symmetric key associated with the profile using a public key; and

storing the encrypted symmetric key in the header of the profile.

13. A system that facilitates making a copy of a profile store while the profile store is being updated, comprising:

at least one processor; and

at least one memory comprising computer-executable instructions, wherein the at least one processor is configured to execute the computer-executable instructions and cause the system to perform a method, the method comprising;

accessing periodically each profile in a first profile store;

recording a profile snapshot of each accessed profile to a profile snapshot queue;

retrieving a plurality of profile snapshots from the profile snapshot queue;

storing the retrieved plurality of profile snapshots from the profile snapshot queue into a second profile store;

retrieving a subset of profile updates from a first live update queue, wherein;

each profile update in the retrieved subset of profile updates corresponds to one profile snapshot of the plurality of profile snapshots stored in the second profile store; and

each profile update in the retrieved subset of profile updates occurred after its corresponding profile snapshot was recorded in the profile snapshot queue;

updating the plurality of profile snapshots in the second profile store with the subset of profile updates; and

keeping the second profile store up to date after a most recent update has been applied to the second profile store by applying subsequent updates from the first live update queue to corresponding profile snapshots in the second profile store.

14. The system of claim 13, wherein the first profile store includes:

personal profiles containing personal attributes associated with people;

or

organizational profiles containing organizational attributes associated with organizations.

15. The system of claim 13, wherein the method further comprises:

decreasing a period between each profile access in the first profile store during lightly loaded periods for an underlying computer system; and

increasing the period between each profile access in the first profile store during heavily loaded periods for the underlying computer system.

16. The system of claim 13, wherein the method further comprises:

retrieving updates from a second live update queue,

wherein the first live update queue is associated with a first topic, and

wherein the second live update queue is associated with a second topic.

17. The system of claim 16, wherein the method further comprises:

entering a profile update of the subset of profile updates into one of the first live update queue or the second live update queue.

18. The system of claim 16, wherein the method further comprises:

receiving a request to subscribe to one of the first live update queue or the second live update queue.

23. The system of claim 13, wherein accessing periodically each profile in the first profile store further comprises:

decrypting each profile with at least a private key and a symmetric key associated with the profile,

wherein the symmetric key associated with the profile is stored in a header of the profile.

24. The system of claim 23, wherein storing the retrieved plurality of profile snapshots from the profile snapshot queue into the second profile store comprises:

encrypting each respective profile snapshot using the symmetric key associated with the profile;

encrypting the symmetric key associated with the profile using a public key; and

storing the encrypted symmetric key in the header of the profile.