公开(公告)号：US20170357703A1

公开(公告)日：2017-12-14

申请号：US15665103

申请日：2017-07-31

Applicant: Amazon Technologies, Inc.

Inventor： Marvin Michael Theimer ,  Gaurav D. Ghare ,  John David Dunagan ,  Gregory M. Burgess ,  Ying Xiong

IPC: G06F17/30

Abstract: A partitioning policy, comprising an indication of an initial mapping of data records of a stream to a plurality of partitions, is selected to distribute data records of a data stream among a plurality of nodes of a stream management service. Data ingestion nodes and storage nodes are configured according to the initial mapping. In response to a determination that a triggering criterion for dynamically repartitioning the data stream has been met, a modified mapping is generated, and a different set of ingestion and storage nodes are configured. For at least some time during which arriving data records are stored in accordance with the modified mapping, data records stored at the first set of storage nodes in accordance with the initial mapping are retained.

公开(公告)号：US11409796B1

公开(公告)日：2022-08-09

申请号：US16140243

申请日：2018-09-24

Applicant: Amazon Technologies, Inc.

Inventor： Mihir Sadruddin Surani ,  Roberto Pentz De Faria ,  Mohit Gupta ,  Yuxuan Liu ,  Leslie Johann Lamprecht ,  John Merrill Phillips ,  John David Dunagan ,  Malcolm Featonby

IPC: G06F16/00 ,  G06F16/901 ,  G06F21/62 ,  G06F16/23 ,  G06F16/907

Abstract: A database service that receives and manages time series data into a set of generational data tables. The database service generates a set of generational data tables configured to receive a subset of time series data. Each generational data table is created with an initial set of access parameters that facilitates the receipt of incoming time series data. Thereafter, the database service creates additional generational data tables to receive the continuous received time series data and then modifies the access parameters of the previously created data table, such as for read only rights.

公开(公告)号：US09858322B2

公开(公告)日：2018-01-02

申请号：US14077162

申请日：2013-11-11

Applicant: Amazon Technologies, Inc.

Inventor： Marvin Michael Theimer ,  Gaurav D. Ghare ,  John David Dunagan ,  Greg Burgess ,  Ying Xiong

IPC: G06F17/30 ,  G06F15/173 ,  G06F17/00

CPC classification number: G06F17/30563 ,  G06F17/30073

Abstract: A programmatic interface is implemented, enabling a client of a stream management service to select a data ingestion policy for a data stream. A client request selecting an at-least-once ingestion policy is received. In accordance with the at-least-once policy, a client may transmit an indication of a data record one or more times to the service until a positive acknowledgement is received. In response to receiving a plurality of transmissions indicating a particular data record, respective positive acknowledgements are sent to the client. Based on a persistence policy selected for the stream, copies of the data record are stored at one or more storage locations in response to one particular transmission of the plurality of transmissions.

公开(公告)号：US10884778B1

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

申请号：US16147405

申请日：2018-09-28

Applicant: Amazon Technologies, Inc.

Inventor： John David Dunagan ,  Mohit Gupta ,  Mihir Sadruddin Surani ,  Yuxuan Liu ,  Les Johann Lamprecht ,  John Merrill Phillips ,  Malcolm Featonby ,  Roberto Pentz De Faria ,  Erik Quanstrom ,  James Rigby ,  Ethan Faust ,  Wenbo Bu

IPC: H04L29/08 ,  H04M7/00 ,  G06F9/50 ,  H04L29/06 ,  G06F9/455

Abstract: Techniques for managing dynamically scalable virtualized compute instances within a provider network are described. A dynamically scalable instance has a baseline performance level and a maximum performance level associated with a computing resource, such as a processor, a memory, a network interface, etc. In response to receive a request to launch a dynamically scalable instance, one or more services select a computer system to host the requested instance from a pool of instance-hosting computer systems of a provider network. The instance-hosting computer systems include a monitoring agent that reports computing resource usage data to the one or more services. The one or more services monitor the resource usage of the instance-hosting computer systems and migrate instances so that the dynamically scalable instances can operate up to the maximum level of performance.

公开(公告)号：US10795905B2

公开(公告)日：2020-10-06

申请号：US15858480

申请日：2017-12-29

Applicant: Amazon Technologies, Inc.

Inventor： Marvin Michael Theimer ,  Gaurav D. Ghare ,  John David Dunagan ,  Gregory M. Burgess ,  Ying Xiong

IPC: G06F16/25 ,  G06F16/11

Abstract: A programmatic interface is implemented, enabling a client of a stream management service to select a data ingestion policy for a data stream. A client request selecting an at-least-once ingestion policy is received. In accordance with the at-least-once policy, a client may transmit an indication of a data record one or more times to the service until a positive acknowledgement is received. In response to receiving a plurality of transmissions indicating a particular data record, respective positive acknowledgements are sent to the client. Based on a persistence policy selected for the stream, copies of the data record are stored at one or more storage locations in response to one particular transmission of the plurality of transmissions.

公开(公告)号：US20180189367A1

公开(公告)日：2018-07-05

申请号：US15858480

申请日：2017-12-29

Applicant: Amazon Technologies, Inc.

Inventor： Marvin Michael Theimer ,  Gaurav D. Ghare ,  John David Dunagan ,  Greg Burgess ,  Ying Xiong

IPC: G06F17/30

CPC classification number: G06F16/254 ,  G06F16/113

Abstract: A programmatic interface is implemented, enabling a client of a stream management service to select a data ingestion policy for a data stream. A client request selecting an at-least-once ingestion policy is received. In accordance with the at-least-once policy, a client may transmit an indication of a data record one or more times to the service until a positive acknowledgement is received. In response to receiving a plurality of transmissions indicating a particular data record, respective positive acknowledgements are sent to the client. Based on a persistence policy selected for the stream, copies of the data record are stored at one or more storage locations in response to one particular transmission of the plurality of transmissions.

公开(公告)号：US09104392B1

公开(公告)日：2015-08-11

申请号：US13917595

申请日：2013-06-13

Applicant: Amazon Technologies, Inc.

Inventor： John David Dunagan ,  Derek Solomon Pai ,  Caitlyn Rose Shim ,  John W. Heitmann ,  Michael R. Foster

IPC: G06F17/30 ,  G06F7/24

CPC classification number: G06F17/30528

Abstract: Monitoring data can be received and managed in a multi-tenant environment. Monitoring data can be received for multiple tenants. The received monitoring data can be sorted. Sorting can be performed based on various criteria, such as by tenant. The sorted monitoring data can be written to data files. Each data file can store monitoring data for a plurality of tenants. Receiving, sorting, and writing monitoring data can be performed within a multi-tenant monitoring system.

Abstract translation: 监控数据可以在多租户环境中接收和管理。 可以为多个租户收到监控数据。 收到的监控数据可以进行排序。 可以根据各种标准进行排序，例如租户。 排序的监视数据可以写入数据文件。 每个数据文件可以存储多个租户的监视数据。 接收，分拣和写入监控数据可以在多租户监控系统内进行。

公开(公告)号：US10691716B2

公开(公告)日：2020-06-23

申请号：US15665103

申请日：2017-07-31

Applicant: Amazon Technologies, Inc.

Inventor： Marvin Michael Theimer ,  Gaurav D. Ghare ,  John David Dunagan ,  Gregory M. Burgess ,  Ying Xiong

IPC: G06F16/25 ,  G06F16/00

Abstract: A partitioning policy, comprising an indication of an initial mapping of data records of a stream to a plurality of partitions, is selected to distribute data records of a data stream among a plurality of nodes of a stream management service. Data ingestion nodes and storage nodes are configured according to the initial mapping. In response to a determination that a triggering criterion for dynamically repartitioning the data stream has been met, a modified mapping is generated, and a different set of ingestion and storage nodes are configured. For at least some time during which arriving data records are stored in accordance with the modified mapping, data records stored at the first set of storage nodes in accordance with the initial mapping are retained.

公开(公告)号：US09817864B1

公开(公告)日：2017-11-14

申请号：US13917586

申请日：2013-06-13

Applicant: Amazon Technologies, Inc.

Inventor： John David Dunagan ,  Derek Solomon Pai ,  Caitlyn Rose Shim ,  John W. Heitmann ,  Michael R. Foster

IPC: G06F17/30

CPC classification number: G06F17/30442 ,  G06F11/30 ,  G06F17/30424

Abstract: Monitoring data can be sent, received, stored, and accessed with zero setup. Customers can send monitoring data to be stored without the customers having to perform any setup ahead-of-time, such as arbitrary lists of key-value pairs. Customers can perform zero setup pivot queries using stored monitoring data. For example, users can perform pivot queries using any available stored information, such as available metric types and dimensions, without any setup needed ahead-of-time.

公开(公告)号：US09720989B2

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

申请号：US14077171

申请日：2013-11-11

Applicant: Amazon Technologies, Inc.

Inventor： Marvin Michael Theimer ,  Gaurav D. Ghare ,  John David Dunagan ,  Greg Burgess ,  Ying Xiong

IPC: G06F17/30 ,  G06F15/173 ,  G06F17/00

CPC classification number: G06F17/30569 ,  G06F17/30

Abstract: A partitioning policy, comprising an indication of an initial mapping of data records of a stream to a plurality of partitions, is selected to distribute data records of a data stream among a plurality of nodes of a stream management service. Data ingestion nodes and storage nodes are configured according to the initial mapping. In response to a determination that a triggering criterion for dynamically repartitioning the data stream has been met, a modified mapping is generated, and a different set of ingestion and storage nodes are configured. For at least some time during which arriving data records are stored in accordance with the modified mapping, data records stored at the first set of storage nodes in accordance with the initial mapping are retained.