AWS::Pipes::Pipe PipeSourceDynamoDBStreamParameters
The parameters for using a DynamoDB stream as a source.
Syntax
To declare this entity in your Amazon CloudFormation template, use the following syntax:
JSON
{ "BatchSize" :Integer, "DeadLetterConfig" :DeadLetterConfig, "MaximumBatchingWindowInSeconds" :Integer, "MaximumRecordAgeInSeconds" :Integer, "MaximumRetryAttempts" :Integer, "OnPartialBatchItemFailure" :String, "ParallelizationFactor" :Integer, "StartingPosition" :String}
YAML
BatchSize:IntegerDeadLetterConfig:DeadLetterConfigMaximumBatchingWindowInSeconds:IntegerMaximumRecordAgeInSeconds:IntegerMaximumRetryAttempts:IntegerOnPartialBatchItemFailure:StringParallelizationFactor:IntegerStartingPosition:String
Properties
BatchSizeThe maximum number of records to include in each batch.
Required: No
Type: Integer
Update requires: No interruption
DeadLetterConfigDefine the target queue to send dead-letter queue events to.
Required: No
Type: DeadLetterConfig
Update requires: No interruption
MaximumBatchingWindowInSecondsThe maximum length of a time to wait for events.
Required: No
Type: Integer
Update requires: No interruption
MaximumRecordAgeInSeconds(Streams only) Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge never discards old records.
Required: No
Type: Integer
Update requires: No interruption
MaximumRetryAttempts(Streams only) Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, EventBridge retries failed records until the record expires in the event source.
Required: No
Type: Integer
Update requires: No interruption
OnPartialBatchItemFailure(Streams only) Define how to handle item process failures.
AUTOMATIC_BISECThalves each batch and retry each half until all the records are processed or there is one failed message left in the batch.Required: No
Type: String
Update requires: No interruption
ParallelizationFactor(Streams only) The number of batches to process concurrently from each shard. The default value is 1.
Required: No
Type: Integer
Update requires: No interruption
StartingPosition(Streams only) The position in a stream from which to start reading.
Valid values:
TRIM_HORIZON | LATESTRequired: Yes
Type: String
Update requires: Replacement