公开(公告)号：US20190266026A1

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

申请号：US16286350

申请日：2019-02-26

Applicant: Amazon Technologies, Inc.

Inventor： AndyGibb Halim

IPC: G06F9/50 ,  G06F9/48 ,  G06F9/54

Abstract: A timer service receives timer creation requests from clients and fires those timers upon their expiration by returning to the requesting clients payloads provided with the timer creation requests. A timer creation request includes a client identifier, a timer expiration time, and a payload. The timer service queues timer creation requests, a creation worker adds timer records to a timer store in response to requests and manages partitions of the timer store, and sweeper workers, one per partition, sweep timers into a second queue. A firing worker reads timer index records from the second queue, determines the timers referenced in those timer index records and executes the payloads of those timers. The timer store can be tiered, with partitions different storage priorities based on the timer expirations of the timers in the partitions.

公开(公告)号：US20170017527A1

公开(公告)日：2017-01-19

申请号：US15280233

申请日：2016-09-29

Applicant: Amazon Technologies, Inc.

Inventor： AndyGibb Halim ,  Swapneel Patil

IPC: G06F9/52 ,  G06F9/48

CPC classification number: G06F9/52 ,  G06F9/46 ,  G06F9/48 ,  G06F9/4881 ,  G06F9/50

Abstract: A distributed work processing system for processing computational tasks is scalable and fault-tolerant without requiring centralized control. Worker processes running on worker hosts are organized into a logical group and worker coordinators running on worker coordinator hosts coordinate tasks assigned to worker processes. A task store might hold a collection of tasks to be performed by the logical group. A lock database can be used for locking the logical group for coordination by one worker coordinator process at a time. A membership store contains mappings of worker processes to logical groups, and an assignment store indicates which tasks are assigned to which workers. The worker coordinator process has a scanner process to deal with unassigned tasks and deduplicating duplicate assignments. If a worker coordinator does not see enough worker processes, it can instantiate more. If a worker process does not see a worker coordinator, it can instantiate one.

Abstract translation: 用于处理计算任务的分布式工作处理系统是可扩展的和容错的，而不需要集中控制。 在worker主机上运行的worker进程被组织成一个逻辑组，并且在worker协调器主机上运行的worker协调器协调分配给worker进程的任务。 任务存储可能会保存由逻辑组执行的任务集合。 锁定数据库可用于一次由一个工作人员协调程序锁定逻辑组进行协调。 会员存储包含对逻辑组的工作进程的映射，分配存储指示哪些工作分配给哪些工作人员。 工作协调器进程具有处理未分配任务和重复分配重复分配的扫描程序。 如果工作协调器看不到足够的工作进程，则可以实例化更多。 如果一个工作进程没有看到一个工作协调器，它可以实例化一个。

公开(公告)号：US09424075B1

公开(公告)日：2016-08-23

申请号：US14619855

申请日：2015-02-11

Applicant: Amazon Technologies, Inc.

Inventor： AndyGibb Halim

IPC: G06F9/46 ,  G06F9/48

CPC classification number: G06F9/542 ,  G06F9/4825

Abstract: A timer service receives timer creation requests from clients and fires those timers upon their expiration by returning to the requesting clients payloads provided with the timer creation requests. A timer creation request includes a client identifier, a timer expiration time, and a payload. The timer service queues timer creation requests, a creation worker adds timer records to a timer store in response to requests and manages virtual partitions of the timer store, and sweeper workers, one per virtual partition, sweep timers into a second queue. A firing worker reads timer index records from the second queue, determines the timers referenced in those timer index records and executes the payloads of those timers. The timer store can be tiered, with virtual partitions different storage priorities based on the timer expirations of the timers in the virtual partitions.

Abstract translation: 定时器服务从客户端接收定时器创建请求，并通过返回到提供有定时器创建请求的请求客户端有效载荷来触发它们到期的那些定时器。 定时器创建请求包括客户端标识符，定时器到期时间和有效载荷。 定时器服务对定时器创建请求进行排队，创建工作者响应于请求向定时器存储器添加定时器记录，并管理定时器存储的虚拟分区，扫描器工作器（每个虚拟分区一个）将定时器扫描到第二个队列中。 射击工作人员从第二个队列读取定时器索引记录，确定这些定时器索引记录中引用的定时器，并执行这些定时器的有效载荷。 定时器存储可以分层，虚拟分区根据虚拟分区中定时器的定时器到期而不同的存储优先级。

公开(公告)号：US09237074B1

公开(公告)日：2016-01-12

申请号：US13890056

申请日：2013-05-08

Applicant: Amazon Technologies, Inc.

Inventor： Sudharsan Sampath ,  Vinoo Vasudevan ,  AndyGibb Halim ,  Pradipta Biswas

IPC: H04L12/24

CPC classification number: H04L41/12 ,  H04L41/044 ,  H04L61/3005 ,  H04L61/3015 ,  H04L61/3065

Abstract: Some examples provide for issuing identifiers to clients of a distributed identifier generation system. A request for a unique identifier may be received by a host. The host may generate an identifiers based at least in part on a host identifier issued to the generating host and a value of a counter operated by the generating host. The identifiers may be unique within the distributed identifier generation system.

Abstract translation: 一些示例提供向分布式标识符生成系统的客户端发布标识符。 主机可以接收到唯一标识符的请求。 主机可以至少部分地基于发给生成主机的主机标识符和由生成主机操作的计数器的值来生成标识符。 标识符在分布式标识符生成系统内可以是唯一的。

公开(公告)号：US10228979B1

公开(公告)日：2019-03-12

申请号：US15209520

申请日：2016-07-13

Applicant: Amazon Technologies, Inc.

Inventor： AndyGibb Halim

IPC: G06F9/50

Abstract: A timer service receives timer creation requests from clients and fires those timers upon their expiration by returning to the requesting clients payloads provided with the timer creation requests. A timer creation request includes a client identifier, a timer expiration time, and a payload. The timer service queues timer creation requests, a creation worker adds timer records to a timer store in response to requests and manages virtual partitions of the timer store, and sweeper workers, one per virtual partition, sweep timers into a second queue. A firing worker reads timer index records from the second queue, determines the timers referenced in those timer index records and executes the payloads of those timers. The timer store can be tiered, with virtual partitions different storage priorities based on the timer expirations of the timers in the virtual partitions.

公开(公告)号：US09740537B2

公开(公告)日：2017-08-22

申请号：US15280233

申请日：2016-09-29

Applicant: Amazon Technologies, Inc.

Inventor： AndyGibb Halim ,  Swapneel Patil

IPC: G06F9/52 ,  G06F9/46 ,  G06F9/48 ,  G06F9/50

CPC classification number: G06F9/52 ,  G06F9/46 ,  G06F9/48 ,  G06F9/4881 ,  G06F9/50

Abstract: A distributed work processing system for processing computational tasks is scalable and fault-tolerant without requiring centralized control. Worker processes running on worker hosts are organized into a logical group and worker coordinators running on worker coordinator hosts coordinate tasks assigned to worker processes. A task store might hold a collection of tasks to be performed by the logical group. A lock database can be used for locking the logical group for coordination by one worker coordinator process at a time. A membership store contains mappings of worker processes to logical groups, and an assignment store indicates which tasks are assigned to which workers. The worker coordinator process has a scanner process to deal with unassigned tasks and deduplicating duplicate assignments. If a worker coordinator does not see enough worker processes, it can instantiate more. If a worker process does not see a worker coordinator, it can instantiate one.

公开(公告)号：US11157324B2

公开(公告)日：2021-10-26

申请号：US16286350

申请日：2019-02-26

Applicant: Amazon Technologies, Inc.

Inventor： AndyGibb Halim

IPC: G06F9/50 ,  G06F9/48 ,  G06F9/54

Abstract: A timer service receives timer creation requests from clients and fires those timers upon their expiration by returning to the requesting clients payloads provided with the timer creation requests. A timer creation request includes a client identifier, a timer expiration time, and a payload. The timer service queues timer creation requests, a creation worker adds timer records to a timer store in response to requests and manages partitions of the timer store, and sweeper workers, one per partition, sweep timers into a second queue. A firing worker reads timer index records from the second queue, determines the timers referenced in those timer index records and executes the payloads of those timers. The timer store can be tiered, with partitions different storage priorities based on the timer expirations of the timers in the partitions.

公开(公告)号：US09459933B1

公开(公告)日：2016-10-04

申请号：US14619834

申请日：2015-02-11

Applicant: Amazon Technologies, Inc.

Inventor： AndyGibb Halim ,  Swapneel Patil

IPC: G06F9/52 ,  G06F9/46 ,  G06F9/48 ,  G06F9/50

CPC classification number: G06F9/52 ,  G06F9/46 ,  G06F9/48 ,  G06F9/4881 ,  G06F9/50

Abstract: A distributed work processing system for processing computational tasks IS scalable and fault-tolerant without requiring centralized control. Worker processes running on worker hosts and worker coordinators running on worker coordinator hosts interact with a task store that holds a collection of tasks to be performed by a logical group of worker processes, a lock database used for locking the logical group for coordination by one worker coordinator process at a time, a membership store that contains mappings of worker processes to logical groups, and an assignment store indicating which tasks are assigned to which workers. The worker coordinator process has a scanner process to deal with unassigned tasks and deduplicating duplicate assignments. If a worker coordinator does not see enough worker processes, it can instantiate more. If a worker process does not see a worker coordinator, it can instantiate one.

Abstract translation: 用于处理计算任务的分布式工作处理系统是可扩展的和容错的，而不需要集中控制。 在工作主机和运行在工作协调器主机上的工作协调器上运行的工作进程与一个任务存储进行交互，该任务存储包含要由逻辑组的工作进程执行的任务集合，用于锁定逻辑组以供一个工作人员进行协调的锁定数据库 协调程序进程，一个包含工作进程到逻辑组的映射的成员存储，以及一个分配存储，指示哪些工作分配给哪些工作。 工作协调器进程具有处理未分配任务和重复分配重复分配的扫描程序。 如果工作协调器看不到足够的工作进程，则可以实例化更多。 如果一个工作进程没有看到一个工作协调器，它可以实例化一个。