DynamoDB에 작성하는 AWS IoT 규칙을 만드는 방법

1) DynamoDB 테이블을 만듭니다.
해시 키를 id, 범위 키를 time 으로 합니다.



다음 프로그램에서도 만들 수 있습니다.

dynamo_create.py

#! /usr/bin/python
# -*- coding: utf-8 -*-
#
#   dynamo_create.py
#
#                   Dec/10/2017
# ---------------------------------------------------------------
import  sys
import  datetime
import  boto3
from decimal import *

# ---------------------------------------------------------------
def create_table_proc(table_name):
    table = dynamodb.create_table(
        TableName=table_name,
        KeySchema=[
        {
        'AttributeName': 'id',
        'KeyType': 'HASH'
        },
        {
        'AttributeName': 'time',
        'KeyType': 'RANGE'
        },
        ],
        AttributeDefinitions=[
            {'AttributeName': 'id', 'AttributeType': 'S' },
            {'AttributeName': 'time', 'AttributeType': 'S' },
            ],
        ProvisionedThroughput={
            'ReadCapacityUnits': 1,
            'WriteCapacityUnits': 1
            }
        )

    print("Table status:", table.table_status)
#
# ---------------------------------------------------------------
sys.stderr.write ("*** 開始 ***\n")
#
dynamodb = boto3.resource('dynamodb')

table_name = 'iot_test'

try:
    create_table_proc(table_name)
except Exception as ee:
    sys.stderr.write("*** error *** in create_table_proc ***\n")
    sys.stderr.write(str(ee) + "\n")

sys.stderr.write ("*** 終了 ***\n")
# ---------------------------------------------------------------

2) IoT 규칙을 만듭니다.
AWS Iot 콘솔의 ACT로 들어갑니다.


해시 키 값 ${id_in}
레지스터의 값 ${time_in}



3) IoT Thing(브로커)을 만듭니다.



AWS 콘솔에서 생성하는 방법은
AWS IOT를 간편하게 사용하는 방법

AWS CLI에서 생성하는 방법은
AWS IOT를 AWS CLI로 구성

4) Pub/Sub를 테스트합니다.
IoT Thing을 만들 때 만든 인증 파일을 사용합니다.

여기에 그 방법이 있습니다.
Raspberry Pi에서 mosquitto를 사용하여 AWS IOT에 Pub/Sub

Publish 할 JSON을 다음과 같이하십시오.

in01.json

{
  "id_in": "rasp_10001",
  "time_in": "2017-12-10 17:07:10",
  "message": "Hello"
}

다음과 같이 DynamoDB에 기록됩니다.