자습서: DynamoDB 테이블에 디바이스 데이터 저장 - AWS IoT Core
1단계: 이 자습서를 위한 DynamoDB 테이블 생성2단계: DynamoDB 테이블로 데이터를 전송하는 AWS IoT 규칙 생성3단계: AWS IoT 규칙 및 DynamoDB 테이블 테스트4단계: 결과 및 다음 단계 검토

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

자습서: DynamoDB 테이블에 디바이스 데이터 저장

이 자습서에서는 메시지 데이터를 DynamoDB 테이블로 보내는 AWS IoT 규칙을 생성하는 방법을 보여줍니다.

이 자습서에서는 가상 기상 센서 디바이스에서 DynamoDB 테이블로 메시지 데이터를 전송하는 규칙을 생성합니다. 이 규칙은 여러 기상 센서의 데이터를 단일 데이터베이스 테이블에 추가할 수 있도록 포맷합니다.

이 자습서에서 배울 내용

  • DynamoDB 테이블 생성 방법

  • 규칙에서 DynamoDB 테이블로 메시지 데이터를 보내는 방법 AWS IoT

  • 규칙에서 대체 템플릿을 사용하는 방법 AWS IoT

  • 규칙 쿼리 문에서 간단한 SQL 쿼리 및 함수를 사용하는 방법

  • MQTT 클라이언트를 사용하여 규칙을 테스트하는 방법 AWS IoT

이 자습서는 완료하는 데 약 30분 걸립니다.

이 자습서를 시작하기 전에 다음 사항을 확인해야 합니다.

1단계: 이 자습서를 위한 DynamoDB 테이블 생성

이 자습서에서는 다음과 같은 속성이 포함된 DynamoDB 테이블을 만들어 가상 기상 센서 디바이스의 데이터를 기록합니다.

  • sample_time은 기본 키이며 샘플이 기록된 시간을 설명합니다.

  • device_id는 정렬 키이며 샘플을 제공한 디바이스를 설명합니다.

  • device_data는 디바이스에서 수신되고 규칙 쿼리 문에 의해 형식이 지정된 데이터입니다.

이 자습서용 DynamoDB 테이블을 생성하려면

  1. DynamoDB 콘솔을 열고 테이블 생성을 선택합니다.

  2. 테이블 생성(Create table)에서

    1. 테이블 이름에 테이블 이름 wx_data를 입력합니다.

    2. 파티션 키(Partition key)에 sample_time을 입력하고 필드 옆에 있는 옵션 목록에서 Number를 선택합니다.

    3. 정렬 키(Sort key)에 device_id를 입력하고 필드 옆에 있는 옵션 목록에서 Number를 선택합니다.

    4. 페이지 하단에서 생성(Create)을 선택합니다.

나중에 DynamoDB 규칙 작업을 구성할 때 device_data를 정의합니다.

2단계: DynamoDB 테이블로 데이터를 전송하는 AWS IoT 규칙 생성

이 단계에서는 규칙 쿼리 문을 사용하여 가상 기상 센서 디바이스의 데이터 형식을 데이터베이스 테이블에 기록하도록 지정합니다.

기상 센서 디바이스에서 받은 샘플 메시지 페이로드는 다음과 같습니다.

{
  "temperature": 28,
  "humidity": 80,
  "barometer": 1013,
  "wind": {
    "velocity": 22,
    "bearing": 255
  }
}

데이터베이스 항목의 경우 규칙 쿼리 문을 사용하여 메시지 페이로드의 구조를 다음과 같이 병합합니다.

{
  "temperature": 28,
  "humidity": 80,
  "barometer": 1013,
  "wind_velocity": 22,
  "wind_bearing": 255
}

이 규칙에서는 몇 가지 대체 템플릿을(를) 사용합니다. 대체 템플릿은 함수 및 메시지 데이터에서 동적 값을 삽입할 수 있는 표현식입니다.

DynamoDB 테이블로 데이터를 전송하는 AWS IoT 규칙을 생성하려면

  1. AWS IoT 콘솔의 규칙 허브를 엽니다. 또는 에서 AWS IoT 홈페이지를 열고 메시지 라우팅>규칙으로 이동할 수 있습니다. AWS Management Console

  2. 규칙(Rules)에서 새 규칙 생성을 시작하려면 규칙 생성(Create rule)을 선택합니다.

  3. 규칙 속성(Rule properties)에서

    1. 규칙 이름(Rule name)에 wx_data_ddb를 입력합니다.

      규칙 이름은 사용자 AWS 계정 및 지역 내에서 고유해야 하며 공백을 포함할 수 없다는 점을 기억하세요. 이 이름에 밑줄 문자를 사용하여 규칙 이름의 두 단어를 구분했습니다.

    2. 규칙 설명(Rule description)에서 규칙을 설명합니다.

      의미 있는 설명을 사용하면 이 규칙이 수행하는 작업과 규칙을 만든 이유를 쉽게 기억할 수 있습니다. 설명은 필요한 만큼 길어질 수 있으므로 가능한 한 자세하게 설명하세요.

  4. 다음을 선택하여 계속 진행합니다.

  5. SQL 문(SQL statement)에서

    1. SQL 버전(SQL version)에서 2016-03-23을 선택합니다.

    2. SQL 문(SQL statement) 편집 상자에 문을 입력합니다.

      SELECT temperature, humidity, barometer,
  wind.velocity as wind_velocity,
  wind.bearing as wind_bearing,
FROM 'device/+/data'

      이 문은 다음을 수행합니다.

      • device/+/data 주제 필터와 일치하는 주제가 있는 MQTT 메시지를 수신합니다.

      • wind 속성의 요소를 개별 속성으로 형식화합니다.

      • temperature, humidity 및 barometer 속성은 변경되지 않은 상태로 전달합니다.

  6. 다음을 선택하여 계속 진행합니다.

  7. 규칙 작업(Rule actions)에서

    1. 이 규칙에 대한 규칙 작업 목록을 열려면 작업 1(Action 1)에서 DynamoDB를 선택합니다.

      참고

      규칙 작업으로 DynamoDBv2가 아니라 DynamoDB를 선택해야 합니다.

    2. 테이블 이름에서 이전 단계에서 생성한 DynamoDB 테이블의 이름 wx_data를 선택합니다.

      파티션 키 유형(Partition key type) 및 정렬 키 유형(Sort key type) 필드는 DynamoDB 테이블의 값으로 채워집니다.

    3. 파티션 키에서 sample_time를 입력합니다.

    4. 파티션 키 값에 ${timestamp()}를 입력합니다.

      이것은 이 규칙에서 사용할 첫 번째 대체 템플릿입니다. 메시지 페이로드의 값을 사용하는 대신 timestamp 함수에서 반환된 값을 사용합니다. 자세한 내용은 AWS IoT Core 개발자 안내서의 timestamp를 참조하세요.

    5. 정렬 키(Sort key)에 device_id를 입력합니다.

    6. 정렬 키 값에 ${cast(topic(2) AS DECIMAL)}를 입력합니다.

      이것은 이 규칙에서 사용할 두 번째 대체 템플릿입니다. 키의 숫자 형식과 일치하도록 DECIMAL 값으로 캐스트한 후 디바이스 ID인 주제 이름에 두 번째 요소의 값을 삽입합니다. 주제에 대한 자세한 내용은 AWS IoT Core 개발자 안내서의 topic을 참조하세요. 캐스팅에 대한 자세한 내용은 AWS IoT Core 개발자 안내서의 cast를 참조하세요.

    7. 이 열에 메시지 데이터 쓰기에 device_data를 입력합니다.

      그러면 DynamoDB 테이블에 device_data 열이 생성됩니다.

    8. 작업은 비워 둡니다.

    9. IAM role(IAM 역할)에서 Create new role(새 역할 생성)을 선택합니다.

    10. Create role(역할 생성) 대화 상자에서 Role name(역할 이름)에 wx_ddb_role을 입력합니다. 이 새 역할에는 wx_data_ddb 규칙이 생성한 wx_data DynamoDB 테이블로 데이터를 전송할 수 있도록 허용하는 접두사 aws-iot-rule "“가 있는 정책이 자동으로 포함됩니다.

    11. IAM 역할(IAM role)에서 wx_ddb_role을 선택합니다.

    12. 페이지 하단에서 다음(Next)을 선택합니다.

  8. 검토 및 생성(Review and create) 페이지 하단에서 생성(Create)을 선택하여 규칙을 생성합니다.

3단계: AWS IoT 규칙 및 DynamoDB 테이블 테스트

새 규칙을 테스트하려면 MQTT 클라이언트를 사용하여 이 테스트에 사용된 MQTT 메시지를 게시하고 구독합니다.

새 창에서 AWS IoT 콘솔의 MQTT 클라이언트를 엽니다. 이렇게 하면 MQTT 클라이언트의 구성을 그대로 유지하면서 규칙을 편집할 수 있습니다. MQTT 클라이언트는 콘솔의 다른 페이지로 이동하기 위해 나가면 구독 또는 메시지 로그를 유지하지 않습니다. 또한 규칙이 보내는 새 항목을 보려면 콘솔의 DynamoDB 테이블 허브에 AWS IoT 별도의 콘솔 창을 열어 두는 것이 좋습니다.

MQTT 클라이언트를 사용하여 규칙을 테스트하려면

  1. AWS IoT 콘솔의 MQTT 클라이언트에서 입력 주제(device/+/data)를 구독합니다.

    1. MQTT 클라이언트에서 주제 구독(Subscribe to a topic)을 선택합니다.

    2. 주제 필터에 입력 주제 필터의 주제(device/+/data)를 입력합니다.

    3. 구독을 선택합니다.

  2. 이제 특정 디바이스 ID device/22/data로 입력 주제에 메시지를 게시합니다. 와일드카드 문자가 포함된 MQTT 항목에는 게시할 수 없습니다.

    1. MQTT 클라이언트에서 주제에 게시(Publish to a topic)를 선택합니다.

    2. 주제 이름(Topic name)에 주제 이름(device/22/data)을 입력합니다.

    3. 메시지 페이로드에 다음 샘플 데이터를 입력합니다.

      {
  "temperature": 28,
  "humidity": 80,
  "barometer": 1013,
  "wind": {
    "velocity": 22,
    "bearing": 255
  }
}

    4. MQTT 메시지를 게시하려면 게시를 선택합니다.

    5. 이제 MQTT 클라이언트에서 주제 구독(Subscribe to a topic)을 선택합니다. 구독 열에서 device/+/data 구독을 선택합니다. 이전 단계의 샘플 데이터가 나타나는지 확인합니다.

  3. 규칙에서 생성한 DynamoDB 테이블의 행을 보려면 선택합니다.

    1. 콘솔의 DynamoDB 테이블 허브에서 AWS IoT wx_data를 선택한 다음 항목 탭을 선택합니다.

      항목(Items) 탭이 이미 사용 중인 경우 테이블 헤더의 오른쪽 상단 모서리에서 새로 고침 아이콘을 선택하여 디스플레이를 새로 고쳐야 할 수 있습니다.

    2. 테이블의 sample_time 값은 링크이며 하나를 엽니다. 방금 첫 번째 메시지를 전송한 경우 이는 목록에 있는 유일한 메시지입니다.

      이 링크는 테이블의 해당 행에 있는 모든 데이터를 표시합니다.

    3. device_data 항목을 확장하여 규칙 쿼리 문에서 생성된 데이터를 확인합니다.

    4. 이 디스플레이에서 사용할 수 있는 데이터의 다양한 표현을 살펴보세요. 이 디스플레이에서 데이터를 편집할 수도 있습니다.

    5. 이 데이터 행 검토를 마친 후 변경 사항을 저장하려면 저장을 선택하고 변경 사항을 저장하지 않고 종료하려면 취소를 선택합니다.

올바른 동작이 표시되지 않으면 문제 해결 팁을 확인합니다.

DynamoDB 규칙 문제 해결

다음은 예상한 결과가 표시되지 않는 경우에 대비하여 확인해야 할 몇 가지 사항입니다.

  • 오류 배너가 있음

    입력 메시지를 게시할 때 오류가 나타나면 먼저 해당 오류를 수정하세요. 다음 단계는 해당 오류를 수정하는 데 도움이 될 수 있습니다.

  • MQTT 클라이언트에서 입력 메시지가 표시되지 않음

    device/+/data 주제 필터를 구독한 경우 입력 메시지를 device/22/data 주제에 게시할 때마다 절차에 설명된 대로 해당 메시지가 MQTT 클라이언트에 나타나야 합니다.

    확인해야 할 사항
    • 구독한 주제 필터 확인

      절차에 설명된 대로 입력 메시지 주제를 구독한 경우 게시할 때마다 입력 메시지의 복사본이 표시되어야 합니다.

      메시지가 표시되지 않으면 구독한 주제 이름을 확인하고 게시한 주제와 비교합니다. 주제 이름은 대소문자를 구분하며 구독한 주제는 메시지 페이로드를 게시한 주제와 동일해야 합니다.

    • 메시지 게시 함수 확인

      MQTT 클라이언트의 구독에서 device/+/data를 선택하고 게시 메시지의 주제를 확인한 다음 주제에 게시를 선택합니다. 주제 아래의 편집 상자에서 메시지 페이로드가 메시지 목록에 나타납니다.

  • DynamoDB 테이블에 데이터가 표시되지 않음

    가장 먼저 할 일은 테이블 헤더의 오른쪽 상단 모서리에 있는 새로 고침 아이콘을 선택하여 디스플레이를 새로 고치는 것입니다. 찾고있는 데이터가 표시되지 않으면 다음을 확인하세요.

    확인해야 할 사항
    • MQTT 클라이언트와 생성한 규칙을 확인합니다. AWS 리전

      MQTT 클라이언트를 실행 중인 콘솔은 생성한 규칙과 동일한 AWS 리전에 있어야 합니다.

    • 규칙 쿼리 문의 입력 메시지 주제 확인

      규칙이 작동하려면 규칙 쿼리 문의 FROM 절에 있는 주제 필터와 일치하는 주제 이름이 포함된 메시지를 받아야 합니다.

      MQTT 클라이언트에 있는 주제의 철자와 함께 규칙 쿼리 문에서 주제 필터의 철자를 확인하세요. 주제 이름은 대/소문자를 구분하며 메시지의 주제는 규칙 쿼리 문의 주제 필터와 일치해야 합니다.

    • 입력 메시지 페이로드의 내용 확인

      규칙이 작동하려면 SELECT 문에서 선언된 메시지 페이로드에서 데이터 필드를 찾아야 합니다.

      MQTT 클라이언트에 있는 메시지 페이로드의 철자와 함께 규칙 쿼리 명령문의 temperature 필드 철자를 확인하세요. 필드 이름은 대소문자를 구분하며 규칙 쿼리 문의 temperature 필드는 메시지 페이로드의 temperature 필드와 동일해야 합니다.

      메시지 페이로드의 JSON 문서의 형식이 올바른지 확인하세요. JSON에 쉼표 누락과 같은 오류가 있으면 규칙에서 읽을 수 없습니다.

    • 규칙 작업에 사용된 키 및 필드 이름 확인

      주제 규칙에 사용되는 필드 이름은 게시된 메시지의 JSON 메시지 페이로드에 있는 필드 이름과 일치해야 합니다.

      콘솔에서 생성한 규칙을 열고 MQTT 클라이언트에서 사용된 규칙 작업 구성의 필드 이름을 확인합니다.

    • 규칙에서 사용 중인 역할 확인

      규칙 작업에는 원래 주제를 받고 새 주제를 게시할 수 있는 권한이 있어야 합니다.

      메시지 데이터를 수신하고 DynamoDB 테이블을 업데이트하도록 규칙을 인증하는 정책은 사용된 주제에 따라 다릅니다. 규칙에 사용되는 주제 또는 DynamoDB 테이블 이름을 변경하는 경우 규칙 작업의 역할을 업데이트하여 해당 정책을 일치하도록 업데이트해야 합니다.

      문제가 의심되는 경우 규칙 작업을 편집하고 새 역할을 만듭니다. 규칙 작업에 의해 생성된 새 역할에는 이러한 작업을 수행하는 데 필요한 권한이 부여됩니다.

4단계: 결과 및 다음 단계 검토

이 규칙을 사용하여 DynamoDB 테이블로 몇 개의 메시지를 전송한 후 이를 실험하여 자습서의 일부 측면을 변경하면 테이블에 기록된 데이터에 어떤 영향을 주는지 확인하세요. 다음은 시작하는 데 도움이 될 몇 가지 아이디어입니다.

  • 입력 메시지의 주제에서 device_id를 변경하고 데이터의 영향을 관찰합니다. 이 기능을 사용하여 여러 기상 센서의 수신 데이터를 시뮬레이션할 수 있습니다.

  • 규칙 쿼리 문에서 선택한 필드를 변경하고 데이터의 영향을 관찰합니다. 이 옵션을 사용하여 테이블에 저장된 데이터를 필터링할 수 있습니다.

  • 테이블에 추가된 각 행에 대해 MQTT 메시지를 전송하려면 재게시 규칙 작업을 추가합니다. 디버깅에 사용할 수 있습니다.

이 자습서를 완료했으면 자습서: AWS Lambda 함수를 사용하여 알림 형식 지정 섹션을 확인합니다.