公开(公告)号：US20240111751A1

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

申请号：US17936339

申请日：2022-09-28

Applicant: Amazon Technologies, Inc.

Inventor： Himanshu Jindal

IPC: G06F16/23 ,  G06F16/22 ,  G06F16/25

CPC classification number: G06F16/2343 ,  G06F16/2255 ,  G06F16/2365 ,  G06F16/256

Abstract: Systems and methods for implementing record locking for transactions using a probabilistic data structure are described. This probabilistic structure enables adding of data records without growth of the data structure. The data structure includes a hash table for each of multiple hash functions, where entries in the respective hash tables store a transaction time and locking state. To lock a record, each hash function is applied to a record key to provide an index into a respective hash table and a minimum of the values stored in the hash tables is retrieved. If the retrieved value is less than a transaction time for a transaction attempting to lock the record, locking is permitted and the transaction time is recorded to each of the hash tables. To commit the transaction, the probabilistic data structure is atomically updated as part of the commit operation.

公开(公告)号：US10701167B1

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

申请号：US15255130

申请日：2016-09-01

Applicant: Amazon Technologies, Inc.

Inventor： Calvin Yue-Ren Kuo ,  Himanshu Jindal ,  Jonathan I. Turow ,  Frank Miley

IPC: H04L29/08 ,  H04L12/24 ,  G06F15/16

Abstract: A technology is provided for adapting a quorum size of messaging nodes in a service provider environment. An adaptive quorum evaluation is executed to determine a number of messaging nodes for a quorum of messaging nodes. A messaging environment trigger is identified to change the number of messaging nodes used for the quorum of messaging nodes. The number of messaging nodes used for the quorum of messaging nodes is changed based on the messaging environment trigger. Data for the message is synchronized with a quorum of messaging nodes before delivering the message.

公开(公告)号：US20220171759A1

公开(公告)日：2022-06-02

申请号：US17362729

申请日：2021-06-29

Applicant: Amazon Technologies, Inc.

Inventor： Himanshu Jindal ,  Shivateja Reddy Ummenthala ,  Almann Tsutomu Goo ,  Yannis Papakonstantinou ,  Lewis Bruck ,  Tate Andrew Certain ,  Pulkit Maheshwari

IPC: G06F16/23

Abstract: Schema incompatibilities are generating views at target data stores are detected. A view definition may be received at a view management system that specifies data to obtain from source data stores and identifies a target data store to store the view. The view management system may identify an incompatibility between a schema for the data, specified in the view definition, with a type system for the target data store. The view management system may provide an indication of the incompatibility with the type system for the target data store.

公开(公告)号：US20210160325A1

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

申请号：US16712896

申请日：2019-12-12

Applicant: Amazon Technologies, Inc.

Inventor： Alexandra Elizabeth Baoboe Lee ,  Nicholas A. Gochenaur ,  Christoph Saalfeld ,  Himanshu Jindal ,  Eeshan Shreeram Thakar ,  Jared Sharfin

IPC: H04L29/08 ,  H04L29/06 ,  G06F9/54

Abstract: Systems and methods are provided for dynamically configuring an IoT communications system. The IoT communications system receives a client message from an IoT device. The client message includes an endpoint designation (such as by specifying an endpoint in the Server Name Indication (SNI) field of the TLS client hello message). The IoT communications system determines whether the endpoint is associated with a custom or default processing logic and/or settings. Either custom or default processing logic is executed or custom or default settings are applied.

公开(公告)号：US10382307B1

公开(公告)日：2019-08-13

申请号：US15389281

申请日：2016-12-22

Applicant: Amazon Technologies, Inc.

Inventor： Himanshu Jindal ,  Paritosh Mohan ,  Nicholas Andrew Gochenaur

IPC: G06F15/16 ,  H04L12/26 ,  H04L12/861

Abstract: Technology is described for sending subscription-based messages to devices. A message associated with a defined topic may be received. A first subset of devices may be identified that subscribe to the defined topic. A first subset of messages may be provided to a message queue for transmission to devices indicated in the first subset of devices. A second subset of devices may be identified that subscribe to the defined topic. A second subset of messages may be provided to the message queue for transmission to devices indicated in the second subset of devices. The second subset of messages may include an increased subset size as compared to the first subset of messages. The subset size may be increased at a rate to enable sending the message to the plurality of device subscribed to the defined topic within a defined time period.

公开(公告)号：US11343318B2

公开(公告)日：2022-05-24

申请号：US16712896

申请日：2019-12-12

Applicant: Amazon Technologies, Inc.

Inventor： Alexandra Elizabeth Baoboe Lee ,  Nicholas A. Gochenaur ,  Christoph Saalfeld ,  Himanshu Jindal ,  Eeshan Shreeram Thakar ,  Jared Sharfin

IPC: H04L29/08 ,  G06F9/54 ,  H04L29/06 ,  H04L67/125

Abstract: Systems and methods are provided for dynamically configuring an IoT communications system. The IoT communications system receives a client message from an IoT device. The client message includes an endpoint designation (such as by specifying an endpoint in the Server Name Indication (SNI) field of the TLS client hello message). The IoT communications system determines whether the endpoint is associated with a custom or default processing logic and/or settings. Either custom or default processing logic is executed or custom or default settings are applied.

公开(公告)号：US11122000B1

公开(公告)日：2021-09-14

申请号：US16711285

申请日：2019-12-11

Applicant: Amazon Technologies, Inc.

Inventor： Christoph Saalfeld ,  Dominique Fortier ,  Nicholas A. Gochenaur ,  Himanshu Jindal ,  Venkata Harish Kommaraju

IPC: H04L12/58 ,  G06F15/16 ,  H04L29/08 ,  H04L12/26 ,  H04L29/06

Abstract: A message broker of a publish-subscribe messaging system (e.g., using the MQTT protocol or other publish-subscribe protocol) detects a life-cycle event for topic subscription and notifies a publisher of the life-cycle event. The message broker may detect a transition in a number of subscribers to a topic from zero subscribers to one or more subscribers or from one or more subscribers to zero subscribers. In response, the message broker provides an indication to the publisher that the number of subscribers to the topic has transitioned from zero to one or more (or from one or more to zero). This causes the publisher to begin publishing messages on the publisher's topic (or to stop publishing messages on the publisher's topic).

公开(公告)号：US10833881B1

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

申请号：US15804799

申请日：2017-11-06

Applicant: Amazon Technologies, Inc.

Inventor： Himanshu Jindal ,  Gary Wicker

IPC: H04L12/18 ,  H04L29/08 ,  H04L12/66 ,  H04L29/06

Abstract: A technology is described for distributing a publication message. An example method may include receiving a message at a first device gateway to broadcast to devices subscribed to a broadcast topic. The first device gateway maintains a first subscription table indicating which devices connected to the first device gateway are subscribed to the broadcast topic. The first device gateway distributes the message to the devices indicated in the first subscription table as being subscribed to the broadcast topic. In addition, the first device gateway may distribute the message to a second device gateway which maintains a second subscription table indicating which devices connected to the second device gateway are subscribed to the broadcast topic, and the second device gateway distributes the message to the devices indicated in the second subscription table as being subscribed to the broadcast topic.

公开(公告)号：US11665110B1

公开(公告)日：2023-05-30

申请号：US16588808

申请日：2019-09-30

Applicant: Amazon Technologies, Inc.

Inventor： Himanshu Jindal ,  Christoph Saalfeld ,  Saurabh Chatterjee

IPC: G06F15/173 ,  H04L47/70 ,  H04L47/74 ,  H04L47/78 ,  H04L67/51

CPC classification number: H04L47/826 ,  H04L47/746 ,  H04L47/781 ,  H04L47/823 ,  H04L67/51

Abstract: After a service receives a request from another service, the service determines an amount of time to process the request by the service as well as a remaining time allotment to complete processing the request (e.g., a timeout value). Based on the remaining time allotment and the amount of time to process the request by at least the service (predicted time or actual time), the service may determine whether to continue processing the request (e.g., by the service and/or one or more subsequent services) or fail the request. In response, the service may then continue processing the request (e.g., continue processing at the service itself or propagate the request to the next service), or the service may fail the request.

公开(公告)号：US11381506B1

公开(公告)日：2022-07-05

申请号：US16833327

申请日：2020-03-27

Applicant: Amazon Technologies, Inc.

Inventor： Himanshu Jindal ,  Christoph Saalfeld

IPC: H04L47/125 ,  H04L45/24 ,  H04L67/1029 ,  H04L67/1025 ,  G06F11/34 ,  G06N20/00

Abstract: Adaptive load balancing may be implemented for a distributed system. An evaluation of criteria for creating a mapping for an identifier associated with requests may be performed. The created mapping may route requests to a distributed system to request handling nodes that cache request information for performing the requests. When requests are received, if an identifier determined to be associated with the request is mapped to request handling nodes, then the request may be sent to the identified request handling nodes instead of performing a load balancing technique to select a request handling node for the request.