FirehoseSubscription

class aws_cdk.aws_sns_subscriptions.FirehoseSubscription(delivery_stream, *, raw_message_delivery=None, role=None, dead_letter_queue=None, filter_policy=None, filter_policy_with_message_body=None)

Bases: object

Use an Amazon Data Firehose delivery stream as a subscription target.

See:: https://docs.aws.amazon.com/sns/latest/dg/sns-firehose-as-subscriber.html
ExampleMetadata:: infused

Example:

import aws_cdk.aws_kinesisfirehose as firehose
# stream: firehose.DeliveryStream

my_topic = sns.Topic(self, "Topic")

my_topic.add_subscription(subscriptions.FirehoseSubscription(stream))

Parameters:

delivery_stream (IDeliveryStream)
raw_message_delivery (Optional[bool]) – Whether to remove any Amazon SNS metadata from published messages. Default: false
role (Optional[IRole]) – The role to assume to write messages to the Amazon Data Firehose delivery stream. Default: - A new Role is created
dead_letter_queue (Optional[IQueue]) – Queue to be used as dead letter queue. If not passed no dead letter queue is enabled. Default: - No dead letter queue enabled.
filter_policy (Optional[Mapping[str, SubscriptionFilter]]) – The filter policy. Default: - all messages are delivered
filter_policy_with_message_body (Optional[Mapping[str, FilterOrPolicy]]) – The filter policy that is applied on the message body. To apply a filter policy to the message attributes, use filterPolicy. A maximum of one of filterPolicyWithMessageBody and filterPolicy may be used. Default: - all messages are delivered

Methods

bind(topic)

Returns a configuration for a Lambda function to subscribe to an SNS topic.

Parameters:: topic (ITopic)
Return type:: TopicSubscriptionConfig