-
公开(公告)号：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.
-
公开(公告)号：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.
-
公开(公告)号：US10560465B2
公开(公告)日：2020-02-11
申请号：US16186314
申请日：2018-11-09
Applicant: Amazon Technologies, Inc.
Inventor： Gaurav D. Ghare , Roger Shane Barga
IPC: H04L29/06
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.
-
公开(公告)号：US11836533B2
公开(公告)日：2023-12-05
申请号：US17813009
申请日：2022-07-15
Applicant: Amazon Technologies, Inc.
Inventor： Gaurav D. Ghare , Roger Shane Barga
IPC: G06F9/50 , G06F16/2455
CPC classification number: G06F9/505 , G06F16/24568
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.
-
公开(公告)号：US20190082005A1
公开(公告)日：2019-03-14
申请号：US16179339
申请日：2018-11-02
Applicant: Amazon Technologies, Inc.
Inventor： Gaurav D. Ghare , Roger Shane Barga
Abstract: Managed function execution for processing data streams in real time may be. A function that describes one or more operations to be performed with respect to one or more data streams may be received via programmatic interface for a managed stream processing system. Stream processing nodes capable of applying the function may be determined and execution of the one or more operations may be initiated at the stream processing nodes as data records of the data stream are received. Results of the application of the processing function may be provided to one or more destinations specified for the function. Performance metrics may also be collected for the execution of the function and provided to a client that submitted the function.
-
Patent Agency Ranking
公开(公告)号：US10122788B2
公开(公告)日：2018-11-06
申请号：US15084347
申请日：2016-03-29
Applicant: Amazon Technologies, Inc.
Inventor： Gaurav D. Ghare , Roger Shane Barga
Abstract: Managed function execution for processing data streams in real time may be. A function that describes one or more operations to be performed with respect to one or more data streams may be received via programmatic interface for a managed stream processing system. Stream processing nodes capable of applying the function may be determined and execution of the one or more operations may be initiated at the stream processing nodes as data records of the data stream are received. Results of the application of the processing function may be provided to one or more destinations specified for the function. Performance metrics may also be collected for the execution of the function and provided to a client that submitted the function.
-
公开(公告)号：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.
-
公开(公告)号：US11417109B1
公开(公告)日：2022-08-16
申请号：US15926987
申请日：2018-03-20
Applicant: Amazon Technologies, Inc.
Inventor： Marvin Michael Theimer , Roger Shane Barga , William J. Vass
Abstract: An event detection system for detecting events related to vehicles based on sensor data from the vehicles. An event detection service on a network may receive streams of sensor data from vehicles and apply machine learning techniques to train models and to analyze the data to detect vehicle-related events. Supervised and unsupervised techniques may be used to train the models and to detect known as well as anomalous events. Events may be detected based on data from one or from multiple vehicles. The system may respond to events by alerting entities and/or signaling vehicle control systems to respond to the events. Trained models may be downloaded to vehicles; the vehicle computer systems can then locally detect events. The downloaded models can be further trained on the vehicles, uploaded to the network, and integrated into the network-based models to improve the performance of the models.
-
公开(公告)号：US20200285514A1
公开(公告)日：2020-09-10
申请号：US16825432
申请日：2020-03-20
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.
-
公开(公告)号：US10447772B2
公开(公告)日：2019-10-15
申请号：US16179339
申请日：2018-11-02
Applicant: Amazon Technologies, Inc.
Inventor： Gaurav D. Ghare , Roger Shane Barga
IPC: H04L29/08 , G06F16/2455 , H04L29/06 , G06F16/27
Abstract: Managed function execution for processing data streams in real time may be. A function that describes one or more operations to be performed with respect to one or more data streams may be received via programmatic interface for a managed stream processing system. Stream processing nodes capable of applying the function may be determined and execution of the one or more operations may be initiated at the stream processing nodes as data records of the data stream are received. Results of the application of the processing function may be provided to one or more destinations specified for the function. Performance metrics may also be collected for the execution of the function and provided to a client that submitted the function.
-
-
-
-
-
-
-
-
-
Search Results
11
records
(took 0.015 seconds)
