interface DataProcessorProps ⚠️

Language	Type name
.NET	Amazon.CDK.AWS.KinesisFirehose.Alpha.DataProcessorProps
Go	github.com/aws/aws-cdk-go/awscdkkinesisfirehosealpha/v2#DataProcessorProps
Java	software.amazon.awscdk.services.kinesisfirehose.alpha.DataProcessorProps
Python	aws_cdk.aws_kinesisfirehose_alpha.DataProcessorProps
TypeScript (source)	@aws-cdk/aws-kinesisfirehose-alpha » DataProcessorProps

⚠️ Deprecated: undefined

Configure the data processor.

Example

// Provide a Lambda function that will transform records before delivery, with custom
// buffering and retry configuration
const lambdaFunction = new lambda.Function(this, 'Processor', {
  runtime: lambda.Runtime.NODEJS_LATEST,
  handler: 'index.handler',
  code: lambda.Code.fromAsset(path.join(__dirname, 'process-records')),
});
const lambdaProcessor = new firehose.LambdaFunctionProcessor(lambdaFunction, {
  bufferInterval: Duration.minutes(5),
  bufferSize: Size.mebibytes(5),
  retries: 5,
});
declare const bucket: s3.Bucket;
const s3Destination = new destinations.S3Bucket(bucket, {
  processor: lambdaProcessor,
});
new firehose.DeliveryStream(this, 'Delivery Stream', {
  destination: s3Destination,
});

Properties

Name	Type	Description
bufferInterval?⚠️	Duration	The length of time Kinesis Data Firehose will buffer incoming data before calling the processor.
bufferSize?⚠️	Size	The amount of incoming data Kinesis Data Firehose will buffer before calling the processor.
retries?⚠️	number	The number of times Kinesis Data Firehose will retry the processor invocation after a failure due to network timeout or invocation limits.

---

bufferInterval?⚠️

⚠️ Deprecated: undefined

Type: Duration (optional, default: Duration.minutes(1))

The length of time Kinesis Data Firehose will buffer incoming data before calling the processor.

s

---

bufferSize?⚠️

⚠️ Deprecated: undefined

Type: Size (optional, default: Size.mebibytes(3))

The amount of incoming data Kinesis Data Firehose will buffer before calling the processor.

---

retries?⚠️

⚠️ Deprecated: undefined

Type: number (optional, default: 3)

The number of times Kinesis Data Firehose will retry the processor invocation after a failure due to network timeout or invocation limits.