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,
          }
        },
      }),
    },
  ],
});