interface DataProcessorProps

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

Configure the LambdaFunctionProcessor.

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 firehose.S3Bucket(bucket, {
  processors: [lambdaProcessor],
});
new firehose.DeliveryStream(this, 'Delivery Stream', {
  destination: s3Destination,
});

Properties

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

---

bufferInterval?

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

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

s

---

bufferSize?

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

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

---

retries?

Type: number (optional, default: 3)

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