class RecordDeAggregationProcessor

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

Implements IDataProcessor

The data processor for multi record deaggrecation.

Record deaggregation by JSON or by delimiter is capped at 500 per record.

See also: https://docs.aws.amazon.com/firehose/latest/dev/dynamic-partitioning-multirecord-deaggergation.html

Example

declare const bucket: s3.Bucket;
const s3Destination = new firehose.S3Bucket(bucket, {
  dynamicPartitioning: { enabled: true },
  processors: [
    firehose.RecordDeAggregationProcessor.json(),
  ],
});

Initializer

new RecordDeAggregationProcessor(options: RecordDeAggregationProcessorOptions)

Parameters

• options RecordDeAggregationProcessorOptions

Properties

Name	Type	Description
props	DataProcessorProps	The constructor props of the DataProcessor.

---

props

Type: DataProcessorProps

The constructor props of the DataProcessor.

Methods

Name	Description
bind(scope, options)	Binds this processor to a destination of a delivery stream.
static delimited(delimiter)	Perform deaggregation based on a specified custom delimiter.
static json()	Perform deaggregation from JSON objects on a single line with no delimiter or newline-delimited (JSONL).

---

bind(scope, options)

public bind(scope: Construct, options: DataProcessorBindOptions): DataProcessorConfig

Parameters

• scope Construct
• options DataProcessorBindOptions

Returns

• DataProcessorConfig

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.

---

static delimited(delimiter)

public static delimited(delimiter: string): RecordDeAggregationProcessor

Parameters

• delimiter string — The custom delimiter.

Returns

• RecordDeAggregationProcessor

Perform deaggregation based on a specified custom delimiter.

---

static json()

public static json(): RecordDeAggregationProcessor

Returns

• RecordDeAggregationProcessor

Perform deaggregation from JSON objects on a single line with no delimiter or newline-delimited (JSONL).