feat(iot-actions): add support for DynamoDBv2 rule

packages/@aws-cdk/aws-iot-actions/README.md

@@ -31,6 +31,7 @@ Currently supported are:
 - Put records to Kinesis Data Firehose stream
 - Send messages to SQS queues
 - Publish messages on SNS topics
+- Write messages into columns of DynamoDB
 
 ## Republish a message to another MQTT topic
 
@@ -278,3 +279,40 @@ const topicRule = new iot.TopicRule(this, 'TopicRule', {
   ],
 });
 ```
+
+## Write attributes of a message to DynamoDB
+
+The code snippet below creates an AWS IoT rule that writes all or part of an 
+MQTT message to DynamoDB using the DynamoDBv2 action.
+
+```ts
+import * as dynamodb from '@aws-cdk/aws-dynamodb';
+
+const tablePartitionKey: dynamodb.Attribute = {
+  name: 'hashKey',
+  type: dynamodb.AttributeType.STRING,
+};
+
+const tableSortKey: dynamodb.Attribute = {
+  name: 'sortKey',
+  type: dynamodb.AttributeType.NUMBER,
+};
+
+const table = new dynamodb.Table(this, 'MyTable', {
+  tableName: 'MyTable',
+  readCapacity: 1,
+  writeCapacity: 1,
+  partitionKey: tablePartitionKey,
+  sortKey: tableSortKey,
+});
+
+const topicRule = new iot.TopicRule(this, 'TopicRule', {
+  sql: iot.IotSql.fromStringAsVer20160323(
+    "SELECT * FROM 'device/+/data'",
+  ),
+  actions: [
+    new actions.DynamoDBv2PutItemAction(table)
+  ],
+});
+
+```

packages/@aws-cdk/aws-iot-actions/lib/dynamo-db-v2-put-item.ts

@@ -0,0 +1,45 @@
+import * as dynamodb from '@aws-cdk/aws-dynamodb';
+import * as iam from '@aws-cdk/aws-iam';
+import * as iot from '@aws-cdk/aws-iot';
+import { CommonActionProps } from './common-action-props';
+import { singletonActionRole } from './private/role';
+
+/**
+ * Configuration properties of an action for the dynamodb table.
+ */
+export interface DynamoDBv2PutItemActionProps extends CommonActionProps {
+}
+
+
+/**
+ * The action to put the record from an MQTT message to the Kinesis Data Firehose stream.
+ */
+export class DynamoDBv2PutItemAction implements iot.IAction {
+  private readonly role?: iam.IRole;
+
+  /**
+   * @param table the DynamoDB table in which to put the items.
+   * @param props Optional properties to not use default
+   */
+  constructor(private readonly table: dynamodb.ITable, props: DynamoDBv2PutItemActionProps = {}) {
+    this.role = props.role;
+  }
+
+  bind(rule: iot.ITopicRule): iot.ActionConfig {
+    const role = this.role ?? singletonActionRole(rule);
+    role.addToPrincipalPolicy(new iam.PolicyStatement({
+      actions: ['dynamodb:PutItem'],
+      resources: [this.table.tableArn],
+    }));
+    return {
+      configuration: {
+        dynamoDBv2: {
+          putItem: {
+            tableName: this.table.tableName,
+          },
+          roleArn: role.roleArn,
+        },
+      },
+    };
+  }
+}

packages/@aws-cdk/aws-iot-actions/lib/index.ts

@@ -2,6 +2,7 @@ export * from './cloudwatch-logs-action';
 export * from './cloudwatch-put-metric-action';
 export * from './cloudwatch-set-alarm-state-action';
 export * from './common-action-props';
+export * from './dynamo-db-v2-put-item';
 export * from './firehose-put-record-action';
 export * from './iot-republish-action';
 export * from './kinesis-put-record-action';

packages/@aws-cdk/aws-iot-actions/package.json

@@ -88,6 +88,7 @@
   },
   "dependencies": {
     "@aws-cdk/aws-cloudwatch": "0.0.0",
+    "@aws-cdk/aws-dynamodb": "0.0.0",
     "@aws-cdk/aws-iam": "0.0.0",
     "@aws-cdk/aws-iot": "0.0.0",
     "@aws-cdk/aws-kinesis": "0.0.0",
@@ -104,6 +105,7 @@
   "homepage": "https://github.com/aws/aws-cdk",
   "peerDependencies": {
     "@aws-cdk/aws-cloudwatch": "0.0.0",
+    "@aws-cdk/aws-dynamodb": "0.0.0",
     "@aws-cdk/aws-iam": "0.0.0",
     "@aws-cdk/aws-iot": "0.0.0",
     "@aws-cdk/aws-kinesis": "0.0.0",

packages/@aws-cdk/aws-iot-actions/test/dynamodb-v2/dynamodb-v2-put-item-action.integ.snapshot/cdk.out

@@ -0,0 +1 @@
+{"version":"18.0.0"}

packages/@aws-cdk/aws-iot-actions/test/dynamodb-v2/dynamodb-v2-put-item-action.integ.snapshot/integ.json

@@ -0,0 +1,14 @@
+{
+  "version": "18.0.0",
+  "testCases": {
+    "dynamodb-v2/integ.dynamodb-v2-put-item-action": {
+      "stacks": [
+        "test-dynamo-d-bv2-put-item-action-stack"
+      ],
+      "diffAssets": false,
+      "stackUpdateWorkflow": true
+    }
+  },
+  "synthContext": {},
+  "enableLookups": false
+}

packages/@aws-cdk/aws-iot-actions/test/dynamodb-v2/dynamodb-v2-put-item-action.integ.snapshot/manifest.json

@@ -0,0 +1,54 @@
+{
+  "version": "18.0.0",
+  "artifacts": {
+    "Tree": {
+      "type": "cdk:tree",
+      "properties": {
+        "file": "tree.json"
+      }
+    },
+    "test-dynamo-d-bv2-put-item-action-stack": {
+      "type": "aws:cloudformation:stack",
+      "environment": "aws://unknown-account/unknown-region",
+      "properties": {
+        "templateFile": "test-dynamo-d-bv2-put-item-action-stack.template.json",
+        "validateOnSynth": false
+      },
+      "metadata": {
+        "/test-dynamo-d-bv2-put-item-action-stack/TopicRule/Resource": [
+          {
+            "type": "aws:cdk:logicalId",
+            "data": "TopicRule40A4EA44"
+          }
+        ],
+        "/test-dynamo-d-bv2-put-item-action-stack/TopicRule/TopicRuleActionRole/Resource": [
+          {
+            "type": "aws:cdk:logicalId",
+            "data": "TopicRuleTopicRuleActionRole246C4F77"
+          }
+        ],
+        "/test-dynamo-d-bv2-put-item-action-stack/TopicRule/TopicRuleActionRole/DefaultPolicy/Resource": [
+          {
+            "type": "aws:cdk:logicalId",
+            "data": "TopicRuleTopicRuleActionRoleDefaultPolicy99ADD687"
+          }
+        ],
+        "/test-dynamo-d-bv2-put-item-action-stack/MyTable": [
+          {
+            "type": "aws:cdk:hasPhysicalName",
+            "data": {
+              "Ref": "MyTable794EDED1"
+            }
+          }
+        ],
+        "/test-dynamo-d-bv2-put-item-action-stack/MyTable/Resource": [
+          {
+            "type": "aws:cdk:logicalId",
+            "data": "MyTable794EDED1"
+          }
+        ]
+      },
+      "displayName": "test-dynamo-d-bv2-put-item-action-stack"
+    }
+  }
+}

packages/@aws-cdk/aws-iot-actions/test/dynamodb-v2/dynamodb-v2-put-item-action.integ.snapshot/test-dynamo-d-bv2-put-item-action-stack.template.json

@@ -0,0 +1,105 @@
+{
+ "Resources": {
+  "TopicRule40A4EA44": {
+   "Type": "AWS::IoT::TopicRule",
+   "Properties": {
+    "TopicRulePayload": {
+     "Actions": [
+      {
+       "DynamoDBv2": {
+        "PutItem": {
+         "TableName": {
+          "Ref": "MyTable794EDED1"
+         }
+        },
+        "RoleArn": {
+         "Fn::GetAtt": [
+          "TopicRuleTopicRuleActionRole246C4F77",
+          "Arn"
+         ]
+        }
+       }
+      }
+     ],
+     "AwsIotSqlVersion": "2016-03-23",
+     "Sql": "SELECT * FROM 'device/+/data'"
+    }
+   }
+  },
+  "TopicRuleTopicRuleActionRole246C4F77": {
+   "Type": "AWS::IAM::Role",
+   "Properties": {
+    "AssumeRolePolicyDocument": {
+     "Statement": [
+      {
+       "Action": "sts:AssumeRole",
+       "Effect": "Allow",
+       "Principal": {
+        "Service": "iot.amazonaws.com"
+       }
+      }
+     ],
+     "Version": "2012-10-17"
+    }
+   }
+  },
+  "TopicRuleTopicRuleActionRoleDefaultPolicy99ADD687": {
+   "Type": "AWS::IAM::Policy",
+   "Properties": {
+    "PolicyDocument": {
+     "Statement": [
+      {
+       "Action": "dynamodb:PutItem",
+       "Effect": "Allow",
+       "Resource": {
+        "Fn::GetAtt": [
+         "MyTable794EDED1",
+         "Arn"
+        ]
+       }
+      }
+     ],
+     "Version": "2012-10-17"
+    },
+    "PolicyName": "TopicRuleTopicRuleActionRoleDefaultPolicy99ADD687",
+    "Roles": [
+     {
+      "Ref": "TopicRuleTopicRuleActionRole246C4F77"
+     }
+    ]
+   }
+  },
+  "MyTable794EDED1": {
+   "Type": "AWS::DynamoDB::Table",
+   "Properties": {
+    "KeySchema": [
+     {
+      "AttributeName": "hashKey",
+      "KeyType": "HASH"
+     },
+     {
+      "AttributeName": "sortKey",
+      "KeyType": "RANGE"
+     }
+    ],
+    "AttributeDefinitions": [
+     {
+      "AttributeName": "hashKey",
+      "AttributeType": "S"
+     },
+     {
+      "AttributeName": "sortKey",
+      "AttributeType": "N"
+     }
+    ],
+    "ProvisionedThroughput": {
+     "ReadCapacityUnits": 1,
+     "WriteCapacityUnits": 1
+    },
+    "TableName": "MyTable"
+   },
+   "UpdateReplacePolicy": "Delete",
+   "DeletionPolicy": "Delete"
+  }
+ }
+}