class CloudWatchLogProcessor

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

Implements IDataProcessor

The data processor to extract message after decompression of CloudWatch Logs.

This processor must used with DecompressionProcessor

See also: https://docs.aws.amazon.com/firehose/latest/dev/Message_extraction.html

Example

declare const bucket: s3.Bucket;
const s3Destination = new firehose.S3Bucket(bucket, {
  processors: [
    new firehose.DecompressionProcessor(),
    new firehose.CloudWatchLogProcessor({ dataMessageExtraction: true }),
  ],
});
new firehose.DeliveryStream(this, 'Delivery Stream', {
  destination: s3Destination,
});

Initializer

new CloudWatchLogProcessor(options: CloudWatchLogProcessorOptions)

Parameters

• options CloudWatchLogProcessorOptions

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.

---

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.