Package software.amazon.awscdk.services.iot


@Stability(Experimental) @Deprecated package software.amazon.awscdk.services.iot
Deprecated.

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 software.amazon.awscdk.services.iot.*;
 import software.amazon.awscdk.services.iot.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:

 Function func = Function.Builder.create(this, "MyFunction")
         .runtime(Runtime.NODEJS_14_X)
         .handler("index.handler")
         .code(Code.fromInline("\n    exports.handler = (event) => {\n      console.log(\"It is test for lambda action of AWS IoT Rule.\", event);\n    };"))
         .build();
 
 TopicRule.Builder.create(this, "TopicRule")
         .topicRuleName("MyTopicRule") // optional
         .description("invokes the lambda function") // optional
         .sql(IotSql.fromStringAsVer20160323("SELECT topic(2) as device_id, timestamp() as timestamp FROM 'device/+/data'"))
         .actions(List.of(new LambdaFunctionAction(func)))
         .build();
 

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

 Function func;
 
 
 TopicRule topicRule = TopicRule.Builder.create(this, "TopicRule")
         .sql(IotSql.fromStringAsVer20160323("SELECT topic(2) as device_id, timestamp() as timestamp FROM 'device/+/data'"))
         .build();
 topicRule.addAction(new 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 software.amazon.awscdk.services.logs.*;
 
 
 LogGroup logGroup = new LogGroup(this, "MyLogGroup");
 
 TopicRule.Builder.create(this, "TopicRule")
         .sql(IotSql.fromStringAsVer20160323("SELECT topic(2) as device_id, timestamp() as timestamp FROM 'device/+/data'"))
         .errorAction(new CloudWatchLogsAction(logGroup))
         .build();
 

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

 TopicRule.Builder.create(this, "TopicRule")
         .sql(IotSql.fromStringAsVer20160323("SELECT topic(2) as device_id, timestamp() as timestamp FROM 'device/+/data'"))
         .enabled(false)
         .build();
 

See also @aws-cdk/aws-iot-actions for other actions. Deprecated: 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 https://docs.aws.amazon.com/cdk/v2/guide/migrating-v2.html