FirehoseRecordSeparator

class aws_cdk.aws_iot_actions.FirehoseRecordSeparator(value)

Bases: Enum

(experimental) Record Separator to be used to separate records.

Stability:

experimental

ExampleMetadata:

infused

Example:

import aws_cdk.aws_kinesisfirehose as firehose
import aws_cdk.aws_kinesisfirehose_destinations as destinations


bucket = s3.Bucket(self, "MyBucket")
stream = firehose.DeliveryStream(self, "MyStream",
    destinations=[destinations.S3Bucket(bucket)]
)

topic_rule = iot.TopicRule(self, "TopicRule",
    sql=iot.IotSql.from_string_as_ver20160323("SELECT * FROM 'device/+/data'"),
    actions=[
        actions.FirehosePutRecordAction(stream,
            batch_mode=True,
            record_separator=actions.FirehoseRecordSeparator.NEWLINE
        )
    ]
)

Attributes

COMMA

(experimental) Separate by a commma.

Stability:

experimental

NEWLINE

(experimental) Separate by a new line.

Stability:

experimental

TAB

(experimental) Separate by a tab.

Stability:

experimental

WINDOWS_NEWLINE

(experimental) Separate by a windows new line.

Stability:

experimental