US 11,968,280 B1
Controlling ingestion of streaming data to serverless function executions
Vinayak Sood, Seattle, WA (US); Mandakini Saroop, Seattle, WA (US); Shu Song, Seattle, WA (US); Tejas Mahadeo Ghadge, Seattle, WA (US); Tyson Charles Olychuck, Seattle, WA (US); Dinesh Saheblal Gupta, Bothell, WA (US); and Jia Liu, Campbell, CA (US)
Assigned to Amazon Technologies, Inc., Seattle, WA (US)
Filed by Amazon Technologies, Inc., Seattle, WA (US)
Filed on Nov. 24, 2021, as Appl. No. 17/456,546.
Int. Cl. G06F 8/33 (2018.01); G06F 8/41 (2018.01); H04L 67/133 (2022.01); H04L 67/564 (2022.01); H04L 67/5651 (2022.01); H04L 67/60 (2022.01)
CPC H04L 67/60 (2022.05) [H04L 67/133 (2022.05); H04L 67/564 (2022.05); H04L 67/5651 (2022.05)] 22 Claims
OG exemplary drawing
 
1. A computer-implemented method comprising:
iteratively retrieving data items from a data stream;
generating a first batch of data items including one or more data items retrieved from the data stream;
requesting invocation of a serverless function to process the first batch of data items;
obtaining, from an execution of the serverless function, instructions controlling subsequent ingestion of data items from the data stream by executions of the serverless function, the instructions including an instruction to generate a subsequent batch of data items by resubmitting a portion of the one or more data items in the first batch of data items beginning at a location in the first batch of data items identified within the instructions; and
modify subsequent invocations of the serverless function according to the instructions, wherein modifying the subsequent invocations of the serverless function according to the instructions comprises:
generating the subsequent batch of data items for processing by the serverless function by resubmitting a portion of the one or more data items in the first batch of data items beginning at the location in the first batch of data items identified within the instructions; and
requesting a second invocation of the serverless function to process the subsequent batch of data items.