@Generated(value="jsii-pacmak/1.63.2 (build a8a8833)",
date="2022-08-09T19:16:39.150Z")
public interface DataProcessorProps
Example:
import path.*; import software.amazon.awscdk.services.kinesisfirehose.*; import software.amazon.awscdk.services.kms.*; import software.amazon.awscdk.services.lambda.nodejs.*; import software.amazon.awscdk.services.logs.*; import software.amazon.awscdk.services.s3.*; import software.amazon.awscdk.core.*; import software.amazon.awscdk.services.kinesisfirehose.destinations.*; App app = new App(); Stack stack = new Stack(app, "aws-cdk-firehose-delivery-stream-s3-all-properties"); Bucket bucket = Bucket.Builder.create(stack, "Bucket") .removalPolicy(RemovalPolicy.DESTROY) .autoDeleteObjects(true) .build(); Bucket backupBucket = Bucket.Builder.create(stack, "BackupBucket") .removalPolicy(RemovalPolicy.DESTROY) .autoDeleteObjects(true) .build(); LogGroup logGroup = LogGroup.Builder.create(stack, "LogGroup") .removalPolicy(RemovalPolicy.DESTROY) .build(); NodejsFunction dataProcessorFunction = NodejsFunction.Builder.create(stack, "DataProcessorFunction") .entry(join(__dirname, "lambda-data-processor.js")) .timeout(Duration.minutes(1)) .build(); LambdaFunctionProcessor processor = LambdaFunctionProcessor.Builder.create(dataProcessorFunction) .bufferInterval(Duration.seconds(60)) .bufferSize(Size.mebibytes(1)) .retries(1) .build(); Key key = Key.Builder.create(stack, "Key") .removalPolicy(RemovalPolicy.DESTROY) .build(); Key backupKey = Key.Builder.create(stack, "BackupKey") .removalPolicy(RemovalPolicy.DESTROY) .build(); DeliveryStream.Builder.create(stack, "Delivery Stream") .destinations(List.of(S3Bucket.Builder.create(bucket) .logging(true) .logGroup(logGroup) .processor(processor) .compression(Compression.GZIP) .dataOutputPrefix("regularPrefix") .errorOutputPrefix("errorPrefix") .bufferingInterval(Duration.seconds(60)) .bufferingSize(Size.mebibytes(1)) .encryptionKey(key) .s3Backup(DestinationS3BackupProps.builder() .mode(BackupMode.ALL) .bucket(backupBucket) .compression(Compression.ZIP) .dataOutputPrefix("backupPrefix") .errorOutputPrefix("backupErrorPrefix") .bufferingInterval(Duration.seconds(60)) .bufferingSize(Size.mebibytes(1)) .encryptionKey(backupKey) .build()) .build())) .build(); app.synth();
Modifier and Type | Interface and Description |
---|---|
static class |
DataProcessorProps.Builder
A builder for
DataProcessorProps |
static class |
DataProcessorProps.Jsii$Proxy
An implementation for
DataProcessorProps |
Modifier and Type | Method and Description |
---|---|
static DataProcessorProps.Builder |
builder() |
default Duration |
getBufferInterval()
(experimental) The length of time Kinesis Data Firehose will buffer incoming data before calling the processor.
|
default Size |
getBufferSize()
(experimental) The amount of incoming data Kinesis Data Firehose will buffer before calling the processor.
|
default java.lang.Number |
getRetries()
(experimental) The number of times Kinesis Data Firehose will retry the processor invocation after a failure due to network timeout or invocation limits.
|
default Duration getBufferInterval()
s
Default: Duration.minutes(1)
default Size getBufferSize()
Default: Size.mebibytes(3)
default java.lang.Number getRetries()
Default: 3
static DataProcessorProps.Builder builder()
DataProcessorProps.Builder
of DataProcessorProps