公开(公告)号：US12079206B2

公开(公告)日：2024-09-03

申请号：US18091313

申请日：2022-12-29

Applicant: Salesforce, Inc.

Inventor： Narsimha Reddy Challa ,  Swaroop Jayanthi ,  Komalapriya J ,  Ramalinga Raju Kalidindi

IPC: G06F16/23 ,  G06F16/27

CPC classification number: G06F16/2386 ,  G06F16/273

Abstract: An online system performs replication of database from one system to another. A source database is replicated to a target database by performing an initial bulk copy followed by repeated change data capture. The system performs batching to group events generated by the change data capture events. The system performs a multi-constrained analysis to determine when a batch is ready for sending. The system uses multiple buffers for transmitting events to decouple the receiving and sending of events. The online system may be a multi-tenant system the source and target databases stores data of tenants. The system determines a tenant score to adjust the resources allocated during event transfer. The system splits an event into partial events, to avoid dependency between the partial events so that tasks can be executed independent of each other. Therefore, the system performs replication with reduced synchronization overhead.

公开(公告)号：US20240220484A1

公开(公告)日：2024-07-04

申请号：US18091313

申请日：2022-12-29

Applicant: Salesforce, Inc.

Inventor： Narsimha Reddy Challa ,  Swaroop Jayanthi ,  Komalapriya ,  Raju Kalidindi

IPC: G06F16/23 ,  G06F16/27

CPC classification number: G06F16/2386 ,  G06F16/273

Abstract: An online system performs replication of database from one system to another. A source database is replicated to a target database by performing an initial bulk copy followed by repeated change data capture. The system performs batching to group events generated by the change data capture events. The system performs a multi-constrained analysis to determine when a batch is ready for sending. The system uses multiple buffers for transmitting events to decouple the receiving and sending of events. The online system may be a multi-tenant system the source and target databases stores data of tenants. The system determines a tenant score to adjust the resources allocated during event transfer. The system splits an event into partial events, to avoid dependency between the partial events so that tasks can be executed independent of each other. Therefore, the system performs replication with reduced synchronization overhead.

公开(公告)号：US20240256250A1

公开(公告)日：2024-08-01

申请号：US18104092

申请日：2023-01-31

Applicant: Salesforce, Inc.

Inventor： Naga Venkata Durga Rao Bokka ,  Swaroop Jayanthi ,  Hemanth Siddulugari

IPC: G06F8/65

CPC classification number: G06F8/65

Abstract: The system performs optimized upgrades for datacenters configured on a cloud platform. The optimized upgrade process combines upgrades of operating system and services on a node of a cluster of machines of the cloud platform. The system detects a service version change and operating system version change. If the system detects the version change for both a service and the operating system for a node, the system orchestrates the upgrade process for both service and operating system at the same time. The system restarts the node and service once the upgrade completes. This reduces the multiple restarts of the node/services thereby improving the availability of the system for clients.

公开(公告)号：US20240220478A1

公开(公告)日：2024-07-04

申请号：US18090461

申请日：2022-12-28

Applicant: Salesforce, Inc.

Inventor： Sai Rama Raju Alluru ,  Swaroop Jayanthi

IPC: G06F16/23 ,  G06F16/27

CPC classification number: G06F16/2365 ,  G06F16/2386 ,  G06F16/275

Abstract: A system generates consistent copies of data stored in a source database in a plurality of target database systems. The system sends a change data stream from the source database system to the target database systems for performing data updates. The system receives timestamps of a latest transactions processed by consumer processes updating the target database system. The system determines a pause timestamp that occurs after the received transactions. The updates to the target database systems are paused once a transaction corresponding to the pause timestamp is processed. The pause timestamp is used to generate a consistent copy of a source database system in a target database system using multiple partitioned change data streams, each partitioned change data stream processing transactions associated with a partition of the source database system.