REMOTE INVOCATION OF CODE EXECUTION IN A LOCALIZED DEVICE COORDINATOR

• US 20180150341A1
• Filed: 11/28/2016
• Published: 05/31/2018
• Est. Priority Date: 11/28/2016
• Status: Active Grant

• Current Assignee: Amazon Technologies, Inc. (Amazon.com, Inc.)
• Original Assignee: Amazon Technologies, Inc. (Amazon.com, Inc.)
• Inventors: Pan, Cheng, Kuo, Calvin Yue-Ren, Turow, Jonathan I., Brooker, Marc John, Sorenson, III, James Christopher, McClenahan, Weili Zhong
• Granted Patent: US 10,783,016 B2
• Time in Patent Office: Days
• CPC Class Codes: G06F 9/5027 the resource being a machine, e.g. CPUs, Servers, Terminals
• CPC Class Codes: G06F 9/547 Remote procedure calls [RPC]; Web services

Abstract

Systems and methods are described for implementing a coordinator within a coordinated environment, which environment includes set of coordinated devices managed by the coordinator. The coordinator can be provisioned with a set of tasks, each task corresponding to a segment of code that can be executed by the coordinator, such as to manage the coordinated devices. To assist in execution of the tasks, the coordinator can include a remote interface that enables retrieval of task calls from an external system, such as an external on-demand code execution environment. The remote interface may periodically retrieve calls from the external system, and generate corresponding call messages on the coordinator to cause executions of called tasks. The remote interface can further obtain outputs of such executions, and report those outputs to the external system.

Claims

1. A coordinator computing device implementing a remote interface enabling remote invocation of tasks on the coordinator computing device, wherein the coordinator computing device is configured to manage one or more coordinated devices within a coordinated environment, and wherein individual tasks correspond to code executable by the coordinator computing device to manage operation of the one or more coordinated devices, the coordinator computing device comprising:

a non-transitory data store including computer executable instructions corresponding to the remote interface that, when executed, enables remote invocation of tasks on the coordinator computing device;

a processor in communication with the non-transitory data store and configured to execute the remote interface, wherein execution of the remote interface causes the processor to;

transmit a query to an on-demand code execution environment remote from the coordinator computing device to obtain a call to execute a task on the coordinator computing device, wherein the query is addressed to a resource identifier associated with a queue of calls to the coordinator computing device maintained at the on-demand code execution environment;

obtain the call to execute the task on the coordinator computing device, wherein the call includes parameters to be passed to an execution of the task;

determine a resource identifier associated with the task and the coordinator computing device; and

generate a call message corresponding to the call to execute the task on the coordinator computing device, wherein the call message is addressed to the resource identifier associated with the task, wherein the call message includes the parameters to be passed to an execution of the task, and wherein the call message causes execution of the task on the coordinator computing device.

2. The coordinator computing device of claim 1, wherein execution of the remote interface further causes the processor to:

obtain an execution identifier corresponding to the execution of the task;

obtain a return message from the execution of the task, wherein the message specifies the execution identifier;

identify the return message as an output of the execution of the task based at least in part on the execution identifier; and

return the output of the execution of the task to on-demand code execution environment.

3. The coordinator computing device of claim 2, wherein execution of the remote interface causes the processor to obtain the execution identifier by at least one of generating the execution identifier or detecting the execution identifier within the call to execute the task.

4. The coordinator computing device of claim 1, wherein the call message is a hypertext transport protocol (HTTP) message addressed to the resource identifier associated with the task.

5. Non-transitory computer readable media including instructions executable by a coordinator computing device to implement a remote interface enabling remote invocation of tasks on the coordinator computing device, wherein individual tasks correspond to code executable by the coordinator computing device to manage operation of the one or more coordinated devices, and wherein execution of the instructions causes the coordinator computing device to:

transmit a query to an on-demand code execution environment, remote from the coordinator computing device, for a call to execute a task on the coordinator computing device, wherein the query is addressed to a resource identifier associated with a queue of calls to the coordinator computing device maintained at the on-demand code execution environment;

obtain the call to execute the task on the coordinator computing device;

determine a resource identifier associated with task and the coordinator computing device; and

generate a call message corresponding to the call to execute the task on the coordinator computing device, wherein the call message is addressed to the resource identifier associated with the task.

6. The non-transitory computer readable media of claim 5, wherein execution of the instructions further causes the coordinator computing device to:

obtain a return message from the execution of the task, wherein the message specifies an execution identifier corresponding to the execution of the task;

identify the return message as an output of the execution of the task based at least in part on the execution identifier; and

return the output of the execution of the task to on-demand code execution environment.

7. The non-transitory computer readable media of claim 5, wherein execution of the instructions causes the coordinator computing device to return the output of the execution of the task to on-demand code execution environment at least partly by transmitting the output to a second resource identifier, on the on-demand code execution environment, including the execution identifier.

8. The non-transitory computer readable media of claim 5, wherein execution of the instructions causes the coordinator computing device to:

generate a return request message specifying the execution identifier corresponding to the execution of the second task; and

transmit the return request message to a resource identifier associated with the second task.

9. The non-transitory computer readable media of claim 5, wherein the call message includes a priority to be assigned to the execution of the second task.

10. The non-transitory computer readable media of claim 5, wherein the resource identifier associated with the second task and the coordinator computing device includes a domain name associated with the coordinator computing device, a port associated with the communication manager, and a path associated with the second task.

11. The non-transitory computer readable media of claim 5, wherein the resource identifier associated with the second task is a uniform resource identifier.

12. The non-transitory computer readable media of claim 5, wherein execution of the instructions causes the coordinator computing device to generate an execution environment for execution of the task to execute the task within the execution environment.

13. A computer-implemented method implemented by a coordinator computing device to enable remote invocation of tasks on the coordinator computing device, wherein individual tasks of correspond to code executable by the coordinator computing device, the computer-implemented method comprising:

transmitting a query to an on-demand code execution environment, remote from the coordinator computing device, for a call to execute a task on the coordinator computing device, wherein the query is addressed to a resource identifier associated with a queue of calls to the coordinator computing device maintained at the on-demand code execution environment;

obtaining the call to execute the task on the coordinator computing device;

determining a resource identifier associated with a task and the coordinator computing device; and

generating a call message corresponding to the call to execute the task on the coordinator computing device, wherein the call message is addressed to the resource identifier associated with the task.

14. The computer-implemented method of claim 13 further comprising at least one of assigning an execution identifier to an execution of the task or identifying, within the call, the execution identifier.

15. The computer-implemented method of claim 14, wherein the call message includes the execution identifier.

16. The computer-implemented method of claim 13 further comprising executing the task on the coordinator computing device in response to the call message, wherein comprising executing the task on the coordinator computing device comprises generating an execution environment for execution of the task on the coordinator computing device.

17. The computer-implemented method of claim 13, wherein

obtaining a return message from an execution of the task, wherein the message specifies an execution identifier corresponding to the execution of the task;

identifying the return message as an output of the execution of the task based at least in part on the execution identifier; and

returning the output of the execution of the task to on-demand code execution environment.

18. The computer-implemented method of claim 17 further comprising generating a return request message specifying the execution identifier and transmitting the return request message to a resource identifier corresponding to the task.

19. The computer-implemented method of claim 17, wherein returning the output of the execution of the task to on-demand code execution environment comprises including the execution identifier as a header field associated with the output.

20. The computer-implemented method of claim 13, wherein generating the call message comprises decapsulating the call message from to the obtained call.