Isolated read channel categories at streaming data service
AssigneeAmazon Technologies, Inc.
InventorsBenjamin Warren Mercier, Sayantan Chakravorty, Yasemin Avcular, Charlie Paucard
Life of this patent
Estimating the term…
Abstract
In response to a first programmatic request, metadata indicating that a first isolated read channel of a real-time category has been associated with a first target stream is stored at a stream management service. In response to another request, metadata indicating that a second isolated read channel of a non-real-time category has been associated with a second target stream is stored. In response to a read request indicating the first channel or the second channel, one or more data records of the corresponding target streams are provided.
Claims20
A system, comprising:
- one or more computing devices of a data streams management service;
- wherein the one or more computing devices include instructions that upon execution on a processor cause the one or more computing devices to:
- provide, via a programmatic interface, an indication of a plurality of categories of isolated read channels configurable for one or more data streams, including at least a first real-time category and a first non-real-time category;
- in response to a first channel establishment request received via a programmatic interface, wherein the first channel establishment request indicates (a) at least a first target data stream and (b) the first real time category, perform one or more operations to
- verify that a first storage configuration of the first target data stream meets a first performance capability criterion corresponding to the first real-time category;
- and
- store metadata indicating that a first isolated read channel of the first real-time category has been established and associated with the first target data stream;
- in response to a second channel establishment request received via the programmatic interface, wherein the second channel establishment request indicates (a) at least a second target data stream and (b) the first non-real time category, perform one or more operations to:
- verify that a second storage configuration of the second target data stream meets a second performance capability criterion corresponding to the first non-real-time category;
- and
- store metadata indicating that a second isolated read channel of the first non-real-time category has been established and associated with the second target data stream;
- in response to a first read request directed to the first target data stream using the first isolated read channel, provide contents of a data record of the first target data stream using at least a portion of the first storage configuration;
- and
- in response to a second read request directed to the second target data stream using the second isolated read channel, provide contents of a data record of the second target data stream using at least a portion of the second storage configuration.
A method, comprising:
- performing, by one or more computing devices:
- in response to a first programmatic channel establishment request, wherein the first programmatic channel establishment request indicates (a) at least a first target data stream and (b) at least a first real-time category of isolated read channels, storing metadata indicating that a first isolated read channel of the first real-time category has been established and associated with the first target data stream;
- in response to a second programmatic channel establishment request, wherein the second programmatic channel establishment request indicates (a) at least a second target data stream and (b) at least a first non-real-time category of isolated read channels, storing metadata indicating that a second isolated read channel of the first non-real-time category has been established and associated with the second target data stream;
- in response to a first read request directed to the first target data stream using the first isolated read channel, providing, from a first storage configuration, contents of a data record of the first target data stream;
- and
- in response to a second read request directed to the second target data stream using the second isolated read channel, providing, from a second storage configuration, contents of a data record of the second target data stream.
One or more non-transitory computer-accessible storage media storing program instructions that when executed on or across one or more processors cause the one or more processors to:
- in response to a first programmatic channel establishment request, wherein the first programmatic channel establishment request indicates (a) at least a first target data stream and (b) at least a first real-time category of isolated read channels, store metadata indicating that a first isolated read channel of the first real-time category has been established and associated with the first target data stream;
- in response to a second programmatic channel establishment request, wherein the second programmatic channel establishment request indicates (a) at least a second target data stream and (b) at least a first non-real-time category of isolated read channels, store metadata indicating that a second isolated read channel of the first non-real-time category has been established and associated with the second target data stream;
- in response to a first read request directed to the first target data stream using the first isolated read channel, provide contents of a data record of the first target data stream;
- and
- in response to a second read request directed to the second target data stream using the second isolated read channel, providing contents of a data record of the second target data stream.
Dependencies are inferred from the claim text.