DynamoDBv2

DynamoDBv2 (dynamoDBv2) 操作可将所有或部分 MQTT 消息写入 Amazon DynamoDB 表。负载中的每个属性将写入 DynamoDB 数据库中的单独一列。

要求

此规则操作具有以下要求：

• AWS IoT 可以代入执行dynamodb:PutItem操作的 IAM 角色。有关更多信息，请参阅授予 AWS IoT 规则所需的访问权限。

  在 AWS IoT 控制台中，您可以选择或创建 AWS IoT 允许执行此规则操作的角色。

• 如果要定义 MQTT 消息负载，则它必须包含一个与表的主分区键相匹配的根级键，以及一个与表的主排序键相匹配的根级键。

• 如果您使用客户托管 AWS KMS key （KMS 密钥）对 DynamoDB 中的静态数据进行加密，则该服务必须有权代表调用方使用 KMS 密钥。有关更多信息，请参阅 Amazon DynamoDB 入门指南中的客户托管式 KMS。

参数

使用此操作创建 AWS IoT 规则时，必须指定以下信息：

putItem

用于指定消息数据将写入的 DynamoDB 表的对象。该对象必须具备以下信息：

tableName

DynamoDB 表的名称。

仅支持替换模板：API 且 AWS CLI 仅支持

roleARN

允许访问 DynamoDB 表的 IAM 角色。有关更多信息，请参阅要求。

支持替换模板：否

写入 DynamoDB 表的数据是规则的 SQL 语句的结果。

示例

以下 JSON 示例在规则中定义了 DynamoDBv2 操作。 AWS IoT

{
    "topicRulePayload": {
        "sql": "SELECT * AS message FROM 'some/topic'", 
        "ruleDisabled": false,
        "awsIotSqlVersion": "2016-03-23",
        "actions": [
            {
                "dynamoDBv2": {
                    "putItem": {
                        "tableName": "my_ddb_table"
                    },
                    "roleArn": "arn:aws:iam::123456789012:role/aws_iot_dynamoDBv2", 
                }
            }
        ]
    }
}

以下 JSON 示例定义了在规则中使用替换模板的 DynamoDB 操作。 AWS IoT

{
    "topicRulePayload": {
        "sql": "SELECT * FROM 'some/topic'",
        "ruleDisabled": false,
        "awsIotSqlVersion": "2015-10-08",
        "actions": [
            {
                "dynamoDBv2": {
                    "putItem": {
                        "tableName": "${topic()}"
                    },
                    "roleArn": "arn:aws:iam::123456789012:role/aws_iot_dynamoDBv2"
                }
            }
        ]
    }
}

另请参阅

• Amazon DynamoDB 开发人员指南中的什么是 DynamoDB？

• Amazon DynamoDB 开发人员指南中的 DynamoDB 入门