US 11,675,501 B2
Streaming data service with isolated read channels
Vasudeva Gade, Sammamish, WA (US); Benjamin Warren Mercier, Seattle, WA (US); Sayantan Chakravorty, Sammamish, WA (US); Yasemin Avcular, Seattle, WA (US); and Charlie Paucard, Seattle, WA (US)
Assigned to Amazon Technologies, Inc., Seattle, WA (US)
Filed by Amazon Technologies, Inc., Seattle, WA (US)
Filed on Sep. 4, 2020, as Appl. No. 17/13,441.
Application 17/013,441 is a continuation of application No. 16/143,341, filed on Sep. 26, 2018, granted, now 10,768,830.
Claims priority of provisional application 62/698,821, filed on Jul. 16, 2018.
Prior Publication US 2020/0401323 A1, Dec. 24, 2020
This patent is subject to a terminal disclaimer.
Int. Cl. G06F 3/06 (2006.01)
CPC G06F 3/0617 (2013.01) [G06F 3/065 (2013.01); G06F 3/0644 (2013.01); G06F 3/0647 (2013.01); G06F 3/0653 (2013.01); G06F 3/0659 (2013.01); G06F 3/0673 (2013.01)] 20 Claims
OG exemplary drawing
 
1. A computer-implemented method, comprising:
obtaining an indication, via a programmatic interface, from a client of a data streaming service, of a retention period for records of a data stream, wherein:
the data stream comprises a sequence of the records being streamed from one or more data sources to one or more data consumers;
the one or more data sources perform write operations to the data stream to generate data portions to be included in respective contents of the records;
the respective contents of the respective records comprise respective sequence numbers indicative of an order in which the respective records were received into the data stream; and
the one or more data consumers perform read operations on the data stream to access the respective contents of the respective data records; and
storing the records of the data stream at a first set of storage devices of the data streaming service; and
in response to detecting that one or more of the records of the data stream have remained at the first set of storage devices for at least the retention period, transferring the one or more records to a second set of storage devices.