stream_consumers

Creates, updates, deletes or gets a stream_consumer resource or lists stream_consumers in a region

Overview

Name	stream_consumers
Type	Resource
Description	Resource Type definition for AWS::Kinesis::StreamConsumer
Id	awscc.kinesis.stream_consumers

Fields

Name	Datatype	Description
consumer_creation_timestamp	string	Timestamp when the consumer was created.
consumer_name	string	The name of the Kinesis Stream Consumer. For a given Kinesis data stream, each consumer must have a unique name. However, consumer names don't have to be unique across data streams.
consumer_arn	string	The ARN returned by Kinesis Data Streams when you registered the consumer. If you don't know the ARN of the consumer that you want to deregister, you can use the ListStreamConsumers operation to get a list of the descriptions of all the consumers that are currently registered with a given data stream. The description of a consumer contains its ARN.
consumer_status	string	A consumer can't read data while in the CREATING or DELETING states. Valid Values: CREATING | DELETING | ACTIVE
stream_arn	string	The Amazon resource name (ARN) of the Kinesis data stream that you want to register the consumer with.
▶tags	array	An arbitrary set of tags (key–value pairs) to associate with the Kinesis consumer.
region	string	AWS region.

For more information, see AWS::Kinesis::StreamConsumer.

Methods

Name	Accessible by	Required Params
create_resource	INSERT	ConsumerName, StreamARN, region
delete_resource	DELETE	data__Identifier, region
list_resources	SELECT	region
get_resource	SELECT	data__Identifier, region

SELECT examples

Gets all properties from an individual stream_consumer.

SELECT
region,
consumer_creation_timestamp,
consumer_name,
consumer_arn,
consumer_status,
stream_arn,
tags
FROM awscc.kinesis.stream_consumers
WHERE region = 'us-east-1' AND data__Identifier = '<ConsumerARN>';

INSERT example

Use the following StackQL query and manifest file to create a new stream_consumer resource, using stack-deploy.

Required Properties

/*+ create */
INSERT INTO awscc.kinesis.stream_consumers (
 ConsumerName,
 StreamARN,
 region
)
SELECT 
'{{ ConsumerName }}',
 '{{ StreamARN }}',
'{{ region }}';

All Properties

/*+ create */
INSERT INTO awscc.kinesis.stream_consumers (
 ConsumerName,
 StreamARN,
 Tags,
 region
)
SELECT 
 '{{ ConsumerName }}',
 '{{ StreamARN }}',
 '{{ Tags }}',
 '{{ region }}';

Manifest

version: 1
name: stack name
description: stack description
providers:
  - aws
globals:
  - name: region
    value: '{{ vars.AWS_REGION }}'
resources:
  - name: stream_consumer
    props:
      - name: ConsumerName
        value: '{{ ConsumerName }}'
      - name: StreamARN
        value: '{{ StreamARN }}'
      - name: Tags
        value:
          - Value: '{{ Value }}'
            Key: '{{ Key }}'

DELETE example

/*+ delete */
DELETE FROM awscc.kinesis.stream_consumers
WHERE data__Identifier = '<ConsumerARN>'
AND region = 'us-east-1';

Permissions

To operate on the stream_consumers resource, the following permissions are required:

Read

kinesis:DescribeStreamConsumer,
kinesis:ListTagsForResource

Create

kinesis:RegisterStreamConsumer,
kinesis:DescribeStreamConsumer,
kinesis:TagResource

List

kinesis:ListStreamConsumers

Delete

kinesis:DeregisterStreamConsumer,
kinesis:DescribeStreamConsumer,
kinesis:UntagResource