KinesisStartingPosition

class aws_cdk.aws_pipes_sources_alpha.KinesisStartingPosition(value, names=None, *, module=None, qualname=None, type=None, start=1, boundary=None)

Bases: Enum

(experimental) The position in a Kinesis stream from which to start reading.

Stability:: experimental
ExampleMetadata:: infused

Example:

# source_stream: kinesis.Stream
# target_queue: sqs.Queue


pipe_source = sources.KinesisSource(source_stream,
    starting_position=sources.KinesisStartingPosition.LATEST
)

pipe = pipes.Pipe(self, "Pipe",
    source=pipe_source,
    target=SqsTarget(target_queue)
)

Attributes

AT_TIMESTAMP

(experimental) Start streaming from the position denoted by the time stamp specified in the startingPositionTimestamp field.

Stability:: experimental

LATEST

(experimental) Start streaming just after the most recent record in the shard, so that you always read the most recent data in the shard.

Stability:: experimental

TRIM_HORIZON

(experimental) Start streaming at the last untrimmed record in the shard, which is the oldest data record in the shard.

Stability:: experimental