DynamicPartitioningProps

class aws_cdk.aws_kinesisfirehose.DynamicPartitioningProps(*, enabled, retry_duration=None)

Bases: object

Props for defining dynamic partitioning.

Parameters:

enabled (bool) – Whether to enable the dynamic partitioning. You cannot enable dynamic partitioning for an existing Firehose stream that does not have dynamic partitioning already enabled.
retry_duration (Optional[Duration]) – The total amount of time that Data Firehose spends on retries. Minimum: Duration.seconds(0) Maximum: Duration.seconds(7200) Default: Duration.seconds(300)

See:

https://docs.aws.amazon.com/firehose/latest/dev/dynamic-partitioning.html

ExampleMetadata:

infused

Example:

# bucket: s3.Bucket

s3_destination = firehose.S3Bucket(bucket,
    dynamic_partitioning=firehose.DynamicPartitioningProps(enabled=True),
    processors=[
        firehose.RecordDeAggregationProcessor.delimited("####")
    ]
)

Attributes

enabled

Whether to enable the dynamic partitioning.

You cannot enable dynamic partitioning for an existing Firehose stream that does not have dynamic partitioning already enabled.

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

retry_duration

The total amount of time that Data Firehose spends on retries.

Minimum: Duration.seconds(0) Maximum: Duration.seconds(7200)

Default:: Duration.seconds(300)