AppendDelimiterToRecordProcessor

class aws_cdk.aws_kinesisfirehose.AppendDelimiterToRecordProcessor

Bases: object

The data processor to append new line delimiter to each record.

See:: https://docs.aws.amazon.com/firehose/latest/dev/dynamic-partitioning-s3bucketprefix.html#dynamic-partitioning-new-line-delimiter
ExampleMetadata:: infused

Example:

# bucket: s3.Bucket

s3_destination = firehose.S3Bucket(bucket,
    processors=[
        firehose.AppendDelimiterToRecordProcessor()
    ]
)
firehose.DeliveryStream(self, "Delivery Stream",
    destination=s3_destination
)

Methods

bind(_scope, *, role, dynamic_partitioning_enabled=None, prefix=None)

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.

Parameters:

_scope (Construct)
role (IRole) – The IAM role assumed by Amazon Data Firehose to write to the destination that this DataProcessor will bind to.
dynamic_partitioning_enabled (Optional[bool]) – Whether the dynamic partitioning is enabled. Default: false
prefix (Optional[str]) – S3 bucket prefix. Default: - No prefix

Return type:

DataProcessorConfig

Attributes

props: The constructor props of the DataProcessor.