StreamConsumerProps

class aws_cdk.aws_kinesis.StreamConsumerProps(*, stream, stream_consumer_name)

Bases: object

Properties for a Kinesis Stream Consumer.

Parameters:

stream (IStream) – The Kinesis data stream to associate this consumer with.
stream_consumer_name (str) – The name of the stream consumer.

ExampleMetadata:

infused

Example:

lambda_role = iam.Role(self, "Role",
    assumed_by=iam.ServicePrincipal("lambda.amazonaws.com"),
    description="Example role..."
)

stream = kinesis.Stream(self, "MyEncryptedStream",
    encryption=kinesis.StreamEncryption.KMS
)
stream_consumer = kinesis.StreamConsumer(self, "MyStreamConsumer",
    stream_consumer_name="MyStreamConsumer",
    stream=stream
)

# give lambda permissions to read stream via the stream consumer
stream_consumer.grant_read(lambda_role)

Attributes

stream: The Kinesis data stream to associate this consumer with.

stream_consumer_name: The name of the stream consumer.