Package software.amazon.awscdk.services.kinesisfirehose.alpha

Class LambdaFunctionProcessor

java.lang.Object
software.amazon.jsii.JsiiObject
software.amazon.awscdk.services.kinesisfirehose.alpha.LambdaFunctionProcessor
All Implemented Interfaces:
IDataProcessor, software.amazon.jsii.JsiiSerializable
@Generated(value="jsii-pacmak/1.109.0 (build c221850)", date="2025-03-19T18:01:45.145Z") @Stability(Deprecated) @Deprecated public class LambdaFunctionProcessor extends software.amazon.jsii.JsiiObject implements IDataProcessor
Deprecated.
(deprecated) Use an AWS Lambda function to transform records.

Example: 

 Bucket bucket;
 // Provide a Lambda function that will transform records before delivery, with custom
 // buffering and retry configuration
 Function lambdaFunction = Function.Builder.create(this, "Processor")
         .runtime(Runtime.NODEJS_LATEST)
         .handler("index.handler")
         .code(Code.fromAsset(join(__dirname, "process-records")))
         .build();
 LambdaFunctionProcessor lambdaProcessor = LambdaFunctionProcessor.Builder.create(lambdaFunction)
         .bufferInterval(Duration.minutes(5))
         .bufferSize(Size.mebibytes(5))
         .retries(5)
         .build();
 S3Bucket s3Destination = S3Bucket.Builder.create(bucket)
         .processor(lambdaProcessor)
         .build();
 DeliveryStream.Builder.create(this, "Delivery Stream")
         .destination(s3Destination)
         .build();

  • Constructor Details

    • LambdaFunctionProcessor

      protected LambdaFunctionProcessor(software.amazon.jsii.JsiiObjectRef objRef)
      Deprecated.

    • LambdaFunctionProcessor

      protected LambdaFunctionProcessor(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)
      Deprecated.

    • LambdaFunctionProcessor

      @Stability(Deprecated) @Deprecated public LambdaFunctionProcessor(@NotNull IFunction lambdaFunction, @Nullable DataProcessorProps props)
      Deprecated.
      Parameters:
      lambdaFunction - This parameter is required.
      props - The constructor props of the DataProcessor.

    • LambdaFunctionProcessor

      @Stability(Deprecated) @Deprecated public LambdaFunctionProcessor(@NotNull IFunction lambdaFunction)
      Deprecated.
      Parameters:
      lambdaFunction - This parameter is required.

  • Method Details

    • bind

      @Stability(Deprecated) @Deprecated @NotNull public DataProcessorConfig bind(@NotNull software.constructs.Construct _scope, @NotNull DataProcessorBindOptions options)
      Deprecated.
      (deprecated) Binds this processor to a destination of a delivery stream.

      Implementers should use this method to grant processor invocation permissions to the provided stream and return the necessary configuration to register as a processor.

      Specified by:
      bind in interface IDataProcessor
      Parameters:
      _scope - This parameter is required.
      options - This parameter is required.

    • getProps

      @Stability(Deprecated) @Deprecated @NotNull public DataProcessorProps getProps()
      Deprecated.
      (deprecated) The constructor props of the LambdaFunctionProcessor.
      Specified by:
      getProps in interface IDataProcessor