使用 Lambda 从 AWS IoT 到 DynamoDB

Question

我正在使用 AWS IoT。我创建了一个事物并使用 MQTT 查看从事物影子更新的结果。

$aws/things/thing_name/shadow/update

这是示例结果：

{"state": {
"desired": null,
"reported": {
  "ext_addr": "0x124b0013a4c55d",
  "last_reported": "22:20:35 2018-10-30",
  "objects": {
    "temperature": {
      "0": {
        "oid": "temperature",
        "sensorValue": 33,
        "units": "Cels",
        "minMeaValue": 33,
        "maxMeaValue": 33
      }
    }
  }
}

我想使用 Rule 调用 Lambda 函数将 "last_reported"、"objects" 存储在 DynamoDB 的单独列中。但是，我停留在 Lambda 函数的编程步骤。

表格应该有如下项目：

sensor_id = ${topic(3)}

last_reported = SELECT state.reported.last_reported FROM '$aws/things/thing_name/shadow/update'

数据 = SELECT state.reported.objects FROM '$aws/things/thing_name/shadow/update'

提前致谢。

Answer 1

虽然您可以使用 lambda 规则将 IoT 数据存储在 dynamo 中，但 AWS IoT 包含一个 direct-to-dynamo 规则，如果您没有太多，我认为这对您来说会容易得多编程经验：

使用以下定义创建 DynamoDBv2 操作：

{
    "rule": {
        "ruleDisabled": false, 
        "sql": "SELECT payload.state.reported, topic(3) AS sensor_id FROM '$aws/things/+/shadow/update/accepted'", 
        "description": "A test DynamoDBv2 rule", 
        "actions": [{
            "dynamoDBv2": {
                "roleArn": "arn:aws:iam::123456789012:role/aws_iot_dynamoDBv2", 
                "putItem": {
                    "tableName": "my_ddb_table"
                }
             }
        }]
    }
}

地点：

• arn:aws:iam::123456789012:role/aws_iot_dynamoDBv2 是 IAM 角色 允许将项目放到您的发电机表中
• my_ddb_table 是 要将数据保存到的表的名称