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.103.1 (build bef2dea)",
date="2024-09-11T18:01:25.731Z")
@Stability(Experimental)
public class LambdaFunctionProcessor
extends software.amazon.jsii.JsiiObject
implements IDataProcessor
(experimental) 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") .destinations(List.of(s3Destination)) .build();
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final class
(experimental) A fluent builder forLambdaFunctionProcessor
.Nested classes/interfaces inherited from class software.amazon.jsii.JsiiObject
software.amazon.jsii.JsiiObject.InitializationMode
Nested classes/interfaces inherited from interface software.amazon.awscdk.services.kinesisfirehose.alpha.IDataProcessor
IDataProcessor.Jsii$Default, IDataProcessor.Jsii$Proxy
-
Constructor Summary
ConstructorsModifierConstructorDescriptionLambdaFunctionProcessor
(IFunction lambdaFunction) LambdaFunctionProcessor
(IFunction lambdaFunction, DataProcessorProps props) protected
LambdaFunctionProcessor
(software.amazon.jsii.JsiiObject.InitializationMode initializationMode) protected
LambdaFunctionProcessor
(software.amazon.jsii.JsiiObjectRef objRef) -
Method Summary
Modifier and TypeMethodDescriptionbind
(software.constructs.Construct _scope, DataProcessorBindOptions options) (experimental) Binds this processor to a destination of a delivery stream.getProps()
(experimental) The constructor props of the LambdaFunctionProcessor.Methods inherited from class software.amazon.jsii.JsiiObject
jsiiAsyncCall, jsiiAsyncCall, jsiiCall, jsiiCall, jsiiGet, jsiiGet, jsiiSet, jsiiStaticCall, jsiiStaticCall, jsiiStaticGet, jsiiStaticGet, jsiiStaticSet, jsiiStaticSet
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface software.amazon.jsii.JsiiSerializable
$jsii$toJson
-
Constructor Details
-
LambdaFunctionProcessor
protected LambdaFunctionProcessor(software.amazon.jsii.JsiiObjectRef objRef) -
LambdaFunctionProcessor
protected LambdaFunctionProcessor(software.amazon.jsii.JsiiObject.InitializationMode initializationMode) -
LambdaFunctionProcessor
@Stability(Experimental) public LambdaFunctionProcessor(@NotNull IFunction lambdaFunction, @Nullable DataProcessorProps props) - Parameters:
lambdaFunction
- This parameter is required.props
- The constructor props of the DataProcessor.
-
LambdaFunctionProcessor
- Parameters:
lambdaFunction
- This parameter is required.
-
-
Method Details
-
bind
@Stability(Experimental) @NotNull public DataProcessorConfig bind(@NotNull software.constructs.Construct _scope, @NotNull DataProcessorBindOptions options) (experimental) 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 interfaceIDataProcessor
- Parameters:
_scope
- This parameter is required.options
- This parameter is required.
-
getProps
(experimental) The constructor props of the LambdaFunctionProcessor.- Specified by:
getProps
in interfaceIDataProcessor
-