Class DataProcessorProps

Configure the data processor.

Inheritance

object

DataProcessorProps

Implements

IDataProcessorProps

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Amazon.CDK.AWS.KinesisFirehose

Assembly: Amazon.CDK.Lib.dll

Syntax (csharp)

public class DataProcessorProps : IDataProcessorProps

Syntax (vb)

Public Class DataProcessorProps Implements IDataProcessorProps

Remarks

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()

Configure the data processor.

Properties

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

Constructors

DataProcessorProps()

Configure the data processor.

public DataProcessorProps()

Remarks

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
            });

Properties

BufferInterval

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

public Duration? BufferInterval { get; set; }

Property Value

Duration

Remarks

Default: Duration.minutes(1)

BufferSize

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

public Size? BufferSize { get; set; }

Property Value

Size

Remarks

Default: Size.mebibytes(3)

Retries

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

public double? Retries { get; set; }

Property Value

double?

Remarks

Default: 3

Implements

IDataProcessorProps