Skip to main content

CDK Constructs for AWS IoT to AWS Kinesis Data Stream.

Project description

aws-iot-kinesisstreams module

---

Stability: Experimental

All classes are under active development and subject to non-backward compatible changes or removal in any future version. These are not subject to the Semantic Versioning model. This means that while you may use them, you may need to update your source code when upgrading to a newer version of this package.


Reference Documentation: https://docs.aws.amazon.com/solutions/latest/constructs/
Language Package
Python Logo Python aws_solutions_constructs.aws_iot_kinesisstreams
Typescript Logo Typescript @aws-solutions-constructs/aws-iot-kinesisstreams
Java Logo Java software.amazon.awsconstructs.services.iotkinesisstreams

This AWS Solutions Construct implements an AWS IoT MQTT topic rule to send data to an Amazon Kinesis Data Stream.

Here is a minimal deployable pattern definition in Typescript:

const { IotToKinesisStreamsProps,
        IotToKinesisStreams } from '@aws-solutions-constructs/aws-iot-kinesisstreams';

const props: IotToKinesisStreamsProps = {
    iotTopicRuleProps: {
        topicRulePayload: {
            ruleDisabled: false,
            description: "Sends data to kinesis data stream",
            sql: "SELECT * FROM 'solutions/construct'",
            actions: []
        }
    }
};

new IotToKinesisStreams(this, 'test-iot-kinesisstream', props);

Initializer

new IotToKinesisStreams(scope: Construct, id: string, props: IotToKinesisStreamsProps);

Parameters

Pattern Construct Props

Name Type Description
iotTopicRuleProps iot.CfnTopicRuleProps User provided CfnTopicRuleProps to override the defaults
existingStreamObj? kinesis.Stream Existing instance of Kinesis Stream, providing both this and kinesisStreamProps will cause an error.
kinesisStreamProps? kinesis.StreamProps Optional user-provided props to override the default props for the Kinesis data stream, providing both this and existingStreamObj will cause an error
createCloudWatchAlarms boolean Whether to create recommended CloudWatch alarms for Kinesis Data Stream. Default value is set to true

Pattern Properties

Name Type Description
iotTopicRule iot.CfnTopicRule Returns an instance of iot.CfnTopicRule created by the construct
iotActionsRole iam.Role Returns an instance of the iam.Role created by the construct for IoT Rule
kinesisStream kinesis.Stream Returns an instance of the Kinesis stream created by the construct.
cloudwatchAlarms? cloudwatch.Alarm[] Returns an array of recommended CloudWatch Alarms created by the construct for Kinesis Data stream

Default settings

Out of the box implementation of the Construct without any override will set the following defaults:

Amazon IoT Rule

  • Configure least privilege access IAM role for Amazon IoT Rule

Amazon Kinesis Data Stream

  • Configure recommended CloudWatch Alarms for Amazon Kinesis Data Stream
  • Configure least privilege access IAM role for Amazon Kinesis Data Stream

Architecture

Architecture Diagram


© Copyright 2021 Amazon.com, Inc. or its affiliates. All Rights Reserved.

Project details


Release history Release notifications | RSS feed

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

File details

Details for the file aws-solutions-constructs.aws-iot-kinesisstreams-2.2.0.tar.gz.

File metadata

File hashes

Hashes for aws-solutions-constructs.aws-iot-kinesisstreams-2.2.0.tar.gz
Algorithm Hash digest
SHA256 011a20846f8fd294abb7ac8b63b9742eddd3465457c3a3e6c3d1cefe62e661f7
MD5 e3c37091f6007de8768ceeebe009e36f
BLAKE2b-256 d8c4ea7494082f14bdc342dcc575f25c1cdf8599260fcb5d2588389ab850e528

See more details on using hashes here.

File details

Details for the file aws_solutions_constructs.aws_iot_kinesisstreams-2.2.0-py3-none-any.whl.

File metadata

File hashes

Hashes for aws_solutions_constructs.aws_iot_kinesisstreams-2.2.0-py3-none-any.whl
Algorithm Hash digest
SHA256 5683074385ca2623bf2d4963e8fcf08aaa4904f1e19802c692813c813523737f
MD5 bed37dcb8ab6d4a7d3a8de4dfd3578ce
BLAKE2b-256 da402470d743bdc4c075fabb9367b338e447ab6fb2d61a8421e2bc4fd170288a

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page