公开(公告)号：US10885565B1

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

申请号：US14311173

申请日：2014-06-20

Applicant: Amazon Technologies, Inc.

Inventor： Barry Russell ,  Rahul Sharma Pathak ,  Aditya Krishnan

IPC: G06Q30/00 ,  G06Q30/06

Abstract: A network-based data discovery and consumption coordination service may provide data set listings for purchase offered by respective data vendors. The data discovery and consumption coordination service may provide listings in response to search requests based on various search criteria, as well as various filtering techniques based on user reviews, ratings, and other user purchase history for data set listings. The data discovery and consumption coordination service may receive a purchase request via a network-based interface for the service. Data consumption resources which may consume a purchased data set may also be identified via the network-based interface for the data discovery and consumption coordination service. The data discovery and consumption coordination service may direct the transfer of the data set for the purchased data set listing to the identified data consumption resource.

公开(公告)号：US10764347B1

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

申请号：US15821693

申请日：2017-11-22

Applicant: Amazon Technologies, Inc.

Inventor： Gaurav D. Ghare ,  Aditya Krishnan ,  Roger Shane Barga ,  William J. Vass ,  Mushegh Malkhasyan

IPC: H04L29/06 ,  H04N21/439 ,  H04N21/845 ,  H04L29/08 ,  G06F16/71 ,  G06F16/783 ,  H04L1/18 ,  G08B13/196 ,  G08B21/02 ,  G08B25/00 ,  H04L12/28

Abstract: Disclosed are various embodiments for a framework for time-associated data stream storage, processing, and replication. A plurality of streams of time-associated data are received from a plurality of sources via a network using an application-layer protocol. Each of the plurality of streams is divided into a plurality of fragments. An acknowledgement is sent to each of the plurality of sources for each of the plurality of fragments via the network using the application-layer protocol. Processing is performed on each of the plurality of fragments for individual ones of the plurality of streams. An action is implemented relative to a respective fragment based at least in part on a result of the processing.