-
公开(公告)号:US10726404B2
公开(公告)日:2020-07-28
申请号:US14701377
申请日:2015-04-30
Applicant: Amazon Technologies, Inc.
Inventor: Peter Sirota , Don Johnson , Gaurav D. Ghare , Tushar Jain , Alan S. Geller
Abstract: Techniques are described for facilitating use of invocable services by applications in a configurable manner. In at least some situations, the invocable services are Web services or other network-accessible services that are made available by providers of the services for use by others in exchange for fees defined by the service providers. The described techniques facilitate use of such invocable services by applications in a manner configured by the application providers and the service providers, including to track use of third-party invocable services by applications on behalf of end users and to allocate fees that are charged end users between the applications and the services as configured by the providers of the applications and services. In some situations, the configured pricing terms for a service specify fees for end users that differ in one or more ways from the defined fees charged by the provider of that service.
-
公开(公告)号:US20200220910A1
公开(公告)日:2020-07-09
申请号:US16825404
申请日:2020-03-20
Applicant: Amazon Technologies, Inc.
Inventor: Gaurav D. Ghare
Abstract: Idempotent processing of data may be implemented for data records retrieved from a data stream. A data stream may receive data records as input and distribute the ingestion, storage, and processing of the data records amongst one or more partitions of the data stream. Partition metadata may be maintained which includes checkpoint metadata for retrieving, processing, and sending data records in the data stream to a specified destination. When assigned a partition for processing, checkpoint metadata for partition may be accessed to determine whether a pending checkpoint for the partition exists. If not pending checkpoint exists, new data records may be retrieved, processed, and sent from the partition of the data stream to a specified destination. If a checkpoint is pending, then the data records identified by the checkpoint metadata as pending may be retrieved, processed, and sent to the specified destination.
-
公开(公告)号:US20200159648A1
公开(公告)日:2020-05-21
申请号:US16198605
申请日:2018-11-21
Applicant: Amazon Technologies, Inc.
Inventor: Gaurav D. Ghare , Bin Zhu , Roger S. Barga , William J. Vass , Gourav Roy , Chetan Banthiya , Paul Andrew Lafranchise , Dmitry Berkovich , Fusheng Yuan , Ritesh Singh , Swarnaprakash Udayakumar , Brandon Kyle Pelfrey , Jason Chen Hooi Chionh , Iftach Ragoler
Abstract: A robotic device management service obtains, from a customer, a first set of parameters of a robotic device and a second set of parameters for a simulation environment for testing a robotic device application installable on the robotic device. The set of parameters are used to indicate a storage location of the application and a selection of a simulation environment for testing the application. In response to the request, the robotic device management service selects a set of resources on which to execute the simulation in the simulation environment. The robotic device management service obtains the robotic device application from the storage location and loads the application on to the set of resources to execute the simulation.
-
公开(公告)号:US10599478B1
公开(公告)日:2020-03-24
申请号:US15084350
申请日:2016-03-29
Applicant: Amazon Technologies, Inc.
Inventor: Gaurav D. Ghare , Roger Barga
IPC: G06F9/50 , G06F16/2455
Abstract: Automated reconfiguration of real time data stream processing may be implemented. A processing function that describes one or more operations to be performed with respect to one or more data streams may be executed at one or more processing nodes. Performance metrics describing the performance of the processing function at the processing nodes may be collected and monitored. A reconfiguration event may be detected for the processing function. A different execution configuration for the processing function may be determined and initiated in response to detecting the reconfiguration event.
-
公开(公告)号:US10291715B1
公开(公告)日:2019-05-14
申请号:US14144377
申请日:2013-12-30
Applicant: Amazon Technologies, Inc.
Inventor: Peter Sirota , Gaurav D. Ghare , Don Johnson , Tushar Jain , Robert Frederick , Ashish Agrawal , Jeffrey Barr
Abstract: Techniques are described for facilitating interactions between computing systems, such as in accordance with usage models that are configured for available services by the providers of the services. In some situations, the services are Web services, and an electronic Web service (“WS”) marketplace is provided via which third-party WS providers make their WSes available to third-party WS consumers who purchase access to those WSes via the electronic marketplace based on configured usage models selected by the consumers. Some or all of the one or more usage models configured for an available WS may each have associated use prices and/or non-price use conditions, and if so access to those WSes using those usage models may be provided only if a consumer requesting access provides appropriate payment and otherwise satisfies the specified use conditions for a selected usage model.
-
公开(公告)号:US10129118B1
公开(公告)日:2018-11-13
申请号:US15084343
申请日:2016-03-29
Applicant: Amazon Technologies, Inc.
Inventor: Gaurav D. Ghare , Roger Shane Barga
Abstract: Real time detection of anomalies may be implemented for a data stream. A data stream may receive data records as input. An evaluation of the data records may be performed as the data records are received utilizing an anomaly detection model that is dynamically generated for a time period that includes the data records. A responsive action may be performed in response to detecting various anomalies, such as providing a notification of the anomaly, requesting a corrective action, invoking further analysis of the detected anomaly. Evaluations of the data record and responsive actions may be performed as specified by a user, in some embodiments.
-
公开(公告)号: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.
-
公开(公告)号:US09639589B1
公开(公告)日:2017-05-02
申请号:US14136645
申请日:2013-12-20
Applicant: Amazon Technologies, Inc.
Inventor: Marvin Michael Theimer , Benjamin Warren Mercier , Nathaniel Martin Glass , Gaurav D. Ghare
IPC: G06F17/30
CPC classification number: G06F11/1461 , G06F11/1451 , G06F11/1464 , G06F17/30575 , G06F2201/80
Abstract: A replication chain comprising one or more replication nodes of a multi-tenant stream management system is assigned to store data records of a partition of a particular data stream. A data record of the partition is received at a selected replication node of the replication chain. In a sequential order, a respective replica of the data record is stored at each replication node of the chain. An acknowledgement of a successful storage of the data record is provided after the replications are completed.
-
公开(公告)号:US20230004434A1
公开(公告)日:2023-01-05
申请号:US17813009
申请日:2022-07-15
Applicant: Amazon Technologies, Inc.
Inventor: Gaurav D. Ghare , Roger Shane Barga
IPC: G06F9/50 , G06F16/2455
Abstract: Automated reconfiguration of real time data stream processing may be implemented. A processing function that describes one or more operations to be performed with respect to one or more data streams may be executed at one or more processing nodes. Performance metrics describing the performance of the processing function at the processing nodes may be collected and monitored. A reconfiguration event may be detected for the processing function. A different execution configuration for the processing function may be determined and initiated in response to detecting the reconfiguration event.
-
公开(公告)号: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.
-
-
-
-
-
-
-
-
-