公开(公告)号：US20230239345A1

公开(公告)日：2023-07-27

申请号：US18194583

申请日：2023-03-31

Applicant: Amazon Technologies, Inc.

Inventor： Benjamin Warren Mercier ,  Sayantan Chakravorty ,  Yasemin Avcular ,  Charlie Paucard

IPC: H04L67/1029 ,  G06F16/28

CPC classification number: H04L67/1029 ,  G06F16/285

Abstract: In response to a first programmatic request, metadata indicating that a first isolated read channel of a real-time category has been associated with a first target stream is stored at a stream management service. In response to another request, metadata indicating that a second isolated read channel of a non-real-time category has been associated with a second target stream is stored. In response to a read request indicating the first channel or the second channel, one or more data records of the corresponding target streams are provided.

公开(公告)号：US11025691B1

公开(公告)日：2021-06-01

申请号：US15821692

申请日：2017-11-22

Applicant: Amazon Technologies, Inc.

Inventor： Gaurav D. Ghare ,  Vijay Gopal Joshi ,  Sayantan Chakravorty ,  Babu Prasad Dhandapani

IPC: H04L29/06

Abstract: Disclosed are various embodiments for consuming fragments of time-associated data streams. A streaming gateway receives a request from a consumer via a network to obtain a stream of time-associated data. The gateway determines that a first fragment of the stream of time-associated data is stored in a data store. The first fragment is obtained from the data store and sent to the consumer via the network. The gateway determines that the stream of time-associated data is currently being received by an endpoint from a producer. A second segment of the stream is obtained from the endpoint and sent to the consumer via the network.

公开(公告)号：US10944804B1

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

申请号：US15821673

申请日：2017-11-22

Applicant: Amazon Technologies, Inc.

Inventor： Gaurav D. Ghare ,  Sayantan Chakravorty ,  Mushegh Malkhasyan ,  Vijay Gopal Joshi ,  Duc Viet Nguyen ,  Artem Kryvokrysenko ,  Mitchell Ross Loeppky

IPC: H04L29/06 ,  H04N21/4402 ,  H04L29/08 ,  H04L12/26

Abstract: Disclosed are various embodiments for fragmentation of time-associated streaming data. A producer application receives a stream of time-associated data. The producer application then generates a first fragment of the stream of time-associated data and assigns a first unique fragment identifier and a first timestamp to the first fragment. The producer application sends the first fragment via a network using an application-layer protocol to an endpoint. The producer application receives at least one acknowledgement for the first fragment from the endpoint via the network using the application-layer protocol.

公开(公告)号：US10423459B1

公开(公告)日：2019-09-24

申请号：US15275302

申请日：2016-09-23

Applicant: Amazon Technologies, Inc.

Inventor： Christopher Richard Jacques de Kadt ,  Benjamin Warren Mercier ,  Carlos Vara Callau ,  Timothy Daniel Cole ,  Aaron Gifford Freshwater ,  Sayantan Chakravorty ,  Allan Henry Vermeulen

IPC: G06F9/46 ,  G06F9/50

Abstract: A resource manager arranges the resources in a computer system into one or more resource pools. The resource manager allocates a number of active resources and a number of backup resources to a particular resource pool. For each resource managed by the resource manager, the resource manager acquires information that describes the capacity and reliability of the resource. Capacity and reliability information for the particular resource pool is determined based on the capacity and reliability information associated with the resources assigned to the pool. In response to a request, the resource manager may provide an application with resources from several resource pools. The likelihood that the resource manager will be able to provide sufficient resources to the application may be determined based at least in part on the reliability information associated with the several resource pools.

公开(公告)号：US10346366B1

公开(公告)日：2019-07-09

申请号：US15275307

申请日：2016-09-23

Applicant: Amazon Technologies, Inc.

Inventor： Christopher Richard Jacques de Kadt ,  Benjamin Warren Mercier ,  Carlos Vara Callau ,  Timothy Daniel Cole ,  Aaron Gifford Freshwater ,  Sayantan Chakravorty ,  Allan Henry Vermeulen

IPC: G06F16/18 ,  G06F16/23 ,  H04L12/18

Abstract: A pipeline management service improves the operation of a processing pipeline by monitoring the operation of one or more journal services within the processing pipeline, and adjusting operational parameters of the one or more journal services. In various examples, the pipeline management service determines a model of the processing pipeline by identifying the producers and consumers associated with each of the one or more journal services, and determines a processing flow through the one or more journal services based at least in part on the identities of the associated producers and consumers. The pipeline management service acquires backlog information from each of the one or more journal services, and may adjust the operational parameters of a journal service associated with an identified processing bottleneck. In some examples, the pipeline management service adjusts capacity and reliability parameters of the one or more journal services to improve the operation of the processing pipeline.