Requirements Parameters Examples See also

DynamoDB

The DynamoDB (dynamoDB) action writes all or part of an MQTT message to an Amazon DynamoDB table.

You can follow a tutorial that shows you how to create and test a rule with a DynamoDB action. For more information, see Tutorial: Storing device data in a DynamoDB table.

Note

This rule writes non-JSON data to DynamoDB as binary data. The DynamoDB console displays the data as base64-encoded text.

Requirements

This rule action has the following requirements:

An IAM role that Amazon IoT can assume to perform the dynamodb:PutItem operation. For more information, see Granting an Amazon IoT rule the access it requires.

In the Amazon IoT console, you can choose or create a role to allow Amazon IoT to perform this rule action.
If you use a customer managed Amazon KMS key (KMS key) to encrypt data at rest in DynamoDB, the service must have permission to use the KMS key on the caller's behalf. For more information, see Customer Managed KMS key in the Amazon DynamoDB Getting Started Guide.

Parameters

When you create an Amazon IoT rule with this action, you must specify the following information:

tableName

The name of the DynamoDB table.

Supports substitution templates: API and Amazon CLI only

hashKeyField

The name of the hash key (also called the partition key).

Supports substitution templates: API and Amazon CLI only

hashKeyType

(Optional) The data type of the hash key (also called the partition key). Valid values: STRING, NUMBER.

Supports substitution templates: API and Amazon CLI only

hashKeyValue

The value of the hash key. Consider using a substitution template such as ${topic()} or ${timestamp()}.

Supports substitution templates: Yes

rangeKeyField

(Optional) The name of the range key (also called the sort key).

Supports substitution templates: API and Amazon CLI only

rangeKeyType

(Optional) The data type of the range key (also called the sort key). Valid values: STRING, NUMBER.

Supports substitution templates: API and Amazon CLI only

rangeKeyValue

(Optional) The value of the range key. Consider using a substitution template such as ${topic()} or ${timestamp()}.

Supports substitution templates: Yes

payloadField

(Optional) The name of the column where the payload is written. If you omit this value, the payload is written to the column named payload.

Supports substitution templates: Yes

operation

(Optional) The type of operation to be performed. Valid values: INSERT, UPDATE, DELETE.

Supports substitution templates: Yes

roleARN

The IAM role that allows access to the DynamoDB table. For more information, see Requirements.

Supports substitution templates: No

The data written to the DynamoDB table is the result from the SQL statement of the rule.

Examples

The following JSON example defines a DynamoDB action in an Amazon IoT rule.


{
    "topicRulePayload": {
        "sql": "SELECT * AS message FROM 'some/topic'", 
        "ruleDisabled": false,
        "awsIotSqlVersion": "2016-03-23",
        "actions": [
            {
                "dynamoDB": {
                    "tableName": "my_ddb_table",
                    "hashKeyField": "key",
                    "hashKeyValue": "${topic()}",
                    "rangeKeyField": "timestamp",
                    "rangeKeyValue": "${timestamp()}",
                    "roleArn": "arn:aws:iam::123456789012:role/aws_iot_dynamoDB"
                }
            }
        ]
    }
}