The CDK Construct Library for AWS::IoT
Project description
AWS IoT Construct Library
---The APIs of higher level constructs in this module are experimental and under active development. They are subject to non-backward compatible changes or removal in any future version. These are not subject to the Semantic Versioning model and breaking changes will be announced in the release notes. 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.
AWS IoT Core lets you connect billions of IoT devices and route trillions of messages to AWS services without managing infrastructure.
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_LATEST,
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-alpha for other actions.
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
Hashes for aws-cdk.aws-iot-alpha-2.111.0a0.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 931223b9500482f98e9d9940c2fe2b4df77d8c1d2b101723be88e502ad32d21d |
|
MD5 | eec5ec42d9c0bf51f3505c9cbcf68822 |
|
BLAKE2b-256 | 680e23c7eef1e536b3221212dd865dc8258f593be42ee7817d61e3dab88b8973 |
Hashes for aws_cdk.aws_iot_alpha-2.111.0a0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 161886461771ef4ba30aa10b93a818b001f91c711aea97cb4b9ef866bf10eff0 |
|
MD5 | e0a05770f82b00a3c38b05223e595bd3 |
|
BLAKE2b-256 | d4149ce51a25c7bddc7bddfa498014f23500feaf310faf93ae5f032ff8d8bc52 |