AWS IoT Construct Library

---

End-of-Support

AWS CDK v1 has reached End-of-Support on 2023-06-01. This package is no longer being updated, and users should migrate to AWS CDK v2.

For more information on how to migrate, see the Migrating to AWS CDK v2 guide.

AWS IoT Core lets you connect billions of IoT devices and route trillions of messages to AWS services without managing infrastructure.

Installation

Install the module:

$ npm i @aws-cdk/aws-iot

Import it into your code:

import aws_cdk.aws_iot as iot
import aws_cdk.aws_iot_actions as actions

`TopicRule`

Create a topic rule that give your devices the ability to interact with AWS services. You can create a topic rule with an action that invoke the Lambda action as following:

func = lambda_.Function(self, "MyFunction",
    runtime=lambda_.Runtime.NODEJS_14_X,
    handler="index.handler",
    code=lambda_.Code.from_inline("""
            exports.handler = (event) => {
              console.log("It is test for lambda action of AWS IoT Rule.", event);
            };""")
)

iot.TopicRule(self, "TopicRule",
    topic_rule_name="MyTopicRule",  # optional
    description="invokes the lambda function",  # optional
    sql=iot.IotSql.from_string_as_ver20160323("SELECT topic(2) as device_id, timestamp() as timestamp FROM 'device/+/data'"),
    actions=[actions.LambdaFunctionAction(func)]
)

Or, you can add an action after constructing the TopicRule instance as following:

# func: lambda.Function


topic_rule = iot.TopicRule(self, "TopicRule",
    sql=iot.IotSql.from_string_as_ver20160323("SELECT topic(2) as device_id, timestamp() as timestamp FROM 'device/+/data'")
)
topic_rule.add_action(actions.LambdaFunctionAction(func))

You can also supply errorAction as following, and the IoT Rule will trigger it if a rule's action is unable to perform:

import aws_cdk.aws_logs as logs


log_group = logs.LogGroup(self, "MyLogGroup")

iot.TopicRule(self, "TopicRule",
    sql=iot.IotSql.from_string_as_ver20160323("SELECT topic(2) as device_id, timestamp() as timestamp FROM 'device/+/data'"),
    error_action=actions.CloudWatchLogsAction(log_group)
)

If you wanna make the topic rule disable, add property enabled: false as following:

iot.TopicRule(self, "TopicRule",
    sql=iot.IotSql.from_string_as_ver20160323("SELECT topic(2) as device_id, timestamp() as timestamp FROM 'device/+/data'"),
    enabled=False
)

See also @aws-cdk/aws-iot-actions for other actions.

Release files for aws-cdk.aws-iot 1.204.0

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for aws-cdk.aws-iot 1.204.0
File	Size	Uploaded
aws-cdk.aws-iot-1.204.0.tar.gz	509.3 kB	Jun 19, 2023	Details

Built distribution (wheel)

Table of built distributions (wheels) for aws-cdk.aws-iot 1.204.0
File	Interpreter	ABI	Platform	Reset
aws_cdk.aws_iot-1.204.0-py3-none-any.whl 511.1 kB Jun 19, 2023	Python 3	none	any	Details

Total release size: 1.0 MB

Release files / aws-cdk.aws-iot-1.204.0.tar.gz

Download URL	aws-cdk.aws-iot-1.204.0.tar.gz
Size	509.3 kB
Tags	Source
SHA-256 checksum How to use checksums	`d245a60d08d829e56a38315dd170df568c2e9c8639113a0296bb21b57c467874`
BLAKE2b-256 checksum How to use checksums	`bd21280ef0c9ce7f6990f68e7f687dc4e6ffd31f352182ee7bf920b2f16ae299`
Upload date	Jun 19, 2023
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/4.0.2 CPython/3.11.2`

Release files / aws_cdk.aws_iot-1.204.0-py3-none-any.whl

Download URL	aws_cdk.aws_iot-1.204.0-py3-none-any.whl
Size	511.1 kB
Tags	Python 3
SHA-256 checksum How to use checksums	`7ac014fdd63c456b17bee36371c97980a4cd07ee652c3f5ec633a39f22e96377`
BLAKE2b-256 checksum How to use checksums	`a44eb9449bfbb3f0a91e01d3d9d5605c6d7c8e397718d97b5eb6e58df8b948cf`
Upload date	Jun 19, 2023
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/4.0.2 CPython/3.11.2`