PipeSourceDynamoDBStreamParametersProperty Struct
The parameters for using a DynamoDB stream as a source.
Example
ts
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import { aws_pipes as pipes } from 'aws-cdk-lib';
const pipeSourceDynamoDBStreamParametersProperty: pipes.CfnPipe.PipeSourceDynamoDBStreamParametersProperty = {
startingPosition: 'startingPosition',
// the properties below are optional
batchSize: 123,
deadLetterConfig: {
arn: 'arn',
},
maximumBatchingWindowInSeconds: 123,
maximumRecordAgeInSeconds: 123,
maximumRetryAttempts: 123,
onPartialBatchItemFailure: 'onPartialBatchItemFailure',
parallelizationFactor: 123,
};
Properties
batchSizeoptionalnumberbatch_sizeoptionalint | floatbatchSizeoptionalNumberBatchSizeoptionaldoubleBatchSizeoptional*float64#The maximum number of records to include in each batch.
deadLetterConfigoptionalIResolvable | CfnPipe.DeadLetterConfigPropertydead_letter_configoptionaltyping.Union[IResolvable, DeadLetterConfigProperty]deadLetterConfigoptionalIResolvableDeadLetterConfigoptionalIResolvableDeadLetterConfigoptionalinterface{}#Define the target queue to send dead-letter queue events to.
maximumBatchingWindowInSecondsoptionalnumbermaximum_batching_window_in_secondsoptionalint | floatmaximumBatchingWindowInSecondsoptionalNumberMaximumBatchingWindowInSecondsoptionaldoubleMaximumBatchingWindowInSecondsoptional*float64#The maximum length of a time to wait for events.
maximumRecordAgeInSecondsoptionalnumbermaximum_record_age_in_secondsoptionalint | floatmaximumRecordAgeInSecondsoptionalNumberMaximumRecordAgeInSecondsoptionaldoubleMaximumRecordAgeInSecondsoptional*float64#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.
maximumRetryAttemptsoptionalnumbermaximum_retry_attemptsoptionalint | floatmaximumRetryAttemptsoptionalNumberMaximumRetryAttemptsoptionaldoubleMaximumRetryAttemptsoptional*float64#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.
onPartialBatchItemFailureoptionalstringon_partial_batch_item_failureoptionalstronPartialBatchItemFailureoptionalStringOnPartialBatchItemFailureoptionalstringOnPartialBatchItemFailureoptional*string#Define how to handle item process failures.
AUTOMATIC_BISECT halves each batch and retry each half until all the records are processed or there is one failed message left in the batch.
parallelizationFactoroptionalnumberparallelization_factoroptionalint | floatparallelizationFactoroptionalNumberParallelizationFactoroptionaldoubleParallelizationFactoroptional*float64#The number of batches to process concurrently from each shard.
The default value is 1.
startingPositionstringstarting_positionstrstartingPositionStringStartingPositionstringStartingPosition*stringrequired#(Streams only) The position in a stream from which to start reading.
Valid values : TRIM_HORIZON | LATEST