公开(公告)号：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.

公开(公告)号：US20210021653A1

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

申请号：US17062435

申请日：2020-10-02

Applicant: Amazon Technologies, Inc.

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

IPC: H04L29/06

Abstract: From a stream management service, indications of transmissions of data records of a first data stream via a persistent network connection associated with a subscription are provided to a stream processing application. In response to detecting that a transfer throttling condition associated with the subscription has been met, a delay is introduced before additional data records are transmitted via the same persistent network connection. After a subscription expiration period has elapsed, an indication of the expiration is provided to the application via the persistent connection.

公开(公告)号：US10956246B1

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

申请号：US16143361

申请日：2018-09-26

Applicant: Amazon Technologies, Inc.

Inventor： Sumeetkumar Bagde ,  Benjamin Warren Mercier ,  Sayantan Chakravorty ,  Rohit Unnikrishnan Nair ,  Yasemin Avcular ,  Charlie Paucard

IPC: G06F11/07

Abstract: In response to a first programmatic request, metadata indicating that a first isolated read channel associated with a data stream has been established is stored at a stream management service. A read request that indicates the first isolated read channel and the stream is obtained. In response to the read request, contents of data records of the stream are provided.

公开(公告)号：US10855754B1

公开(公告)日：2020-12-01

申请号：US16143340

申请日：2018-09-26

Applicant: Amazon Technologies, Inc.

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

IPC: G06F15/173 ,  H04L29/08 ,  G06F16/28

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.

公开(公告)号：US10798140B1

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

申请号：US16143344

申请日：2018-09-26

Applicant: Amazon Technologies, Inc.

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

IPC: H04L29/06 ,  H04L29/08

Abstract: From a stream management service, indications of transmissions of data records of a first data stream via a persistent network connection associated with a subscription are provided to a stream processing application. In response to detecting that a transfer throttling condition associated with the subscription has been met, a delay is introduced before additional data records are transmitted via the same persistent network connection. After a subscription expiration period has elapsed, an indication of the expiration is provided to the application via the persistent connection.

公开(公告)号：US11509700B2

公开(公告)日：2022-11-22

申请号：US17062435

申请日：2020-10-02

Applicant: Amazon Technologies, Inc.

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

IPC: H04L65/61 ,  G06F3/06 ,  H04L67/02 ,  H04L67/1097 ,  H04L65/612 ,  H04L65/75 ,  H04L65/80 ,  H04L67/1095 ,  H04L67/55

Abstract: From a stream management service, indications of transmissions of data records of a first data stream via a persistent network connection associated with a subscription are provided to a stream processing application. In response to detecting that a transfer throttling condition associated with the subscription has been met, a delay is introduced before additional data records are transmitted via the same persistent network connection. After a subscription expiration period has elapsed, an indication of the expiration is provided to the application via the persistent connection.

公开(公告)号：US11070600B1

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

申请号：US16143343

申请日：2018-09-26

Applicant: Amazon Technologies, Inc.

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

IPC: H04L29/06 ,  H04L29/08 ,  G06F16/28

Abstract: At a stream management service, one or more storage servers of a first repository are assigned to store at least a first partition of a first data stream. At the first repository, records of different partitions are interleaved. In response to determining that a set of data records of the first partition meet a first criterion, a rearranged version of the set in which the data records of the first partition are contiguous is stored at a second repository. Using the rearranged version, one or more records of the first partition are provided to an application which meets a lag criterion.

公开(公告)号：US20210084102A1

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

申请号：US17105287

申请日：2020-11-25

Applicant: Amazon Technologies, Inc.

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

IPC: H04L29/08 ,  G06F16/28

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.

公开(公告)号：US11675501B2

公开(公告)日：2023-06-13

申请号：US17013441

申请日：2020-09-04

Applicant: Amazon Technologies, Inc.

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

IPC: G06F3/06

CPC classification number: G06F3/0617 ,  G06F3/065 ,  G06F3/0644 ,  G06F3/0647 ,  G06F3/0653 ,  G06F3/0659 ,  G06F3/0673

Abstract: At a data stream management service, a first set of metadata indicating that a first isolated read channel has been associated with a first data stream is stored. The first isolated read channel has an associated read performance limit setting. A second set of metadata indicating that a second isolated read channel, with its own performance limit setting, has been associated with a data stream is also stored. Based on determining that the difference between a metric of read operations associated with the first channel and the read performance limit setting of the first channel meets a first criterion, the service initiates a throttling operation for reads associated with the first channel. The throttling decision is made independently of read metrics of the second channel.

公开(公告)号：US11621999B2

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

申请号：US17105287

申请日：2020-11-25

Applicant: Amazon Technologies, Inc.

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

IPC: G06F15/173 ,  H04L67/1029 ,  G06F16/28

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.