enum DynamoDBStartingPosition
Language | Type name |
---|---|
.NET | Amazon.CDK.AWS.Pipes.Sources.Alpha.DynamoDBStartingPosition |
Go | github.com/aws/aws-cdk-go/awscdkpipessourcesalpha/v2#DynamoDBStartingPosition |
Java | software.amazon.awscdk.services.pipes.sources.alpha.DynamoDBStartingPosition |
Python | aws_cdk.aws_pipes_sources_alpha.DynamoDBStartingPosition |
TypeScript (source) | @aws-cdk/aws-pipes-sources-alpha » DynamoDBStartingPosition |
The position in a DynamoDB stream from which to start reading.
Example
const table = new ddb.TableV2(this, 'MyTable', {
partitionKey: {
name: 'id',
type: ddb.AttributeType.STRING,
},
dynamoStream: ddb.StreamViewType.NEW_IMAGE,
});
declare const targetQueue: sqs.Queue;
const pipeSource = new sources.DynamoDBSource(table, {
startingPosition: sources.DynamoDBStartingPosition.LATEST,
});
const pipe = new pipes.Pipe(this, 'Pipe', {
source: pipeSource,
target: new SomeTarget(targetQueue)
});
Members
Name | Description |
---|---|
TRIM_HORIZON | Start reading at the last (untrimmed) stream record, which is the oldest record in the shard. |
LATEST | Start reading just after the most recent stream record in the shard, so that you always read the most recent data in the shard. |
TRIM_HORIZON
Start reading at the last (untrimmed) stream record, which is the oldest record in the shard.
LATEST
Start reading just after the most recent stream record in the shard, so that you always read the most recent data in the shard.