Class DataProcessorProps

(experimental) Configure the data processor.

Inheritance

System.Object

DataProcessorProps

Implements

IDataProcessorProps

Namespace: Amazon.CDK.AWS.KinesisFirehose.Alpha

Assembly: Amazon.CDK.AWS.KinesisFirehose.Alpha.dll

Syntax (csharp)

public class DataProcessorProps : Object, IDataProcessorProps

Syntax (vb)

Public Class DataProcessorProps
    Inherits Object
    Implements IDataProcessorProps

Remarks

Stability: Experimental

ExampleMetadata: infused

Examples

Bucket bucket;
// Provide a Lambda function that will transform records before delivery, with custom
// buffering and retry configuration
var lambdaFunction = new Function(this, "Processor", new FunctionProps {
    Runtime = Runtime.NODEJS_LATEST,
    Handler = "index.handler",
    Code = Code.FromAsset(Join(__dirname, "process-records"))
});
var lambdaProcessor = new LambdaFunctionProcessor(lambdaFunction, new DataProcessorProps {
    BufferInterval = Duration.Minutes(5),
    BufferSize = Size.Mebibytes(5),
    Retries = 5
});
var s3Destination = new S3Bucket(bucket, new S3BucketProps {
    Processor = lambdaProcessor
});
new DeliveryStream(this, "Delivery Stream", new DeliveryStreamProps {
    Destination = s3Destination
});

Synopsis

Constructors

DataProcessorProps()

Properties

BufferInterval	(experimental) The length of time Kinesis Data Firehose will buffer incoming data before calling the processor.
BufferSize	(experimental) The amount of incoming data Kinesis Data Firehose will buffer before calling the processor.
Retries	(experimental) The number of times Kinesis Data Firehose will retry the processor invocation after a failure due to network timeout or invocation limits.

Constructors

DataProcessorProps()

public DataProcessorProps()

Properties

BufferInterval

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

public Duration BufferInterval { get; set; }

Property Value

Duration

Remarks

s

Default: Duration.minutes(1)

Stability: Experimental

BufferSize

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

public Size BufferSize { get; set; }

Property Value

Size

Remarks

Default: Size.mebibytes(3)

Stability: Experimental

Retries

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

public Nullable<double> Retries { get; set; }

Property Value

System.Nullable<System.Double>

Remarks

Default: 3

Stability: Experimental

Implements

IDataProcessorProps