AwsEventbridgePipeSourceDynamodbStreamArgs

interface AwsEventbridgePipeSourceDynamodbStreamArgs extends EventbridgePipeSourceStreamBaseArgs {
batchSize?: Input<number>;
deadLetterConfig?: AwsEventbridgePipeSourceDeadLetterConfigArgs;
maximumBatchingWindowInSeconds?: Input<number>;
maximumRecordAgeInSeconds?: Input<number>;
maximumRetryAttempts?: Input<number>;
onPartialBatchItemFailure?: Input<string>;
parallelizationFactor?: Input<number>;
startingPosition: Input<'TRIM_HORIZON' | 'LATEST'>;
}

Source parameters for a DynamoDB Streams source.

Hierarchy

EventbridgePipeSourceStreamBaseArgs
AwsEventbridgePipeSourceDynamodbStreamArgs

Properties

`batchSize: Input<number>`

Inherited from batchSize

Maximum number of records per batch. Maximum value: 10000.

`deadLetterConfig: AwsEventbridgePipeSourceDeadLetterConfigArgs`

Inherited from deadLetterConfig

Dead-letter configuration for failed records.

`maximumBatchingWindowInSeconds: Input<number>`

Inherited from maximumBatchingWindowInSeconds

Maximum time in seconds to wait before dispatching a batch. Maximum value: 300.

`maximumRecordAgeInSeconds: Input<number>`

Inherited from maximumRecordAgeInSeconds

Discard records older than this age in seconds. Use -1 for infinite. Maximum: 604800.

`maximumRetryAttempts: Input<number>`

Inherited from maximumRetryAttempts

Maximum number of retry attempts before discarding a record. Use -1 for infinite. Maximum: 10000.

`onPartialBatchItemFailure: Input<string>`

Inherited from onPartialBatchItemFailure

Partial batch failure handling strategy. Valid values: AUTOMATIC_BISECT.

`parallelizationFactor: Input<number>`

Inherited from parallelizationFactor

Number of batches to process concurrently from each shard. Maximum value: 10.

`startingPosition: Input<'TRIM_HORIZON' | 'LATEST'>`

Starting position in the stream. Valid values: TRIM_HORIZON, LATEST. Triggers replacement.