(iot): TopicRule action for Step Functions in AWS IoT

[yamatatsu]

Description

The CDK has no support to trigger Step Functions via AWS IoT Rule.

Use Case

Adding the action that triggers Step Functions to AWS IoT topic rule.

Proposed Solution

Implementing action class.

Probably, following PRs help coding.

• feat(iot): add Action to capture CloudWatch metrics #17503
• feat(iot): add Action to put records to a Firehose stream #17466
• feat(iot): add Action to put objects in S3 Buckets #17307

Other information

Follofing documentation will be help.

• https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-iot-topicrule-stepfunctionsaction.html

It will be good first issue for learning implement feature in CDK!

Acknowledge

• I may be able to implement this feature request
• This feature might incur a breaking change

[sholtomaud]

any update on this issue? Has the feature been implemented in v2?

[yamatatsu]

@sholtomaud Nope yet. But you can use escape-hatch as following:

import * as iot from '@aws-cdk/aws-iot-alpha';

const stateMachine = new new sfn.StateMachine(this, 'StateMachine', {
  definition,
});

const role = new iam.Role(this, 'MyRole', {
  assumedBy: new iam.ServicePrincipal('iot.amazonaws.com'),
});
stateMachine.grantStartExecution(role);

new iot.TopicRule(this, 'TopicRule', {
  sql: iot.IotSql.fromStringAsVer20151008("SELECT topic(2) as device_id FROM 'device/+/data'"),
  actions: [
    {
      bind: () => ({
        configuration: {
          stepFunctions: {
            stateMachineName: stateMachine.stateMachineName,
            executionNamePrefix: "myExecution", // optional
            roleArn: role.roleArn,
          }
        },
      }),
    },
  ],
});

This example needs to install @aws-cdk/aws-iot-alpha if you are using aws-cdk v2.

[sholtomaud]

Ok, looks interesting.

[Bakhoj]

Is there a dirty fix when using python?

[github-actions]

⚠️COMMENT VISIBILITY WARNING⚠️

Comments on closed issues are hard for our team to see.
If you need more assistance, please either tag a team member or open a new issue that references this one.
If you wish to keep having a conversation with other community members under this issue feel free to do so.