公开(公告)号：US11714732B1

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

申请号：US17038212

申请日：2020-09-30

Applicant: Amazon Technologies, Inc.

Inventor： Jacob Wires ,  Julien Mascart ,  Valeri Atamaniouk ,  Jun Dai ,  Sidharth Bajaj ,  Wesley Shawn Davis

IPC: G06F11/20 ,  G06F11/34 ,  G06F9/48 ,  H04L45/021 ,  G06F11/07

CPC classification number: G06F11/2074 ,  G06F9/4887 ,  G06F11/0715 ,  G06F11/3409 ,  H04L45/021 ,  G06F2201/855

Abstract: Sets of asynchronous replication operations may be tracked to ensure consistency. A tracking service may receive notifications of pending asynchronous replication tasks, and responsive to receiving a manifest indicating a request to be notified upon completion of a set of pending replication asynchronous tasks, matches individual ones of the tasks within the set to tasks indicated as pending. The tracking service may then select a routing table based on a most recent sequence number associated with the set of tasks, determine one of more tracking nodes assigned to track the set of tasks, and send the manifest to each of the tracking nodes. As individual ones of the tasks complete, notifications of completion may be sent to the tracking nodes and an aggregator node aggregates the completion notifications for the set. Once all completion notifications are received, a response to the request indicating completion may be sent.

公开(公告)号：US11233738B1

公开(公告)日：2022-01-25

申请号：US16917689

申请日：2020-06-30

Applicant: Amazon Technologies, Inc.

Inventor： Jacob Wires ,  Yuri Zarubin ,  Leon Thrane ,  Zhiyuan Lin ,  Nikolaos Koutsikos Tsatsalmas ,  Marcin Marek Wolicki ,  Valeri Atamaniouk ,  Ming Yiu Andy Siu ,  Sidharth Bajaj

IPC: H04L12/803 ,  H04L12/24 ,  H04L12/851 ,  H04L12/26 ,  H04L12/825

Abstract: The performance of asynchronous tasks may be dynamically configured. An evaluation of pending tasks that includes updates for new tasks and completed tasks being removed is performed. A target capacity for the data traffic workflow is determined from the evaluation of pending tasks in order to satisfy a performance requirement for the data traffic workflow. Modifications to a performance configuration for the data traffic workflow are then made based on a comparison with the target capacity.

公开(公告)号：US11522799B1

公开(公告)日：2022-12-06

申请号：US16917679

申请日：2020-06-30

Applicant: Amazon Technologies, Inc.

Inventor： Nikolaos Koutsikos Tsatsalmas ,  Jacob Wires ,  Marcin Marek Wolicki ,  Jingmin Zhu ,  Yuri Zarubin ,  Leon Thrane ,  Sidharth Bajaj ,  Valeri Atamaniouk

IPC: H04L47/125 ,  H04L47/2441 ,  H04L41/0604 ,  H04L47/50 ,  H04L47/2483

Abstract: Dynamic management of data traffic workflows is performed. An event to perform a data traffic workflow at a remote performance location may be received. Computing resources to perform the data traffic workflow may be identified. Operations to perform the data traffic workflow may be dynamically directed by the identified computing resources to adaptively balance performance of the operations with operations for other data traffic workflows in order to meet respective performance requirements of the data traffic workflows.

公开(公告)号：US11275608B1

公开(公告)日：2022-03-15

申请号：US16002229

申请日：2018-06-07

Applicant: Amazon Technologies, Inc.

Inventor： Vignesh Natarajan ,  Shreyas Yagna ,  Wesley Shawn Davis ,  Henry A. Spang ,  Sidharth Bajaj ,  Sumit Kumar ,  Jared Alan Bergman ,  Tejal Borkar ,  Dmytro Sukhariev

IPC: G06F9/46 ,  G06F9/48 ,  G06F9/50

Abstract: Methods, systems, and computer-readable media for scalable job transformation and management are disclosed. A plurality of tasks expressed in a first format are received at a host. The tasks are associated with a shard identifier based at least in part on one or more criteria, and the tasks are acquired by the host based at least in part on the shard identifier. A subset of the tasks having a common characteristic are determined. The subset of the tasks are aggregated into a job expressed in a second format, where the job represents the subset of the tasks. The job is provided to a job manager, and the subset of the tasks are scheduled for processing using the job manager.