Using configured application information to control use of invocable services

    公开(公告)号:US10726404B2

    公开(公告)日:2020-07-28

    申请号:US14701377

    申请日:2015-04-30

    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.

    IDEMPOTENT PROCESSING OF DATA STREAMS
    22.
    发明申请

    公开(公告)号:US20200220910A1

    公开(公告)日:2020-07-09

    申请号:US16825404

    申请日:2020-03-20

    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.

    Automated reconfiguration of real time data stream processing

    公开(公告)号:US10599478B1

    公开(公告)日:2020-03-24

    申请号:US15084350

    申请日:2016-03-29

    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.

    Controlling access to services via usage models

    公开(公告)号:US10291715B1

    公开(公告)日:2019-05-14

    申请号:US14144377

    申请日:2013-12-30

    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.

    Real time anomaly detection for data streams

    公开(公告)号:US10129118B1

    公开(公告)日:2018-11-13

    申请号:US15084343

    申请日:2016-03-29

    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.

    DATA STREAM INGESTION AND PERSISTENCE TECHNIQUES

    公开(公告)号:US20180189367A1

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

    申请号:US15858480

    申请日:2017-12-29

    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.

    AUTOMATED RECONFIGURATION OF REAL TIME DATA STREAM PROCESSING

    公开(公告)号:US20230004434A1

    公开(公告)日:2023-01-05

    申请号:US17813009

    申请日:2022-07-15

    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.

    Consuming fragments of time-associated data streams

    公开(公告)号:US11025691B1

    公开(公告)日:2021-06-01

    申请号:US15821692

    申请日:2017-11-22

    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.

Patent Agency Ranking