公开(公告)号：US11194815B1

公开(公告)日：2021-12-07

申请号：US16273006

申请日：2019-02-11

Applicant: Amazon Technologies, Inc.

Inventor： Ankit Kumar ,  Alazel Acheson ,  Matthew William Berry ,  Ankul Rastogi ,  Amit Sahasrabudhe

IPC: G06F16/2455 ,  G06F9/50 ,  G06F16/2453 ,  G06F16/9038 ,  G06F16/901

Abstract: Service interruptions in a multi-tenancy, network-based storage system can be mitigated by constraining the execution of queries. In various examples, a network-based storage system may receive a request to execute a query against data maintained by the network-based storage system. The network-based storage system may perform a unit of work to execute the query, progressing through some, but not all, of a set of operations that are to be completed for completing execution of the query. Upon completion of the unit of work, query execution may be paused, query state data may be saved, and query results may be generated for consumption by the requesting computing device. In some embodiments, tokens that are usable to resume query execution based on the saved query state data may be sent to customer computing devices for resuming query execution on-demand.

公开(公告)号：US10187251B1

公开(公告)日：2019-01-22

申请号：US15262752

申请日：2016-09-12

Applicant: Amazon Technologies, Inc.

Inventor： Raghunathan Kothandaraman ,  Mark Aran Aiken ,  Sasanka Rajaram ,  Deep Dixit ,  Gaurav Gupta ,  Ankit Kumar ,  Dhaval Parmar

IPC: H04L12/24 ,  H04L29/08

Abstract: Disclosed are various embodiments for event processing architecture for real-time user engagement. Events that describe user interactions with client applications are analyzed in real-time when received in a data stream. The events are compared to patterns specified, for example, by administrators. If a pattern is matched based on a comparison to events received in the data stream, a predetermined action may be performed. The processing of events may be performed by a compute engine, which may include a virtual machine or a thread implemented in a parallel computing arrangement.

公开(公告)号：US11943385B1

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

申请号：US16917587

申请日：2020-06-30

Applicant: Amazon Technologies, Inc.

Inventor： Ankit Kumar ,  Iulian Catalin Stafie ,  Lisa A Winn ,  Marius Popa ,  Jamie Layne White ,  Dennis Ono Tjandra

IPC: H04M15/00

CPC classification number: H04M15/50 ,  H04M15/58 ,  H04M15/60 ,  H04M15/8214 ,  H04M15/886

Abstract: Cross-service usage is dynamically enforced for different network-based services. A cross-service control system may accept requests to specify a usage quota for a client for an interface of a network-based service. A rule to enforce the usage quota may be distributed to request handling nodes for the service. Usage measurements may be collected from the request handling nodes for requests received from the client via the interface. An update to the usage quota may be determined from an evaluation of the usage measurements. The rule at the request handling nodes may be updated to enforce the updated usage quota.

公开(公告)号：US10897468B1

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

申请号：US16217419

申请日：2018-12-12

Applicant: Amazon Technologies, Inc.

Inventor： Jasmeet Chhabra ,  Ankit Kumar ,  Dan Popick

IPC: G06F7/04 ,  H04L29/06 ,  H04L9/32 ,  H04L9/08 ,  G06F16/909 ,  H04L29/08 ,  G06F9/50 ,  G06F3/0482 ,  H04L12/24 ,  G06F16/901 ,  G06F15/16

Abstract: Techniques for region management for distributed services in provider networks are described. A region management service (RMS) receives requests to enable or disable regions a provider network for users. The RMS identifies what services operate within the involved regions and transmits requests to configure resources within the regions that are specific to the users to the services. The RMS also receives messages indicating whether the transmitting services have successfully configured user resources pertaining to the services for the region.

公开(公告)号：US11947516B1

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

申请号：US15902222

申请日：2018-02-22

Applicant: Amazon Technologies, Inc.

Inventor： Ankit Kumar ,  Alazel Acheson ,  Jasmeet Chhabra ,  Luke Edward Kennedy ,  Daniel Stephen Popick ,  Weixun Wang

IPC: G06F16/23 ,  G06F16/185 ,  G06F16/21 ,  G06F16/22 ,  G06F16/27

CPC classification number: G06F16/23 ,  G06F16/185 ,  G06F16/211 ,  G06F16/22 ,  G06F16/27

Abstract: The updating of a definition layer or schema for a large distributed database can be accomplished using a plurality of data store tiers. A distributed database can be made up of many individual data stores, and these data stores can be allocated across a set of tiers based on business logic or other allocation criteria. The update can be applied sequentially to the individual tiers, such that only data stores for a single tier are being updated at any given time. This can help to minimize downtime for the database as a whole, and can help to minimize problems that may result from an unsuccessful update. Such an approach can also allow for simplified error detection and rollback, as well as providing control over a rate at which the update is applied to the various data stores of the distributed database.

公开(公告)号：US11838357B1

公开(公告)日：2023-12-05

申请号：US17388660

申请日：2021-07-29

Applicant: Amazon Technologies, Inc.

Inventor： Ankit Kumar ,  Dan Popick ,  Sandesh Sanjeev ,  Meng Li ,  David Michael Hulme

IPC: H04L67/1025 ,  H04L67/1014 ,  H04L67/1029

CPC classification number: H04L67/1014 ,  H04L67/1025 ,  H04L67/1029

Abstract: Techniques for incremental stream switching in a distributed system with flip events are described. A special-purpose flip event is inserted into an event stream that indicates, to recipients of the stream, whether they are to switch to use of an alternate event stream. The flip event may identify which other event stream to use, how to obtain events of that event stream, when to switch to the other event stream, and/or whether that particular recipient is to switch. The recipients may be selectively or iteratively migrated using flip events targeting different recipients, limiting the blast radius of a switch. Via use of a tracking data structure, event replay and event skips can be avoided.

公开(公告)号：US11620194B1

公开(公告)日：2023-04-04

申请号：US17362463

申请日：2021-06-29

Applicant: Amazon Technologies, Inc.

Inventor： Sharad Sridhar ,  Sandesh Sanjeev ,  Ankit Kumar ,  Munjal Doshi ,  Rachit Jain

IPC: G06F11/07 ,  G06F11/20 ,  G06F9/54

Abstract: Features are disclosed for managing multiple hosts that stream sequential data to nodes for propagation. The hosts can include a primary host and a failover host that each store a replica of the sequential data. A computing device can monitor the hosts and identify the occurrence of a failover event for the primary host. For example, the computing device may determine the schema has been modified. The computing device can further determine to failover to the failover host based on the failover event. The computing device can insert a flip task into the stream of sequential data for the primary host. The insertion of the flip task may be automatic. Further, each node reading from the stream of sequential data for the primary host may encounter the flip task and failover to the failover host at the same logical position but a different absolute position.

公开(公告)号：US10331693B1

公开(公告)日：2019-06-25

申请号：US15262744

申请日：2016-09-12

Applicant: Amazon Technologies, Inc.

Inventor： Raghunathan Kothandaraman ,  Deep Dixit ,  Gaurav Gupta ,  Sasanka Rajaram ,  Ankit Kumar ,  Mark Aran Aiken ,  Dhaval Parmar

IPC: G06F16/25 ,  G06F16/84 ,  G06F16/21

Abstract: Disclosed are various embodiments for filters and event schema for categorizing and processing streaming event data. An event may be generated by a service that describes user interaction a client application executable on a client device. The event may be received as a data structure in a first format. A filter, such as a regular expression filter, may be applied to the data structure to identify an event type for the event. The data structure may be converted from the first format to a second format in accordance with a common event schema able to be interpreted by virtual compute engines.

公开(公告)号：US11841861B1

公开(公告)日：2023-12-12

申请号：US17543447

申请日：2021-12-06

Applicant: Amazon Technologies, Inc.

Inventor： Ankit Kumar ,  Alazel Acheson ,  Matthew William Berry ,  Ankul Rastogi ,  Amit Sahasrabudhe

IPC: G06F16/2455 ,  G06F9/50 ,  G06F16/2453 ,  G06F16/9038 ,  G06F16/901

CPC classification number: G06F16/24565 ,  G06F9/505 ,  G06F16/24532 ,  G06F16/24561 ,  G06F16/9024 ,  G06F16/9038

Abstract: Service interruptions in a multi-tenancy, network-based storage system can be mitigated by constraining the execution of queries. In various examples, a network-based storage system may receive a request to execute a query against data maintained by the network-based storage system. The network-based storage system may perform a unit of work to execute the query, progressing through some, but not all, of a set of operations that are to be completed for completing execution of the query. Upon completion of the unit of work, query execution may be paused, query state data may be saved, and query results may be generated for consumption by the requesting computing device. In some embodiments, tokens that are usable to resume query execution based on the saved query state data may be sent to customer computing devices for resuming query execution on-demand.