기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.
# 디바이스 데이터를 다른 서비스로 라우팅하는 AWS IoT 규칙 생성
이 자습서에서는 보다 일반적인 AWS IoT 규칙 작업 중 일부를 사용하여 규칙을 생성하고 테스트하는 방법을 보여줍니다.
AWS IoT 규칙은 디바이스에서 다른 AWS 서비스로 데이터를 전송합니다. 이들은 특정 MQTT 메시지를 수신하고, 메시지 페이로드의 데이터를 형식화한 다음 결과를 다른 AWS 서비스로 전송합니다.
Lambda 함수 또는 더 복잡한 규칙을 사용하는 규칙을 만드는 것이 목표인 경우에도 여기에 표시된 순서대로 시도해 보는 것이 좋습니다. 자습서는 기본적인 것부터 복잡한 것의 순서로 제공됩니다. 새로운 개념을 점진적으로 제시하여 특정 자습서가 없는 규칙 작업을 만드는 데 사용할 수 있는 개념을 익힐 수 있습니다.
**참고**
AWS IoT 규칙은 IoT 디바이스에서 다른 AWS 서비스로 데이터를 전송하는 데 도움이 됩니다. 그러나 이를 성공적으로 수행하려면 데이터를 전송하려는 다른 서비스에 대한 실무 지식이 필요합니다. 이 자습서에서는 작업을 완료하는 데 필요한 정보를 제공하지만 솔루션에서 데이터를 사용하기 전에 데이터를 전송할 서비스에 대해 자세히 알아보는 것이 도움이 될 수 있습니다. 다른 AWS 서비스에 대한 자세한 설명은이 자습서의 범위를 벗어납니다.
**자습서 시나리오 개요**
이 자습서의 시나리오는 주기적으로 데이터를 게시하는 기상 센서 디바이스의 시나리오입니다. 이 가상 시스템에는 많은 센서 디바이스가 있습니다. 그러나 이 섹션의 자습서에서는 단일 디바이스에 초점을 맞추면서 여러 센서를 수용할 수 있는 방법을 보여 줍니다.
이 섹션의 자습서에서는 AWS IoT 규칙을 사용하여이 가상 기상 센서 디바이스 시스템으로 다음 작업을 수행하는 방법을 보여줍니다.
+
**[자습서: MQTT 메시지 재게시](iot-repub-rule.md)**
이 자습서에서는 기상 센서에서 받은 MQTT 메시지를 센서 ID와 온도 값만 포함하는 메시지로 다시 게시하는 방법을 보여 줍니다. AWS IoT Core 서비스만 사용하고 간단한 SQL 쿼리와 MQTT 클라이언트를 사용하여 규칙을 테스트하는 방법을 보여줍니다.
+
**[자습서: Amazon SNS 알림 전송](iot-sns-rule.md)**
이 자습서에서는 기상 센서 디바이스의 값이 특정 값을 초과할 때 SNS 메시지를 전송하는 방법을 보여 줍니다. 이전 자습서에 제시된 개념을 기반으로 하며 다른 AWS 서비스인 [Amazon Simple Notification Service](https://docs.aws.amazon.com//sns/latest/dg/welcome.html)(Amazon SNS)로 작업하는 방법을 추가합니다.
Amazon SNS를 처음 사용한다면 이 자습서를 시작하기 전에 [시작하기](https://docs.aws.amazon.com//sns/latest/dg/sns-getting-started.html) 연습을 검토합니다.
+
**[자습서: DynamoDB 테이블에 디바이스 데이터 저장](iot-ddb-rule.md)**
이 자습서에서는 기상 센서 디바이스의 데이터를 데이터베이스 테이블에 저장하는 방법을 보여 줍니다. 규칙 쿼리 문과 대체 템플릿을 사용하여 대상 서비스에 대한 [Amazon DynamoDB](https://docs.aws.amazon.com//amazondynamodb/latest/developerguide/Introduction.html) 메시지 데이터 형식을 지정합니다.
DynamoDB를 처음 사용한다면 이 자습서를 시작하기 전에 [시작하기](https://docs.aws.amazon.com//amazondynamodb/latest/developerguide/GettingStartedDynamoDB.html) 연습을 검토합니다.
+
**[자습서: AWS Lambda 함수를 사용하여 알림 형식 지정](iot-lambda-rule.md)**
이 자습서에서는 Lambda 함수를 호출하여 디바이스 데이터를 다시 형식 지정한 다음 문자 메시지로 전송하는 방법을 보여 줍니다. [AWS Lambda](https://docs.aws.amazon.com//lambda/latest/dg/welcome.html) 함수에 Python 스크립트 및 AWS SDK 함수를 추가하여 날씨 센서 디바이스의 메시지 페이로드 데이터로 형식을 지정하고 문자 메시지를 전송합니다.
Lambda를 처음 사용한다면 이 자습서를 시작하기 전에 [시작하기](https://docs.aws.amazon.com//lambda/latest/dg/getting-started.html) 연습을 검토합니다.
**AWS IoT 규칙 개요**
이러한 모든 자습서가 AWS IoT 규칙을 생성합니다.
디바이스에서 다른 AWS 서비스로 데이터를 전송하는 AWS IoT 규칙의 경우 다음을 사용합니다.
+ 다음으로 구성된 규칙 쿼리 문입니다.
+ 메시지 페이로드에서 데이터를 선택하고 형식을 지정하는 SQL SELECT 절
+ 사용할 메시지를 식별하는 주제 필터(규칙 쿼리 문의 FROM 객체)
+ 작동할 조건을 지정하는 선택적 조건문(SQL WHERE 절)
+ 하나 이상의 규칙 작업
디바이스는 MQTT 주제에 메시지를 게시합니다. SQL SELECT 문의 주제 필터는 규칙을 적용할 MQTT 주제를 식별합니다. SQL SELECT 문에 지정된 필드는 규칙 작업에 사용할 수신 MQTT 메시지 페이로드의 데이터 형식을 지정합니다. 규칙 작업의 전체 목록은 [AWS IoT 규칙 작업](iot-rule-actions.md) 단원을 참조하세요.
**Topics**
+ [자습서: MQTT 메시지 재게시](iot-repub-rule.md)
+ [자습서: Amazon SNS 알림 전송](iot-sns-rule.md)
+ [자습서: DynamoDB 테이블에 디바이스 데이터 저장](iot-ddb-rule.md)
+ [자습서: AWS Lambda 함수를 사용하여 알림 형식 지정](iot-lambda-rule.md)
# 자습서: MQTT 메시지 재게시
이 자습서에서는 지정된 MQTT 메시지가 수신될 때 MQTT 메시지를 게시하는 AWS IoT 규칙을 생성하는 방법을 보여줍니다. 수신 메시지 페이로드는 게시되기 전에 규칙에 의해 수정될 수 있습니다. 이를 통해 디바이스나 펌웨어를 변경할 필요 없이 특정 애플리케이션에 맞는 메시지를 생성할 수 있습니다. 규칙의 필터링 측면을 사용하여 특정 조건이 충족되는 경우에만 메시지를 게시할 수도 있습니다.
규칙에 의해 다시 게시된 메시지는 다른 AWS IoT 디바이스 또는 클라이언트에서 보낸 메시지처럼 작동합니다. 디바이스는 다른 MQTT 메시지 주제를 구독할 수 있는 것과 동일한 방식으로 다시 게시된 메시지를 구독할 수 있습니다.
**이 자습서에서 배울 내용:**
+ 규칙 쿼리 문에서 간단한 SQL 쿼리 및 함수를 사용하는 방법
+ MQTT 클라이언트를 사용하여 AWS IoT 규칙을 테스트하는 방법
이 자습서는 완료하는 데 약 30분 걸립니다.
**Topics**
+ [MQTT 주제 및 AWS IoT 규칙 검토](#iot-repub-rule-mqtt)
+ [1단계: MQTT 메시지를 다시 게시하는 AWS IoT 규칙 생성](#iot-repub-rule-define)
+ [2단계: 새 규칙 테스트](#iot-repub-rule-test)
+ [3단계: 결과 및 다음 단계 검토](#iot-repub-rule-review)
**이 자습서를 시작하기 전에 다음 사항을 확인해야 합니다.**
+
**[설정 AWS 계정](setting-up.md)**
이 자습서를 완료하려면 AWS 계정 및 AWS IoT 콘솔이 필요합니다.
+
**검토된 [MQTT 클라이언트를 사용하여 AWS IoT MQTT 메시지 보기](view-mqtt-messages.md)**
MQTT 클라이언트를 사용하여 주제를 구독하고 게시할 수 있는지 확인하세요. 이 절차에서는 MQTT 클라이언트를 사용하여 새 규칙을 테스트합니다.
## MQTT 주제 및 AWS IoT 규칙 검토
AWS IoT 규칙에 대해 설명하기 전에 MQTT 프로토콜을 이해하는 데 도움이 됩니다. IoT 솔루션에서 MQTT 프로토콜은 HTTP와 같은 다른 네트워크 통신 프로토콜에 비해 몇 가지 이점을 제공하므로 IoT 디바이스에서 널리 사용됩니다. 이 섹션에서는 이 자습서에 적용되는 MQTT의 주요 측면을 검토합니다. MQTTT를 HTTP와 비교하는 방법에 대한 자세한 내용은 [디바이스 통신을 위한 애플리케이션 프로토콜 선택](protocols.md#protocol-selection) 단원을 참조하세요.
**MQTT 프로토콜**
MQTT 프로토콜은 호스트와 게시/구독 통신 모델을 사용합니다. 데이터를 전송하기 위해 디바이스는 주제로 식별되는 메시지를 AWS IoT 메시지 브로커에 게시합니다. 메시지 브로커로부터 메시지를 수신하기 위해 디바이스는 구독 요청의 주제 필터를 메시지 브로커에 전송하여 수신할 주제를 구독합니다. AWS IoT 규칙 엔진은 메시지 브로커에서 MQTT 메시지를 수신합니다.
**AWS IoT 규칙**
AWS IoT 규칙은 규칙 쿼리 문과 하나 이상의 규칙 작업으로 구성됩니다. AWS IoT 규칙 엔진이 MQTT 메시지를 수신하면 이러한 요소는 다음과 같이 메시지에 작동합니다.
+
**규칙 쿼리 문**
규칙의 쿼리 문은 사용할 MQTT 주제를 설명하고, 메시지 페이로드의 데이터를 해석하며, 널리 사용되는 SQL 데이터베이스에서 사용하는 문과 유사한 SQL 문에 설명된 대로 데이터의 형식을 지정합니다. 쿼리 문의 결과는 규칙의 작업으로 전송되는 데이터입니다.
+
**규칙 작업**
규칙의 각 규칙 작업은 규칙의 쿼리 문에서 발생하는 데이터에 적용됩니다.는 [많은 규칙 작업을](iot-rule-actions.md) AWS IoT 지원합니다. 그러나 이 자습서에서는 쿼리 문의 결과를 특정 주제가 포함된 MQTT 메시지로 게시하는 [재게시](republish-rule-action.md) 규칙 작업에 집중할 것입니다.
## 1단계: MQTT 메시지를 다시 게시하는 AWS IoT 규칙 생성
이 자습서에서 생성할 AWS IoT 규칙은 *device\$1id*가 메시지를 전송한 디바이스의 ID인 `device/device_id/data` MQTT 주제를 구독합니다. 이러한 주제는 [주제 필터](topics.md#topicfilters)에 의해 `device/+/data`로 설명됩니다. 여기서 `+`는 두 개의 슬래시 문자 사이의 모든 문자열과 일치하는 와일드카드 문자입니다.
규칙은 일치하는 주제에서 메시지를 수신하면 `device_id` 및 `temperature` 값을 `device/data/temp` 주제가 있는 새 MQTT 메시지로 다시 게시합니다.
예를 들어, `device/22/data` 주제가 있는 MQTT 메시지의 페이로드는 다음과 같습니다.
```
{
"temperature": 28,
"humidity": 80,
"barometer": 1013,
"wind": {
"velocity": 22,
"bearing": 255
}
}
```
규칙은 메시지 페이로드에서 `temperature` 값을 가져오고 주제에서 `device_id`를 가져와 다음과 같은 `device/data/temp` 주제 및 메시지 페이로드가 있는 MQTT 메시지로 다시 게시합니다.
```
{
"device_id": "22",
"temperature": 28
}
```
이 규칙을 사용할 경우 디바이스의 ID와 온도 데이터만 필요한 디바이스는 해당 정보만 수신하기 위해 `device/data/temp` 주제를 구독합니다.
**MQTT 메시지를 다시 게시하는 규칙을 생성하려면**
1. [AWS IoT 콘솔의 **규칙** 허브를](https://console.aws.amazon.com//iot/home#/rulehub) 엽니다.
1. **규칙**에서 **생성**을 선택하고 새 규칙 생성을 시작합니다.
1. **규칙 생성**의 상단 부분에서:
1. **이름**에 규칙 이름을 입력합니다. 본 자습서에서는 이름을 **republish\$1temp**로 지정합니다.
규칙 이름은 계정 및 지역 내에서 고유해야 하며 공백을 포함할 수 없습니다. 이 이름에 밑줄 문자를 사용하여 규칙 이름의 두 단어를 구분했습니다.
1. **설명**에서 규칙을 설명합니다.
의미 있는 설명은 이 규칙이 수행하는 작업과 규칙을 생성한 이유를 기억하는 데 도움이 됩니다. 설명은 필요한 만큼 길어질 수 있으므로 가능한 한 자세하게 설명하세요.
1. **규칙 생성**의 **규칙 쿼리 문**에서:
1. **SQL 버전 사용**에서 **2016-03-23**을(를) 선택합니다.
1. **규칙 쿼리 문** 편집 상자에 쿼리 문을 입력합니다.
```
SELECT topic(2) as device_id, temperature FROM 'device/+/data'
```
이 문은 다음을 수행합니다.
+ `device/+/data` 주제 필터와 일치하는 주제가 있는 MQTT 메시지를 수신합니다.
+ 주제 문자열에서 두 번째 요소를 선택하여 `device_id` 필드에 할당합니다.
+ 메시지 페이로드에서 `temperature` 값 필드를 선택하여 `temperature` 필드에 할당합니다.
1. **하나 이상의 작업 설정**에서:
1. 이 규칙에 대한 규칙 작업 목록을 열려면 **작업 추가**를 선택합니다.
1. **작업 선택**에서 ** AWS IoT 주제에 메시지 다시 게시를** 선택합니다.
1. 작업 목록 하단에서 **구성 작업**을 선택하여 선택한 작업의 구성 페이지를 엽니다.
1. **구성 작업**에서:
1. **주제**에 **device/data/temp**를 입력합니다. 이 규칙이 게시할 메시지의 MQTT 주제입니다.
1. **서비스 품질(QoS)**에서 **0 - 메시지가 0번 이상 전송됨**을 선택합니다.
1. **이 작업을 수행할 수 있는 AWS IoT 액세스 권한을 부여할 역할 선택 또는 생성**에서:
1. **역할 생성**을 선택합니다. **새 역할 생성** 대화 상자가 열립니다.
1. 새 역할을 설명하는 이름을 입력합니다. 본 자습서에서는 **republish\$1role**을 사용합니다.
새 역할을 만들면 규칙 작업을 수행할 올바른 정책이 만들어지고 새 역할에 연결됩니다. 이 규칙 작업의 주제를 변경하거나 다른 규칙 작업에서 이 역할을 사용하는 경우 새 주제 또는 작업에 권한을 부여하도록 해당 역할에 대한 정책을 업데이트해야 합니다. 기존 역할을 업데이트하려면 이 섹션의 **역할 업데이트**를 선택합니다.
1. **역할 생성**을 선택하여 역할을 생성하고 대화 상자를 닫습니다.
1. **작업 추가**를 선택하여 규칙에 작업을 추가하고 **규칙 생성** 페이지로 이동합니다.
1. 이제 ** AWS IoT 주제에 메시지 다시 게시** 작업이 **하나 이상의 작업 설정에** 나열됩니다.
새 작업 타일의 ** AWS IoT 주제에 메시지 재게시** 아래에서 재게시 작업으로 게시할 주제를 볼 수 있습니다.
이 규칙 작업은 이 규칙에 추가할 유일한 규칙 작업입니다.
1. **규칙 생성**에서 하단으로 스크롤하고 **규칙 생성**을 선택하여 규칙을 생성하고 이 단계를 완료합니다.
## 2단계: 새 규칙 테스트
새 규칙을 테스트하려면 MQTT 클라이언트를 사용하여 이 규칙에서 사용하는 MQTT 메시지를 게시하고 구독합니다.
새 창에서 [AWS IoT 콘솔의 MQTT 클라이언트](https://console.aws.amazon.com//iot/home#/test)를 엽니다. 이렇게 하면 MQTT 클라이언트의 구성을 그대로 유지하면서 규칙을 편집할 수 있습니다. MQTT 클라이언트는 콘솔의 다른 페이지로 이동하기 위해 나가면 구독 또는 메시지 로그를 유지하지 않습니다.
**MQTT 클라이언트를 사용하여 규칙을 테스트하려면**
1. [AWS IoT 콘솔의 MQTT 클라이언트](https://console.aws.amazon.com//iot/home#/test)에서 입력 주제(이 경우 `device/+/data`)를 구독합니다.
1. MQTT 클라이언트에서 **구독** 아래에서 **주제 구독**을 선택합니다.
1. **구독 주제**에 입력 주제 필터 **device/\$1/data**의 주제를 입력합니다.
1. 나머지 필드는 기본 설정을 유지합니다.
1. **주제 구독**을 선택합니다.
**구독** 열의 **주제 게시** 아래에 **device/\$1/data**가 나타납니다.
1. 규칙에서 게시할 주제 `device/data/temp`를 구독합니다.
1. **구독** 아래에서 **주제 구독**을 다시 선택하고, **구독 주제**에 다시 게시된 메시지의 주제 **device/data/temp**를 입력합니다.
1. 나머지 필드는 기본 설정을 유지합니다.
1. **주제 구독**을 선택합니다.
**구독** 열의 **device/\$1/data**에서 **device/data/temp**가 나타납니다.
1. 특정 디바이스 ID **device/22/data**로 입력 주제에 메시지를 게시합니다. 와일드카드 문자가 포함된 MQTT 항목에는 게시할 수 없습니다.
1. MQTT 클라이언트의 **구독** 아래에서 **주제 게시**를 선택합니다.
1. **게시** 필드에 입력 주제 이름 **device/22/data**를 입력합니다.
1. 여기에 표시된 샘플 데이터를 복사하고 주제 이름 아래의 편집 상자에 샘플 데이터를 붙여 넣습니다.
```
{
"temperature": 28,
"humidity": 80,
"barometer": 1013,
"wind": {
"velocity": 22,
"bearing": 255
}
}
```
1. MQTT 메시지를 전송하려면 **주제 게시**를 선택합니다.
1. 전송한 메시지를 검토합니다.
1. MQTT 클라이언트의 **구독** 아래에서 이전에 구독한 두 주제 옆에 녹색 점이 있습니다.
녹색 점은 마지막으로 메시지를 본 이후 하나 이상의 새 메시지가 수신되었음을 나타냅니다.
1. **구독** 아래에서 **device/\$1/data**를 선택하여 메시지 페이로드가 방금 게시한 것과 일치하고 다음과 같이 표시되는지 확인하세요.
```
{
"temperature": 28,
"humidity": 80,
"barometer": 1013,
"wind": {
"velocity": 22,
"bearing": 255
}
}
```
1. **구독** 아래에서 **device/data/temp**를 선택하여 게시된 메시지 페이로드가 다음과 같이 표시되는지 확인하세요.
```
{
"device_id": "22",
"temperature": 28
}
```
`device_id` 값은 따옴표로 묶인 문자열이고 `temperature` 값은 숫자여야 합니다. 이는 [https://docs.aws.amazon.com//iot/latest/developerguide/iot-sql-functions.html#iot-function-topic](https://docs.aws.amazon.com//iot/latest/developerguide/iot-sql-functions.html#iot-function-topic) 함수가 입력 메시지의 주제 이름에서 문자열을 추출하는 반면 `temperature` 값은 입력 메시지의 페이로드에서 숫자 값을 사용하기 때문입니다.
`device_id` 값을 숫자 값으로 만들려면 규칙 쿼리 문에서 `topic(2)`를 다음으로 바꿉니다.
```
cast(topic(2) AS DECIMAL)
```
`topic(2)` 값을 숫자 값으로 캐스팅하는 것은 주제의 해당 부분에 숫자만 포함된 경우에만 작동합니다.
1. **device/data/temp** 주제에 올바른 메시지가 게시되었으면 규칙이 작동한 것입니다. 다음 섹션에서 재게시 규칙 작업에 대해 자세히 알아볼 수 있는 내용을 확인하세요.
**device/\$1/data** 또는 **device/data/temp** 주제에 올바른 메시지가 게시되었음을 확인할 수 없는 경우 문제 해결 팁을 확인하세요.
### 재게시 메시지 규칙 문제 해결
다음은 예상한 결과가 표시되지 않는 경우에 대비하여 확인해야 할 몇 가지 사항입니다.
+
**오류 배너가 있음**
입력 메시지를 게시할 때 오류가 나타나면 먼저 해당 오류를 수정하세요. 다음 단계는 해당 오류를 수정하는 데 도움이 될 수 있습니다.
+
**MQTT 클라이언트에서 입력 메시지가 표시되지 않음**
`device/+/data` 주제 필터를 구독한 경우 입력 메시지를 `device/22/data` 주제에 게시할 때마다 절차에 설명된 대로 해당 메시지가 MQTT 클라이언트에 나타나야 합니다.
**확인해야 할 사항**
+
**구독한 주제 필터 확인**
절차에 설명된 대로 입력 메시지 주제를 구독한 경우 게시할 때마다 입력 메시지의 복사본이 표시되어야 합니다.
메시지가 표시되지 않으면 구독한 주제 이름을 확인하고 게시한 주제와 비교합니다. 주제 이름은 대소문자를 구분하며 구독한 주제는 메시지 페이로드를 게시한 주제와 동일해야 합니다.
+
**메시지 게시 함수 확인**
MQTT 클라이언트의 **구독**에서 **device/\$1/data**를 선택하고 게시 메시지의 주제를 확인한 다음 **주제에 게시**를 선택합니다. 주제 아래의 편집 상자에서 메시지 페이로드가 메시지 목록에 나타납니다.
+
**MQTT 클라이언트에서 다시 게시된 메시지가 표시되지 않음**
규칙이 작동하려면 메시지를 수신하고 다시 게시하도록 권한을 부여하는 올바른 정책이 있어야 하며 메시지를 수신해야 합니다.
**확인해야 할 사항**
+
**MQTT 클라이언트 AWS 리전 의 및 생성한 규칙을 확인합니다.**
MQTT 클라이언트를 실행 중인 콘솔은 생성한 규칙과 동일한 AWS 리전에 있어야 합니다.
+
**규칙 쿼리 문의 입력 메시지 주제 확인**
규칙이 작동하려면 규칙 쿼리 문의 FROM 절에 있는 주제 필터와 일치하는 주제 이름이 포함된 메시지를 받아야 합니다.
MQTT 클라이언트에 있는 주제의 철자와 함께 규칙 쿼리 문에서 주제 필터의 철자를 확인하세요. 주제 이름은 대/소문자를 구분하며 메시지의 주제는 규칙 쿼리 문의 주제 필터와 일치해야 합니다.
+
**입력 메시지 페이로드의 내용 확인**
규칙이 작동하려면 SELECT 문에서 선언된 메시지 페이로드에서 데이터 필드를 찾아야 합니다.
MQTT 클라이언트에 있는 메시지 페이로드의 철자와 함께 규칙 쿼리 명령문의 `temperature` 필드 철자를 확인하세요. 필드 이름은 대소문자를 구분하며 규칙 쿼리 문의 `temperature` 필드는 메시지 페이로드의 `temperature` 필드와 동일해야 합니다.
메시지 페이로드의 JSON 문서의 형식이 올바른지 확인하세요. JSON에 쉼표 누락과 같은 오류가 있으면 규칙에서 읽을 수 없습니다.
+
**규칙 동작에서 다시 게시된 메시지 주제 확인**
재게시 규칙 작업에서 새 메시지를 게시하는 주제는 MQTT 클라이언트에서 구독한 주제와 일치해야 합니다.
콘솔에서 만든 규칙을 열고 규칙 작업이 메시지를 다시 게시할 주제를 확인합니다.
+
**규칙에서 사용 중인 역할 확인**
규칙 작업에는 원래 주제를 받고 새 주제를 게시할 수 있는 권한이 있어야 합니다.
메시지 데이터를 수신하고 다시 게시하도록 규칙을 인증하는 정책은 사용된 주제에 따라 다릅니다. 메시지 데이터를 다시 게시하는 데 사용되는 주제를 변경하는 경우 규칙 작업의 역할을 업데이트하여 현재 주제와 일치하도록 정책을 업데이트해야 합니다.
문제가 의심되는 경우 규칙 재게시 작업을 편집하고 새 역할을 만듭니다. 규칙 작업에 의해 생성된 새 역할에는 이러한 작업을 수행하는 데 필요한 권한이 부여됩니다.
## 3단계: 결과 및 다음 단계 검토
**이 자습서에서는**
+ 간단한 SQL 쿼리와 규칙 쿼리 문에서 몇 가지 함수를 사용하여 새 MQTT 메시지를 생성했습니다.
+ 새 메시지를 다시 게시 하는 규칙을 만들었습니다.
+ MQTT 클라이언트를 사용하여 AWS IoT 규칙을 테스트했습니다.
**다음 단계**
이 규칙을 사용하여 몇 가지 메시지를 다시 게시한 후 이 규칙을 실험하여 자습서의 일부 측면을 변경하면 다시 게시된 메시지에 어떤 영향을 주는지 확인해 보세요. 다음은 시작하는 데 도움이 될 몇 가지 아이디어입니다.
+ 입력 메시지의 주제에서 *device\$1id*를 변경하고 다시 게시된 메시지 페이로드의 영향을 관찰합니다.
+ 규칙 쿼리 문에서 선택한 필드를 변경하고 다시 게시된 메시지 페이로드의 영향을 관찰합니다.
+ 이 시리즈의 다음 자습서를 사용해 보고 [자습서: Amazon SNS 알림 전송](iot-sns-rule.md)의 방법을 알아봅니다.
이 자습서에서 사용되는 규칙 다시 게시 작업은 규칙 쿼리 문을 디버깅하는 데 도움이 될 수도 있습니다. 예를 들어 규칙에 이 작업을 추가하여 규칙 쿼리 문이 규칙 작업에 사용되는 데이터의 서식을 지정하는 방법을 확인할 수 있습니다.
# 자습서: Amazon SNS 알림 전송
이 자습서에서는 MQTT 메시지 데이터를 SMS 문자 메시지로 전송할 수 있도록 Amazon SNS 주제로 전송하는 AWS IoT 규칙을 생성하는 방법을 보여줍니다.
이 자습서에서는 온도가 규칙에 설정된 값을 초과할 때마다 기후 센서에서 Amazon SNS 주제의 모든 구독자에게 메시지 데이터를 전송하는 규칙을 생성합니다. 이 규칙은 보고된 온도가 규칙에 의해 설정된 값을 초과할 때를 감지하고 디바이스 ID, 보고된 온도 및 초과된 온도 제한만 포함하는 새 메시지 페이로드를 생성합니다. 이 규칙은 새 메시지 페이로드를 JSON 문서로 SNS 주제에 전송하여 모든 구독자에게 SNS 주제를 알립니다.
**이 자습서에서 배울 내용:**
+ Amazon SNS 알림을 생성하고 테스트하는 방법
+ AWS IoT 규칙에서 Amazon SNS 알림을 호출하는 방법
+ 규칙 쿼리 문에서 간단한 SQL 쿼리 및 함수를 사용하는 방법
+ MQTT 클라이언트를 사용하여 AWS IoT 규칙을 테스트하는 방법
이 자습서는 완료하는 데 약 30분 걸립니다.
**Topics**
+ [1단계: SMS 문자 메시지를 전송하는 Amazon SNS 주제 생성](#iot-sns-rule-create-sns-topic)
+ [2단계: 텍스트 메시지를 전송하는 AWS IoT 규칙 생성](#iot-sns-rule-create-rule)
+ [3단계: AWS IoT 규칙 및 Amazon SNS 알림 테스트](#iot-sns-rule-test-rule)
+ [4단계: 결과 및 다음 단계 검토](#iot-sns-rule-review-results)
**이 자습서를 시작하기 전에 다음 사항을 확인해야 합니다.**
+
**[설정 AWS 계정](setting-up.md)**
이 자습서를 완료하려면 AWS 계정 및 AWS IoT 콘솔이 필요합니다.
+
**검토된 [MQTT 클라이언트를 사용하여 AWS IoT MQTT 메시지 보기](view-mqtt-messages.md)**
MQTT 클라이언트를 사용하여 주제를 구독하고 게시할 수 있는지 확인하세요. 이 절차에서는 MQTT 클라이언트를 사용하여 새 규칙을 테스트합니다.
+
**[Amazon Simple Notification Service](https://docs.aws.amazon.com//sns/latest/dg/welcome.html)를 검토했습니다.**
이전에 Amazon SNS 사용한 적이 없는 경우 [Amazon SNS 액세스 설정](https://docs.aws.amazon.com//sns/latest/dg/sns-setting-up.html)을 검토합니다. 다른 AWS IoT 자습서를 이미 완료한 경우가 AWS 계정 이미 올바르게 구성되어 있어야 합니다.
## 1단계: SMS 문자 메시지를 전송하는 Amazon SNS 주제 생성
이 절차에서는 날씨 센서가 메시지 데이터를 보낼 수 있는 Amazon SNS 주제를 생성하는 방법을 설명합니다. 그러면 Amazon SNS 주제가 SMS 텍스트 메시지를 통해 모든 구독자에게 초과된 온도 제한을 알립니다.
**SMS 문자 메시지를 전송하는 Amazon SNS 주제를 생성하려면**
1. **Amazon SNS 주제를 생성합니다.**
1. [Amazon SNS 콘솔](https://console.aws.amazon.com//sns/home)에 로그인합니다.
1. 왼쪽 탐색 창에서 **주제**를 선택합니다.
1. **주제(Topics)** 페이지에서 **새 주제 생성(Create new topic)**을 선택합니다.
1. **세부 정보**에서 **표준** 유형을 선택합니다. 기본적으로 콘솔은 FIFO 주제를 만듭니다.
1. **이름**에 SNS 주제 이름을 입력합니다. 이 자습서에서는 **high\$1temp\$1notice**을 입력합니다.
1. 페이지 끝으로 스크롤하고 **주제 생성**을 선택합니다.
콘솔에 새 주제의 **세부 정보** 페이지가 열립니다.
1. **Amazon SNS 구독을 생성합니다.**
**참고**
이 구독에서 사용하는 전화번호는 이 자습서에서 전송할 메시지에서 문자 메시지 요금을 부과할 수 있습니다.
1. **high\$1temp\$1notice** 주제 세부 정보 페이지에서 **구독 생성(Create subscription)**을 선택합니다.
1. **구독 생성**에 있는 **세부 정보** 섹션의 **프로토콜** 목록에서 **SMS**를 선택합니다.
1. **엔드포인트**에 문자 메시지를 받을 수 있는 전화 번호를 입력합니다. `+`로 시작하고 국가 및 지역 코드를 포함하고 다른 구두점은 포함하지 않도록 입력해야 합니다.
1. **구독 생성**을 선택합니다.
1. **Amazon SNS 알림을 테스트합니다.**
1. [Amazon SNS 콘솔](https://console.aws.amazon.com//sns/home)의 왼쪽 탐색 창에서 **주제**를 선택합니다.
1. 주제의 세부 정보 페이지를 열려면 **주제**의 주제 목록에서 **high\$1temp\$1notice**를 선택합니다.
1. **주제에 메시지 게시(Publish message to topic)** 페이지를 열려면 **high\$1temp\$1notice** 세부 정보 페이지에서 **메시지 게시(Publish message)**를 선택합니다.
1. **주제에 메시지 게시(Publish message to topic)**에 있는 **메시지 본문** 섹션에서 **엔드포인트로 전송할 메시지 본문(Message body to send to the endpoint)**에 짧은 메시지를 입력합니다.
1. 페이지의 하단으로 스크롤하고 **메시지 게시(Publish message)**를 선택합니다.
1. 구독을 만들 때 이전에 사용한 번호가 있는 전화에서 메시지가 수신되었는지 확인하세요.
테스트 메시지를 받지 못한 경우 전화 번호와 휴대 전화 설정을 다시 확인하세요.
자습서를 계속하기 전에 [Amazon SNS 콘솔](https://console.aws.amazon.com//sns/home)에서 테스트 메시지를 게시할 수 있는지 확인하세요.
## 2단계: 텍스트 메시지를 전송하는 AWS IoT 규칙 생성
이 자습서에서 생성할 AWS IoT 규칙은 메시지를 전송한 디바이스의 ID`device_id`가 인 `device/device_id/data` MQTT 주제를 구독합니다. 이러한 주제는 주제 필터에서 `device/+/data`로 설명됩니다. 여기서 `+`는 두 개의 슬래시 문자 사이의 모든 문자열과 일치하는 와일드카드 문자입니다. 이 규칙은 메시지 페이로드의 `temperature` 필드 값도 테스트합니다.
규칙이 일치하는 주제로부터 메시지를 수신하면 주제 이름에서 `device_id`, 메시지 페이로드에서 `temperature` 값을 가져와 테스트 중인 제한에 대한 상수 값을 추가하고 이러한 값을 JSON 문서로 Amazon SNS 알림 주제에 전송합니다.
예를 들어, 기상 센서 디바이스 번호 32의 MQTT 메시지는 `device/32/data` 주제를 사용하고 다음과 같은 메시지 페이로드가 있습니다.
```
{
"temperature": 38,
"humidity": 80,
"barometer": 1013,
"wind": {
"velocity": 22,
"bearing": 255
}
}
```
규칙의 규칙 쿼리 문은 메시지 페이로드에서 `temperature` 값을 가져오고 주제 이름에서 `device_id`를 가져오고 상수 `max_temperature` 값을 추가하여 다음과 같은 메시지 페이로드를 Amazon SNS 주제로 전송합니다.
```
{
"device_id": "32",
"reported_temperature": 38,
"max_temperature": 30
}
```
**제한 초과 온도 값을 감지하고 Amazon SNS 주제로 전송할 데이터를 생성하는 AWS IoT 규칙을 생성하려면**
1. [AWS IoT 콘솔의 **규칙** 허브를](https://console.aws.amazon.com//iot/home#/rulehub) 엽니다.
1. 이것이 첫 번째 규칙인 경우 **생성** 또는 **규칙 생성**을 선택합니다.
1. **규칙 생성(Create a rule)**에서:
1. **이름(Name)**에 **temp\$1limit\$1notify**를 입력합니다.
규칙 이름은 AWS 계정 및 리전 내에서 고유해야 하며 공백을 가질 수 없습니다. 이 이름에 밑줄 문자를 사용하여 규칙 이름의 단어를 구분했습니다.
1. **설명**에서 규칙을 설명합니다.
의미 있는 설명을 사용하면 이 규칙이 수행하는 작업과 규칙을 만든 이유를 쉽게 기억할 수 있습니다. 설명은 필요한 만큼 길어질 수 있으므로 가능한 한 자세하게 설명하세요.
1. **규칙 생성**의 **규칙 쿼리 문**에서:
1. **SQL 버전 사용**에서 **2016-03-23**을 선택합니다.
1. **규칙 쿼리 문** 편집 상자에 쿼리 문을 입력합니다.
```
SELECT topic(2) as device_id,
temperature as reported_temperature,
30 as max_temperature
FROM 'device/+/data'
WHERE temperature > 30
```
이 문은 다음을 수행합니다.
+ `device/+/data` 주제 필터와 일치하고 `temperature` 값이 30보다 큰 주제가 있는 MQTT 메시지를 수신 대기합니다.
+ 주제 문자열에서 두 번째 요소를 선택하여 `device_id` 필드에 할당합니다.
+ 메시지 페이로드에서 `temperature` 값 필드를 선택하여 `reported_temperature` 필드에 할당합니다.
+ 한계 값을 나타내는 상수 값 `30`을 생성하고 `max_temperature` 필드에 할당합니다.
1. 이 규칙에 대한 규칙 작업 목록을 열려면 **하나 이상의 작업 설정(Set one or more actions)**에서 **작업 추가(Add action)**를 선택합니다.
1. **Select an action(작업 선택)**에서 **SNS 푸시 알림으로 메시지 전송(Send a message as an SNS push notification)**을 선택합니다.
1. 작업 목록 하단에서 선택한 작업의 구성 페이지를 열려면 **구성 작업**을 선택합니다.
1. **구성 작업**에서:
1. **SNS 대상**에서 **선택(Select)**을 클릭하고 **high\$1temp\$1notice**라는 이름의 SNS 주제를 찾은 다음 **선택(Select)**을 클릭합니다.
1. **메시지 형식(Message format)**에서 **RAW**를 선택합니다.
1. **이 작업을 수행할 수 있는 AWS IoT 액세스 권한을 부여할 역할 선택 또는 생성**에서 **역할 생성을** 선택합니다.
1. **새 역할 생성**에서 **이름**에 새 역할의 고유 이름을 입력합니다. 본 자습서에서는 **sns\$1rule\$1role**를 사용합니다.
1. **역할 생성**을 선택합니다.
이 자습서를 반복하거나 기존 역할을 재사용하는 경우 계속 진행하기 전에 **역할 업데이트**를 선택합니다. 그러면 SNS 대상에서 작동하도록 역할의 정책 문서가 업데이트됩니다.
1. **작업 추가**를 선택하여 **규칙 생성** 페이지로 이동합니다.
새 작업의 타일에서 **SNS 푸시 알림으로 메시지 전송하기(Send a message as an SNS push notification)** 아래에서 규칙이 호출할 SNS 주제를 볼 수 있습니다.
이 규칙 작업은 이 규칙에 추가할 유일한 규칙 작업입니다.
1. 규칙을 생성하고 이 단계를 완료하려면 **규칙 생성(Create a rule)**에서 하단으로 스크롤하여 **규칙 생성(Create rule)**을 선택합니다.
## 3단계: AWS IoT 규칙 및 Amazon SNS 알림 테스트
새 규칙을 테스트하려면 MQTT 클라이언트를 사용하여 이 규칙에서 사용하는 MQTT 메시지를 게시하고 구독합니다.
새 창에서 [AWS IoT 콘솔의 MQTT 클라이언트](https://console.aws.amazon.com//iot/home#/test)를 엽니다. 이렇게 하면 MQTT 클라이언트의 구성을 그대로 유지하면서 규칙을 편집할 수 있습니다. 콘솔의 다른 페이지로 이동하기 위해 MQTT 클라이언트를 나가면 구독이나 메시지 로그가 유지되지 않습니다.
**MQTT 클라이언트를 사용하여 규칙을 테스트하려면**
1. [AWS IoT 콘솔의 MQTT 클라이언트](https://console.aws.amazon.com//iot/home#/test)에서 입력 주제(이 경우 `device/+/data`)를 구독합니다.
1. MQTT 클라이언트에서 **구독** 아래에서 **주제 구독**을 선택합니다.
1. **구독 주제**에 입력 주제 필터 **device/\$1/data**의 주제를 입력합니다.
1. 나머지 필드는 기본 설정을 유지합니다.
1. **주제 구독**을 선택합니다.
**구독** 열의 **주제 게시** 아래에 **device/\$1/data**가 나타납니다.
1. 특정 디바이스 ID **device/32/data**로 입력 주제에 메시지를 게시합니다. 와일드카드 문자가 포함된 MQTT 항목에는 게시할 수 없습니다.
1. MQTT 클라이언트의 **구독** 아래에서 **주제 게시**를 선택합니다.
1. **게시** 필드에 입력 주제 이름 **device/32/data**를 입력합니다.
1. 여기에 표시된 샘플 데이터를 복사하고 주제 이름 아래의 편집 상자에 샘플 데이터를 붙여 넣습니다.
```
{
"temperature": 38,
"humidity": 80,
"barometer": 1013,
"wind": {
"velocity": 22,
"bearing": 255
}
}
```
1. **주제에 게시**를 선택하여 MQTT 메시지를 게시합니다.
1. 문자 메시지가 전송되었는지 확인합니다.
1. MQTT 클라이언트의 **구독** 아래에서 이전에 구독한 주제 옆에 녹색 점이 있습니다.
녹색 점은 마지막으로 메시지를 보았을 때 하나 이상의 새 메시지가 수신되었음을 나타냅니다.
1. **구독** 아래에서 **device/\$1/data**를 선택하여 메시지 페이로드가 방금 게시한 것과 일치하고 다음과 같이 표시되는지 확인하세요.
```
{
"temperature": 38,
"humidity": 80,
"barometer": 1013,
"wind": {
"velocity": 22,
"bearing": 255
}
}
```
1. SNS 주제를 구독하는 데 사용한 전화를 확인하고 메시지 페이로드의 내용이 다음과 같이 표시되는지 확인합니다.
```
{"device_id":"32","reported_temperature":38,"max_temperature":30}
```
`device_id` 값은 따옴표로 묶인 문자열이고 `temperature` 값은 숫자여야 합니다. 이는 [https://docs.aws.amazon.com//iot/latest/developerguide/iot-sql-functions.html#iot-function-topic](https://docs.aws.amazon.com//iot/latest/developerguide/iot-sql-functions.html#iot-function-topic) 함수가 입력 메시지의 주제 이름에서 문자열을 추출하는 반면 `temperature` 값은 입력 메시지의 페이로드에서 숫자 값을 사용하기 때문입니다.
`device_id` 값을 숫자 값으로 만들려면 규칙 쿼리 문에서 `topic(2)`를 다음으로 바꿉니다.
```
cast(topic(2) AS DECIMAL)
```
주제의 해당 부분에 숫자만 포함된 경우에만 `topic(2)` 값을 숫자 `DECIMAL` 값으로 캐스팅할 수 있다는 점을 유의하세요.
1. 온도가 한계를 초과하지 않는 MQTT 메시지를 전송해보세요.
1. MQTT 클라이언트의 **구독** 아래에서 **주제 게시**를 선택합니다.
1. **게시** 필드에 입력 주제 이름 **device/33/data**를 입력합니다.
1. 여기에 표시된 샘플 데이터를 복사하고 주제 이름 아래의 편집 상자에 샘플 데이터를 붙여 넣습니다.
```
{
"temperature": 28,
"humidity": 80,
"barometer": 1013,
"wind": {
"velocity": 22,
"bearing": 255
}
}
```
1. MQTT 메시지를 전송하려면 **주제 게시**를 선택합니다.
**device/\$1/data** 구독에서 전송한 메시지가 표시되어야 합니다. 그러나 온도 값이 규칙 쿼리 문에서 최대 온도보다 낮기 때문에 문자 메시지를 받지 않아야 합니다.
올바른 동작이 표시되지 않으면 문제 해결 팁을 확인합니다.
### SNS 메시지 규칙 문제 해결
예상한 결과가 표시되지 않는 경우를 대비하여 확인해야 할 몇 가지 사항이 있습니다.
+
**오류 배너가 있음**
입력 메시지를 게시할 때 오류가 나타나면 먼저 해당 오류를 수정하세요. 다음 단계는 해당 오류를 수정하는 데 도움이 될 수 있습니다.
+
**MQTT 클라이언트에서 입력 메시지가 표시되지 않음**
`device/+/data` 주제 필터를 구독한 경우 입력 메시지를 `device/22/data` 주제에 게시할 때마다 절차에 설명된 대로 해당 메시지가 MQTT 클라이언트에 나타나야 합니다.
**확인해야 할 사항**
+
**구독한 주제 필터 확인**
절차에 설명된 대로 입력 메시지 주제를 구독한 경우 게시할 때마다 입력 메시지의 복사본이 표시되어야 합니다.
메시지가 표시되지 않으면 구독한 주제 이름을 확인하고 게시한 주제와 비교합니다. 주제 이름은 대소문자를 구분하며 구독한 주제는 메시지 페이로드를 게시한 주제와 동일해야 합니다.
+
**메시지 게시 함수 확인**
MQTT 클라이언트의 **구독**에서 **device/\$1/data**를 선택하고 게시 메시지의 주제를 확인한 다음 **주제에 게시**를 선택합니다. 주제 아래의 편집 상자에서 메시지 페이로드가 메시지 목록에 나타납니다.
+
**SMS 메시지가 수신되지 않음**
규칙이 작동하려면 메시지를 수신하고 SNS 알림을 전송할 수 있도록 권한을 부여하는 올바른 정책이 있어야 하며 메시지를 수신해야 합니다.
**확인해야 할 사항**
+
**MQTT 클라이언트 AWS 리전 의 및 생성한 규칙을 확인합니다.**
MQTT 클라이언트를 실행 중인 콘솔은 생성한 규칙과 동일한 AWS 리전에 있어야 합니다.
+
**메시지 페이로드의 온도 값이 테스트 임계값을 초과하는지 확인**
규칙 쿼리 문에 정의된 대로 온도 값이 30보다 작거나 같으면 규칙은 해당 작업을 수행하지 않습니다.
+
**규칙 쿼리 문의 입력 메시지 주제 확인**
규칙이 작동하려면 규칙 쿼리 문의 FROM 절에 있는 주제 필터와 일치하는 주제 이름이 포함된 메시지를 받아야 합니다.
MQTT 클라이언트에 있는 주제의 철자와 함께 규칙 쿼리 문에서 주제 필터의 철자를 확인하세요. 주제 이름은 대/소문자를 구분하며 메시지의 주제는 규칙 쿼리 문의 주제 필터와 일치해야 합니다.
+
**입력 메시지 페이로드의 내용 확인**
규칙이 작동하려면 SELECT 문에서 선언된 메시지 페이로드에서 데이터 필드를 찾아야 합니다.
MQTT 클라이언트에 있는 메시지 페이로드의 철자와 함께 규칙 쿼리 명령문의 `temperature` 필드 철자를 확인하세요. 필드 이름은 대소문자를 구분하며 규칙 쿼리 문의 `temperature` 필드는 메시지 페이로드의 `temperature` 필드와 동일해야 합니다.
메시지 페이로드의 JSON 문서의 형식이 올바른지 확인하세요. JSON에 쉼표 누락과 같은 오류가 있으면 규칙에서 읽을 수 없습니다.
+
**규칙 동작에서 다시 게시된 메시지 주제 확인**
재게시 규칙 작업에서 새 메시지를 게시하는 주제는 MQTT 클라이언트에서 구독한 주제와 일치해야 합니다.
콘솔에서 만든 규칙을 열고 규칙 작업이 메시지를 다시 게시할 주제를 확인합니다.
+
**규칙에서 사용 중인 역할 확인**
규칙 작업에는 원래 주제를 받고 새 주제를 게시할 수 있는 권한이 있어야 합니다.
메시지 데이터를 수신하고 다시 게시하도록 규칙을 인증하는 정책은 사용된 주제에 따라 다릅니다. 메시지 데이터를 다시 게시하는 데 사용되는 주제를 변경하는 경우 규칙 작업의 역할을 업데이트하여 현재 주제와 일치하도록 정책을 업데이트해야 합니다.
문제가 의심되는 경우 규칙 재게시 작업을 편집하고 새 역할을 만듭니다. 규칙 작업에 의해 생성된 새 역할에는 이러한 작업을 수행하는 데 필요한 권한이 부여됩니다.
## 4단계: 결과 및 다음 단계 검토
**이 자습서에서**
+ Amazon SNS 알림 주제 및 구독을 생성하고 테스트했습니다.
+ 규칙 쿼리 문에서 간단한 SQL 쿼리 및 함수를 사용하여 알림에 대한 새 메시지를 만들었습니다.
+ 사용자 지정 메시지 페이로드를 사용한 Amazon SNS 알림을 보내는 AWS IoT 규칙을 생성했습니다.
+ MQTT 클라이언트를 사용하여 AWS IoT 규칙을 테스트했습니다.
**다음 단계**
이 규칙을 사용하여 몇 가지 문자 메시지를 전송한 후 이 규칙을 실험하여 자습서의 일부 측면을 변경하면 메시지가 전송되는 시기에 영향을 받는지 확인하세요. 다음은 시작하는 데 도움이 될 몇 가지 아이디어입니다.
+ 입력 메시지의 주제에서 *device\$1id*를 변경하고 문자 메시지 내용의 영향을 관찰합니다.
+ 규칙 쿼리 문에서 선택한 필드를 변경하고 텍스트 메시지 내용의 영향을 관찰합니다.
+ 최대 온도 대신 최소 온도에 대한 테스트 규칙 쿼리 문에서 테스트를 변경합니다. `max_temperature` 이름을 변경하는 것을 잊지 마세요\$1
+ SNS 알림이 전송될 때 MQTT 메시지를 전송하기 위한 재게시 규칙 작업을 추가합니다.
+ 이 시리즈의 다음 자습서를 사용해 보고 [자습서: DynamoDB 테이블에 디바이스 데이터 저장](iot-ddb-rule.md)의 방법을 알아봅니다.
# 자습서: DynamoDB 테이블에 디바이스 데이터 저장
이 자습서에서는 DynamoDB 테이블로 메시지 데이터를 보내는 AWS IoT 규칙을 생성하는 방법을 보여줍니다.
이 자습서에서는 가상 기상 센서 디바이스에서 DynamoDB 테이블로 메시지 데이터를 전송하는 규칙을 생성합니다. 이 규칙은 여러 기상 센서의 데이터를 단일 데이터베이스 테이블에 추가할 수 있도록 포맷합니다.
**이 자습서에서 배울 내용**
+ DynamoDB 테이블 생성 방법
+ AWS IoT 규칙에서 DynamoDB 테이블로 메시지 데이터를 보내는 방법
+ AWS IoT 규칙에서 대체 템플릿을 사용하는 방법
+ 규칙 쿼리 문에서 간단한 SQL 쿼리 및 함수를 사용하는 방법
+ MQTT 클라이언트를 사용하여 AWS IoT 규칙을 테스트하는 방법
이 자습서는 완료하는 데 약 30분 걸립니다.
**Topics**
+ [1단계: 이 자습서를 위한 DynamoDB 테이블 생성](#iot-ddb-rule-ddb-table)
+ [2단계: DynamoDB 테이블로 데이터를 전송하는 AWS IoT 규칙 생성](#iot-ddb-rule-topic-rule)
+ [3단계: AWS IoT 규칙 및 DynamoDB 테이블 테스트](#iot-ddb-rule-test)
+ [4단계: 결과 및 다음 단계 검토](#iot-ddb-rule-review)
**이 자습서를 시작하기 전에 다음 사항을 확인해야 합니다.**
+
**[설정 AWS 계정](setting-up.md)**
이 자습서를 완료하려면 AWS 계정 및 AWS IoT 콘솔이 필요합니다.
+
**검토된 [MQTT 클라이언트를 사용하여 AWS IoT MQTT 메시지 보기](view-mqtt-messages.md)**
MQTT 클라이언트를 사용하여 주제를 구독하고 게시할 수 있는지 확인하세요. 이 절차에서는 MQTT 클라이언트를 사용하여 새 규칙을 테스트합니다.
+
**[Amazon DynamoDB](https://docs.aws.amazon.com//amazondynamodb/latest/developerguide/Introduction.html) 개요를 검토했습니다.**
이전에 DynamoDB 를 사용하지 않았다면 DynamoDB의 기본 개념과 운영에 익숙해지도록 [DynamoDB 시작하기](https://docs.aws.amazon.com//amazondynamodb/latest/developerguide/GettingStartedDynamoDB.html)를 검토하세요.
## 1단계: 이 자습서를 위한 DynamoDB 테이블 생성
이 자습서에서는 다음과 같은 속성이 포함된 DynamoDB 테이블을 만들어 가상 기상 센서 디바이스의 데이터를 기록합니다.
+ `sample_time`은 기본 키이며 샘플이 기록된 시간을 설명합니다.
+ `device_id`는 정렬 키이며 샘플을 제공한 디바이스를 설명합니다.
+ `device_data`는 디바이스에서 수신되고 규칙 쿼리 문에 의해 형식이 지정된 데이터입니다.
**이 자습서용 DynamoDB 테이블을 생성하려면**
1. [DynamoDB 콘솔](https://console.aws.amazon.com//dynamodb/home)을 열고 **테이블 생성**을 선택합니다.
1. **테이블 생성(Create table)**에서
1. **테이블 이름**에 테이블 이름 **wx\$1data**를 입력합니다.
1. **파티션 키(Partition key)**에 **sample\$1time**을 입력하고 필드 옆에 있는 옵션 목록에서 **Number**를 선택합니다.
1. **정렬 키(Sort key)**에 **device\$1id**를 입력하고 필드 옆에 있는 옵션 목록에서 **Number**를 선택합니다.
1. 페이지 하단에서 **생성(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
}
```
이 규칙에서는 몇 가지 [대체 템플릿](iot-substitution-templates.md)을(를) 사용합니다. 대체 템플릿은 함수 및 메시지 데이터에서 동적 값을 삽입할 수 있는 표현식입니다.
**DynamoDB 테이블로 데이터를 전송하는 AWS IoT 규칙을 생성하려면**
1. [AWS IoT 콘솔의 규칙 허브](https://console.aws.amazon.com//iot/home#/rulehub)를 엽니다. 또는 내에서 AWS IoT AWS Management Console 홈페이지를 열고 **메시지 라우팅>규칙**으로 이동할 수 있습니다.
1. **규칙(Rules)**에서 새 규칙 생성을 시작하려면 **규칙 생성(Create rule)**을 선택합니다.
1. **규칙 속성(Rule properties)**에서
1. **규칙 이름(Rule name)**에 **wx\$1data\$1ddb**를 입력합니다.
규칙 이름은 AWS 계정 및 리전 내에서 고유해야 하며 공백을 가질 수 없습니다. 이 이름에 밑줄 문자를 사용하여 규칙 이름의 두 단어를 구분했습니다.
1. **규칙 설명(Rule description)**에서 규칙을 설명합니다.
의미 있는 설명을 사용하면 이 규칙이 수행하는 작업과 규칙을 만든 이유를 쉽게 기억할 수 있습니다. 설명은 필요한 만큼 길어질 수 있으므로 가능한 한 자세하게 설명하세요.
1. **다음**을 선택하여 계속 진행합니다.
1. **SQL 문(SQL statement)**에서
1. **SQL 버전(SQL version)**에서 **2016-03-23**을 선택합니다.
1. **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` 속성은 변경되지 않은 상태로 전달합니다.
1. **다음**을 선택하여 계속 진행합니다.
1. **규칙 작업(Rule actions)**에서
1. 이 규칙에 대한 규칙 작업 목록을 열려면 **작업 1(Action 1)**에서 **DynamoDB**를 선택합니다.
**참고**
규칙 작업으로 DynamoDBv2가 아니라 DynamoDB를 선택해야 합니다.
1. **테이블 이름**에서 이전 단계에서 생성한 DynamoDB 테이블의 이름 **wx\$1data**를 선택합니다.
**파티션 키 유형(Partition key type)** 및 **정렬 키 유형(Sort key type)** 필드는 DynamoDB 테이블의 값으로 채워집니다.
1. **파티션 키**에서 **sample\$1time**를 입력합니다.
1. **파티션 키 값**에 **\$1\$1timestamp()\$1**를 입력합니다.
이것은 이 규칙에서 사용할 첫 번째 [대체 템플릿](iot-substitution-templates.md)입니다. 메시지 페이로드의 값을 사용하는 대신 timestamp 함수에서 반환된 값을 사용합니다. 자세한 내용은 *AWS IoT Core 개발자 안내서*의 [timestamp](iot-sql-functions.md#iot-function-timestamp)를 참조하세요.
1. **정렬 키(Sort key)**에 **device\$1id**를 입력합니다.
1. **정렬 키 값**에 **\$1\$1cast(topic(2) AS DECIMAL)\$1**를 입력합니다.
이것은 이 규칙에서 사용할 두 번째 [대체 템플릿](iot-substitution-templates.md)입니다. 키의 숫자 형식과 일치하도록 DECIMAL 값으로 캐스트한 후 디바이스 ID인 주제 이름에 두 번째 요소의 값을 삽입합니다. 주제에 대한 자세한 내용은 *AWS IoT Core 개발자 안내서*의 [topic](iot-sql-functions.md#iot-function-topic)을 참조하세요. 캐스팅에 대한 자세한 내용은 *AWS IoT Core 개발자 안내서*의 [cast](iot-sql-functions.md#iot-sql-function-cast)를 참조하세요.
1. **이 열에 메시지 데이터 쓰기**에 **device\$1data**를 입력합니다.
그러면 DynamoDB 테이블에 `device_data` 열이 생성됩니다.
1. **작업**은 비워 둡니다.
1. **IAM role**(IAM 역할)에서 **Create new role**(새 역할 생성)을 선택합니다.
1. **Create role**(역할 생성) 대화 상자에서 **Role name**(역할 이름)에 **wx\$1ddb\$1role**을 입력합니다. 이 새 역할에는 'aws-iot-rule'이라는 접두사가 붙은 정책이 자동으로 포함되며, 이 정책을 통해 **wx\$1data\$1ddb** 규칙이 사용자가 생성한 **wx\$1data** DynamoDB 테이블로 데이터를 전송할 수 있습니다.
1. **IAM 역할(IAM role)**에서 **wx\$1ddb\$1role**을 선택합니다.
1. 페이지 하단에서 **다음(Next)**을 선택합니다.
1. **검토 및 생성(Review and create)** 페이지 하단에서 **생성(Create)**을 선택하여 규칙을 생성합니다.
## 3단계: AWS IoT 규칙 및 DynamoDB 테이블 테스트
새 규칙을 테스트하려면 MQTT 클라이언트를 사용하여 이 테스트에 사용된 MQTT 메시지를 게시하고 구독합니다.
새 창에서 [AWS IoT 콘솔의 MQTT 클라이언트](https://console.aws.amazon.com//iot/home#/test)를 엽니다. 이렇게 하면 MQTT 클라이언트의 구성을 그대로 유지하면서 규칙을 편집할 수 있습니다. MQTT 클라이언트는 콘솔의 다른 페이지로 이동하기 위해 나가면 구독 또는 메시지 로그를 유지하지 않습니다. 또한 규칙이 보내는 새 항목을 보려면 콘솔의 [DynamoDB Tables 허브에 별도의 AWS IoT 콘솔](https://console.aws.amazon.com//dynamodb/home#tables:) 창을 열어야 합니다.
**MQTT 클라이언트를 사용하여 규칙을 테스트하려면**
1. [AWS IoT 콘솔의 MQTT 클라이언트](https://console.aws.amazon.com//iot/home#/test)에서 입력 주제(`device/+/data`)를 구독합니다.
1. MQTT 클라이언트에서 **주제 구독(Subscribe to a topic)**을 선택합니다.
1. **주제 필터**에 입력 주제 필터의 주제(**device/\$1/data**)를 입력합니다.
1. **구독**을 선택합니다.
1. 이제 특정 디바이스 ID **device/22/data**로 입력 주제에 메시지를 게시합니다. 와일드카드 문자가 포함된 MQTT 항목에는 게시할 수 없습니다.
1. MQTT 클라이언트에서 **주제에 게시(Publish to a topic)**를 선택합니다.
1. **주제 이름(Topic name)**에 주제 이름(**device/22/data**)을 입력합니다.
1. **메시지 페이로드**에 다음 샘플 데이터를 입력합니다.
```
{
"temperature": 28,
"humidity": 80,
"barometer": 1013,
"wind": {
"velocity": 22,
"bearing": 255
}
}
```
1. MQTT 메시지를 게시하려면 **게시**를 선택합니다.
1. 이제 MQTT 클라이언트에서 **주제 구독(Subscribe to a topic)**을 선택합니다. **구독** 열에서 **device/\$1/data** 구독을 선택합니다. 이전 단계의 샘플 데이터가 나타나는지 확인합니다.
1. 규칙에서 생성한 DynamoDB 테이블의 행을 보려면 선택합니다.
1. [AWS IoT 콘솔의 DynamoDB 테이블 허브에서](https://console.aws.amazon.com//dynamodb/home#tables:) **wx\$1data**를 선택한 다음 **항목** 탭을 선택합니다.
**항목(Items)** 탭이 이미 사용 중인 경우 테이블 헤더의 오른쪽 상단 모서리에서 새로 고침 아이콘을 선택하여 디스플레이를 새로 고쳐야 할 수 있습니다.
1. 테이블의 **sample\$1time** 값은 링크이며 하나를 엽니다. 방금 첫 번째 메시지를 전송한 경우 이는 목록에 있는 유일한 메시지입니다.
이 링크는 테이블의 해당 행에 있는 모든 데이터를 표시합니다.
1. **device\$1data** 항목을 확장하여 규칙 쿼리 문에서 생성된 데이터를 확인합니다.
1. 이 디스플레이에서 사용할 수 있는 데이터의 다양한 표현을 살펴보세요. 이 디스플레이에서 데이터를 편집할 수도 있습니다.
1. 이 데이터 행 검토를 마친 후 변경 사항을 저장하려면 **저장**을 선택하고 변경 사항을 저장하지 않고 종료하려면 **취소**를 선택합니다.
올바른 동작이 표시되지 않으면 문제 해결 팁을 확인합니다.
### DynamoDB 규칙 문제 해결
다음은 예상한 결과가 표시되지 않는 경우에 대비하여 확인해야 할 몇 가지 사항입니다.
+
**오류 배너가 있음**
입력 메시지를 게시할 때 오류가 나타나면 먼저 해당 오류를 수정하세요. 다음 단계는 해당 오류를 수정하는 데 도움이 될 수 있습니다.
+
**MQTT 클라이언트에서 입력 메시지가 표시되지 않음**
`device/+/data` 주제 필터를 구독한 경우 입력 메시지를 `device/22/data` 주제에 게시할 때마다 절차에 설명된 대로 해당 메시지가 MQTT 클라이언트에 나타나야 합니다.
**확인해야 할 사항**
+
**구독한 주제 필터 확인**
절차에 설명된 대로 입력 메시지 주제를 구독한 경우 게시할 때마다 입력 메시지의 복사본이 표시되어야 합니다.
메시지가 표시되지 않으면 구독한 주제 이름을 확인하고 게시한 주제와 비교합니다. 주제 이름은 대소문자를 구분하며 구독한 주제는 메시지 페이로드를 게시한 주제와 동일해야 합니다.
+
**메시지 게시 함수 확인**
MQTT 클라이언트의 **구독**에서 **device/\$1/data**를 선택하고 게시 메시지의 주제를 확인한 다음 **주제에 게시**를 선택합니다. 주제 아래의 편집 상자에서 메시지 페이로드가 메시지 목록에 나타납니다.
+
**DynamoDB 테이블에 데이터가 표시되지 않음**
가장 먼저 할 일은 테이블 헤더의 오른쪽 상단 모서리에 있는 새로 고침 아이콘을 선택하여 디스플레이를 새로 고치는 것입니다. 찾고있는 데이터가 표시되지 않으면 다음을 확인하세요.
**확인해야 할 사항**
+
**MQTT 클라이언트 AWS 리전 의 및 생성한 규칙을 확인합니다.**
MQTT 클라이언트를 실행 중인 콘솔은 생성한 규칙과 동일한 AWS 리전에 있어야 합니다.
+
**규칙 쿼리 문의 입력 메시지 주제 확인**
규칙이 작동하려면 규칙 쿼리 문의 FROM 절에 있는 주제 필터와 일치하는 주제 이름이 포함된 메시지를 받아야 합니다.
MQTT 클라이언트에 있는 주제의 철자와 함께 규칙 쿼리 문에서 주제 필터의 철자를 확인하세요. 주제 이름은 대/소문자를 구분하며 메시지의 주제는 규칙 쿼리 문의 주제 필터와 일치해야 합니다.
+
**입력 메시지 페이로드의 내용 확인**
규칙이 작동하려면 SELECT 문에서 선언된 메시지 페이로드에서 데이터 필드를 찾아야 합니다.
MQTT 클라이언트에 있는 메시지 페이로드의 철자와 함께 규칙 쿼리 명령문의 `temperature` 필드 철자를 확인하세요. 필드 이름은 대소문자를 구분하며 규칙 쿼리 문의 `temperature` 필드는 메시지 페이로드의 `temperature` 필드와 동일해야 합니다.
메시지 페이로드의 JSON 문서의 형식이 올바른지 확인하세요. JSON에 쉼표 누락과 같은 오류가 있으면 규칙에서 읽을 수 없습니다.
+
**규칙 작업에 사용된 키 및 필드 이름 확인**
주제 규칙에 사용되는 필드 이름은 게시된 메시지의 JSON 메시지 페이로드에 있는 필드 이름과 일치해야 합니다.
콘솔에서 생성한 규칙을 열고 MQTT 클라이언트에서 사용된 규칙 작업 구성의 필드 이름을 확인합니다.
+
**규칙에서 사용 중인 역할 확인**
규칙 작업에는 원래 주제를 받고 새 주제를 게시할 수 있는 권한이 있어야 합니다.
메시지 데이터를 수신하고 DynamoDB 테이블을 업데이트하도록 규칙을 인증하는 정책은 사용된 주제에 따라 다릅니다. 규칙에 사용되는 주제 또는 DynamoDB 테이블 이름을 변경하는 경우 규칙 작업의 역할을 업데이트하여 해당 정책을 일치하도록 업데이트해야 합니다.
문제가 의심되는 경우 규칙 작업을 편집하고 새 역할을 만듭니다. 규칙 작업에 의해 생성된 새 역할에는 이러한 작업을 수행하는 데 필요한 권한이 부여됩니다.
## 4단계: 결과 및 다음 단계 검토
이 규칙을 사용하여 DynamoDB 테이블로 몇 개의 메시지를 전송한 후 이를 실험하여 자습서의 일부 측면을 변경하면 테이블에 기록된 데이터에 어떤 영향을 주는지 확인하세요. 다음은 시작하는 데 도움이 될 몇 가지 아이디어입니다.
+ 입력 메시지의 주제에서 *device\$1id*를 변경하고 데이터의 영향을 관찰합니다. 이 기능을 사용하여 여러 기상 센서의 수신 데이터를 시뮬레이션할 수 있습니다.
+ 규칙 쿼리 문에서 선택한 필드를 변경하고 데이터의 영향을 관찰합니다. 이 옵션을 사용하여 테이블에 저장된 데이터를 필터링할 수 있습니다.
+ 테이블에 추가된 각 행에 대해 MQTT 메시지를 전송하려면 재게시 규칙 작업을 추가합니다. 디버깅에 사용할 수 있습니다.
이 자습서를 완료했으면 [자습서: AWS Lambda 함수를 사용하여 알림 형식 지정](iot-lambda-rule.md) 섹션을 확인합니다.
# 자습서: AWS Lambda 함수를 사용하여 알림 형식 지정
이 자습서에서는 형식 지정 및 다른 AWS 서비스로 전송을 위해 AWS Lambda 작업에 MQTT 메시지 데이터를 전송하는 방법을 보여줍니다. 이 자습서에서 AWS Lambda 작업은 AWS SDK를 사용하여에 대한 자습서에서 생성한 Amazon SNS 주제로 형식이 지정된 메시지를 보냅니다[자습서: Amazon SNS 알림 전송](iot-sns-rule.md).
[자습서: Amazon SNS 알림 전송](iot-sns-rule.md) 수행 방법에 대한 자습서에서는 규칙의 쿼리 문에서 발생한 JSON 문서가 문자 메시지의 본문으로 전송되었습니다. 결과는 다음 예제와 같은 문자 메시지입니다.
```
{"device_id":"32","reported_temperature":38,"max_temperature":30}
```
이 자습서에서는 AWS Lambda 규칙 작업을 사용하여 규칙 쿼리 문의 데이터를 다음과 같은 친숙한 형식으로 포맷하는 AWS Lambda 함수를 호출합니다.
```
Device 32 reports a temperature of 38, which exceeds the limit of 30.
```
이 자습서에서 생성할 AWS Lambda 함수는 규칙 쿼리 문의 데이터를 사용하여 메시지 문자열의 형식을 지정하고 AWS SDK의 [SNS 게시](https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/sns.html#SNS.Client.publish) 함수를 호출하여 알림을 생성합니다.
**이 자습서에서 배울 내용**
+ AWS Lambda 함수를 생성하고 테스트하는 방법
+ AWS Lambda 함수에서 AWS SDK를 사용하여 Amazon SNS 알림을 게시하는 방법
+ 규칙 쿼리 문에서 간단한 SQL 쿼리 및 함수를 사용하는 방법
+ MQTT 클라이언트를 사용하여 AWS IoT 규칙을 테스트하는 방법
이 자습서는 완료하는 데 약 45분이 소요됩니다.
**Topics**
+ [1단계: 텍스트 메시지를 보내는 AWS Lambda 함수 생성](#iot-lambda-rule-create-lambda)
+ [2단계: AWS IoT 규칙 작업을 사용하여 AWS Lambda 규칙 생성](#iot-lambda-rule-create-rule)
+ [3단계: AWS IoT 규칙 및 AWS Lambda 규칙 작업 테스트](#iot-lambda-rule-test-rule)
+ [4단계: 결과 및 다음 단계 검토](#iot-lambda-rule-next-steps)
**이 자습서를 시작하기 전에 다음 사항을 확인해야 합니다.**
+
**[설정 AWS 계정](setting-up.md)**
이 자습서를 완료하려면 AWS 계정 및 AWS IoT 콘솔이 필요합니다.
+
**검토된 [MQTT 클라이언트를 사용하여 AWS IoT MQTT 메시지 보기](view-mqtt-messages.md)**
MQTT 클라이언트를 사용하여 주제를 구독하고 게시할 수 있는지 확인하세요. 이 절차에서는 MQTT 클라이언트를 사용하여 새 규칙을 테스트합니다.
+
**이 섹션의 다른 규칙 자습서를 완료했습니다.**
이 자습서에는 [자습서: Amazon SNS 알림 전송](iot-sns-rule.md) 수행 방법에 대한 자습서에서 생성한 SNS 알림 주제가 필요합니다. 또한 이 섹션의 다른 규칙 관련 자습서를 완료했다고 가정합니다.
+
**[AWS Lambda](https://docs.aws.amazon.com//lambda/latest/dg/welcome.html) 개요를 검토했습니다.**
AWS Lambda 이전에를 사용한 적이 없는 경우 [AWS Lambda](https://docs.aws.amazon.com//lambda/latest/dg/welcome.html) 및 [Lambda 시작하기를](https://docs.aws.amazon.com//lambda/latest/dg/getting-started.html) 검토하여 해당 용어와 개념을 알아봅니다.
## 1단계: 텍스트 메시지를 보내는 AWS Lambda 함수 생성
이 자습서의 AWS Lambda 함수는 규칙 쿼리 문의 결과를 수신하고 요소를 텍스트 문자열에 삽입한 다음 결과 문자열을 Amazon SNS에 알림의 메시지로 보냅니다.
규칙 작업을 사용하여 AWS IoT 알림을 보내는 방법에 대한 자습서[자습서: Amazon SNS 알림 전송](iot-sns-rule.md)와 달리이 자습서에서는 AWS SDK의 함수를 사용하여 Lambda 함수에서 알림을 보냅니다. 그러나 이 자습서에서 사용된 실제 Amazon SNS 알림 주제는 [자습서: Amazon SNS 알림 전송](iot-sns-rule.md) 수행 방법에 대한 자습서에서 사용한 것과 동일합니다.
**텍스트 메시지를 보내는 AWS Lambda 함수를 생성하려면**
1. 새 AWS Lambda 함수를 생성합니다.
1. [AWS Lambda 콘솔](https://console.aws.amazon.com//lambda/home)에서 **함수 생성**을 선택합니다.
1. **함수 생성(Create function)**에서 **블루프린트 사용(Use a blueprint)**을 선택합니다.
**hello-world-python** 블루프린트를 검색하여 선택한 다음 **구성**을 선택합니다.
1. **기본 정보(Basic information)**에서:
1. **Function name(함수 이름)**에 이 함수 이름(**format-high-temp-notification**)을 입력합니다.
1. **실행 역할**에서 ** AWS 정책 템플릿에서 새 역할 생성을** 선택합니다.
1. 역할 이름에 새 역할의 이름(**format-high-temp-notification-role**)을 입력합니다.
1. **정책 템플릿 - *선택 사항***에서 **Amazon SNS 게시 정책**을 검색하고 선택합니다.
1. **함수 생성**을 선택합니다.
1. 블루프린트 코드를 수정하여 Amazon SNS 알림의 형식을 지정하고 전송합니다.
1. 함수를 생성한 후에는 **format-high-temp-notification** 세부 정보 페이지를 참조하세요. 그렇지 않은 경우 [Lambda **함수**](https://console.aws.amazon.com//lambda/home#/functions) 페이지에서 엽니다.
1. **format-high-temp-notification** 세부 정보 페이지에서 **구성(Configuration)** 탭을 선택하고 **함수 코드(Function code)** 패널로 스크롤합니다.
1. **함수 코드(Function code)** 창의 **환경(Environment)** 창에서 Python 파일(`lambda_function.py`)을 선택합니다.
1. **함수 코드(Function code)** 창에서 블루프린트의 원본 프로그램 코드를 모두 삭제하고 이 코드로 교체합니다.다.
```
import boto3
#
# expects event parameter to contain:
# {
# "device_id": "32",
# "reported_temperature": 38,
# "max_temperature": 30,
# "notify_topic_arn": "arn:aws:sns:us-east-1:57EXAMPLE833:high_temp_notice"
# }
#
# sends a plain text string to be used in a text message
#
# "Device {0} reports a temperature of {1}, which exceeds the limit of {2}."
#
# where:
# {0} is the device_id value
# {1} is the reported_temperature value
# {2} is the max_temperature value
#
def lambda_handler(event, context):
# Create an SNS client to send notification
sns = boto3.client('sns')
# Format text message from data
message_text = "Device {0} reports a temperature of {1}, which exceeds the limit of {2}.".format(
str(event['device_id']),
str(event['reported_temperature']),
str(event['max_temperature'])
)
# Publish the formatted message
response = sns.publish(
TopicArn = event['notify_topic_arn'],
Message = message_text
)
return response
```
1. **배포(Deploy)**를 선택합니다.
1. 새 창에서 [자습서: Amazon SNS 알림 전송](iot-sns-rule.md) 수행 방법에 대한 자습서에서 Amazon SNS 주제의 Amazon 리소스 이름(ARN)을 조회합니다.
1. 새 창에서 [Amazon SNS 콘솔의 주제 페이지](https://console.aws.amazon.com//sns/v3/home#/topics)를 엽니다.
1. **주제** 페이지에서 Amazon SNS 주제 목록에서 **high\$1temp\$1notice** 알림 주제를 찾습니다.
1. 다음 단계에서 사용할 **high\$1temp\$1notice** 알림 주제의 **ARN**을 찾습니다.
1. Lambda 함수에 대한 테스트 케이스 생성
1. 콘솔의 [Lambda **함수**](https://console.aws.amazon.com//lambda/home#/functions) 페이지에서 **format-high-temp-notification** 세부 정보 페이지 오른쪽 상단 모서리에 있는 **테스트 이벤트 선택(Select a test event)**(비활성화된 것처럼 보이더라도)을 선택한 다음 **테스트 이벤트 구성(Configure test events)**을 선택합니다.
1. **테스트 이벤트 구성(Configure test event)**에서 **새 테스트 이벤트 구성(Create new test event)**을 선택합니다.
1. **이벤트 이름**에 **SampleRuleOutput**을 입력합니다.
1. JSON 편집기에서 **이벤트 이름** 아래에 이 샘플 JSON 문서를 붙여 넣습니다. 다음은 AWS IoT 규칙이 Lambda 함수로 전송할 항목의 예입니다.
```
{
"device_id": "32",
"reported_temperature": 38,
"max_temperature": 30,
"notify_topic_arn": "arn:aws:sns:us-east-1:57EXAMPLE833:high_temp_notice"
}
```
1. **high\$1temp\$1notice** 알림 주제의 **ARN**이 있는 창을 참조하여 ARN 값을 복사합니다.
1. JSON 편집기의 `notify_topic_arn` 값을 알림 주제의 ARN으로 바꿉니다.
AWS IoT 규칙을 생성할 때 이 ARN 값을 다시 사용할 수 있도록 이 창을 열어 두세요.
1. **생성(Create)**을 선택합니다.
1. 샘플 데이터로 함수를 테스트합니다.
1. **format-high-temp-notification** 세부 정보 페이지의 오른쪽 상단 모서리에서 **SampleRuleOutput**이 **테스트(Test)** 버튼 옆에 나타나는지 확인합니다. 그렇지 않은 경우 사용 가능한 테스트 이벤트 목록에서 선택합니다.
1. 함수에 샘플 규칙 출력 메시지를 전송하려면 **테스트(Test)**를 선택합니다.
함수와 알림이 모두 작동하면 알림을 구독한 휴대 전화에서 문자 메시지를 받습니다.
휴대 전화에서 문자 메시지를 받지 못한 경우 작업 결과를 확인하세요. **함수 코드** 패널의 **실행 결과** 탭에서 응답을 검토하여 발생한 오류를 찾습니다. 함수가 휴대폰으로 알림을 전송할 때까지 다음 단계로 이행하지 마세요.
## 2단계: AWS IoT 규칙 작업을 사용하여 AWS Lambda 규칙 생성
이 단계에서는 규칙 쿼리 문을 사용하여 가상 기상 센서 디바이스의 데이터 형식을 Lambda 함수로 전송하여 문자 메시지를 형식 지정하고 전송합니다.
기상 디바이스에서 받은 샘플 메시지 페이로드는 다음과 같습니다.
```
{
"temperature": 28,
"humidity": 80,
"barometer": 1013,
"wind": {
"velocity": 22,
"bearing": 255
}
}
```
이 규칙에서는 규칙 쿼리 문을 사용하여 다음과 같은 Lambda 함수에 대한 메시지 페이로드를 만듭니다.
```
{
"device_id": "32",
"reported_temperature": 38,
"max_temperature": 30,
"notify_topic_arn": "arn:aws:sns:us-east-1:57EXAMPLE833:high_temp_notice"
}
```
여기에는 Lambda 함수가 올바른 문자 메시지로 형식을 지정하고 전송하는 데 필요한 모든 정보가 들어 있습니다.
**Lambda 함수를 호출하는 AWS IoT 규칙을 생성하려면**
1. [AWS IoT 콘솔의 **규칙** 허브를](https://console.aws.amazon.com//iot/home#/rulehub) 엽니다.
1. **규칙**에서 새 규칙 생성을 시작하려면 **생성**을 선택합니다.
1. **규칙 생성**의 상단 부분에서:
1. **이름**에 규칙 이름 **wx\$1friendly\$1text**를 입력합니다.
규칙 이름은 AWS 계정 및 리전 내에서 고유해야 하며 공백을 가질 수 없습니다. 이 이름에 밑줄 문자를 사용하여 규칙 이름의 두 단어를 구분했습니다.
1. **설명**에서 규칙을 설명합니다.
의미 있는 설명을 사용하면 이 규칙이 수행하는 작업과 규칙을 만든 이유를 쉽게 기억할 수 있습니다. 설명은 필요한 만큼 길어질 수 있으므로 가능한 한 자세하게 설명하세요.
1. **규칙 생성**의 **규칙 쿼리 문**에서:
1. **SQL 버전 사용**에서 **2016-03-23**을(를) 선택합니다.
1. **규칙 쿼리 문** 편집 상자에 쿼리 문을 입력합니다.
```
SELECT
cast(topic(2) AS DECIMAL) as device_id,
temperature as reported_temperature,
30 as max_temperature,
'arn:aws:sns:us-east-1:57EXAMPLE833:high_temp_notice' as notify_topic_arn
FROM 'device/+/data' WHERE temperature > 30
```
이 문은 다음을 수행합니다.
+ `device/+/data` 주제 필터와 일치하고 `temperature` 값이 30보다 큰 주제가 있는 MQTT 메시지를 수신 대기합니다.
+ 주제 문자열에서 두 번째 요소를 선택하고 10진수로 변환한 다음 `device_id` 필드에 할당합니다.
+ 메시지 페이로드에서 `temperature` 값 필드를 선택하여 `reported_temperature` 필드에 할당합니다.
+ 한계 값을 나타내는 상수 값 `30`을 생성하고 `max_temperature` 필드에 할당합니다.
+ `notify_topic_arn` 필드에 대한 상수 값을 만듭니다.
1. **high\$1temp\$1notice** 알림 주제의 **ARN**이 있는 창을 참조하여 ARN 값을 복사합니다.
1. 규칙 쿼리 문 편집기의 ARN 값(*arn:aws:sns:us-east-1:57EXAMPLE833:high\$1temp\$1notice*)을 알림 주제의 ARN으로 바꿉니다.
1. **하나 이상의 작업 설정**에서:
1. 이 규칙에 대한 규칙 작업 목록을 열려면 **작업 추가**를 선택합니다.
1. **작업 선택(Select an action)**에서 **Lambda 함수로 메시지 전송하기(Send a message to a Lambda function)**를 선택합니다.
1. 작업 목록 하단에서 선택한 작업의 구성 페이지를 열려면 **구성 작업**을 선택합니다.
1. **구성 작업**에서:
1. **함수 이름**에서 **선택(Select)**을 클릭합니다.
1. **format-high-temp-notification**을 선택합니다.
1. **작업 구성(Configure action)** 하단에서 **작업 추가(Add action)**를 선택합니다.
1. 규칙을 생성하려면 **규칙 생성(Create a rule)** 하단에서 **규칙 생성(Create rule)**을 선택합니다.
## 3단계: AWS IoT 규칙 및 AWS Lambda 규칙 작업 테스트
새 규칙을 테스트하려면 MQTT 클라이언트를 사용하여 이 규칙에서 사용하는 MQTT 메시지를 게시하고 구독합니다.
새 창에서 [AWS IoT 콘솔의 MQTT 클라이언트](https://console.aws.amazon.com//iot/home#/test)를 엽니다. 이제 MQTT 클라이언트의 구성을 그대로 유지하면서 규칙을 편집할 수 있습니다. MQTT 클라이언트를 떠나 콘솔의 다른 페이지로 이동하면 구독 또는 메시지 로그가 손실됩니다.
**MQTT 클라이언트를 사용하여 규칙을 테스트하려면**
1. [AWS IoT 콘솔의 MQTT 클라이언트](https://console.aws.amazon.com//iot/home#/test)에서 입력 주제(이 경우 `device/+/data`)를 구독합니다.
1. MQTT 클라이언트에서 **구독** 아래에서 **주제 구독**을 선택합니다.
1. **구독 주제**에 입력 주제 필터 **device/\$1/data**의 주제를 입력합니다.
1. 나머지 필드는 기본 설정을 유지합니다.
1. **주제 구독**을 선택합니다.
**구독** 열의 **주제 게시** 아래에 **device/\$1/data**가 나타납니다.
1. 특정 디바이스 ID **device/32/data**로 입력 주제에 메시지를 게시합니다. 와일드카드 문자가 포함된 MQTT 항목에는 게시할 수 없습니다.
1. MQTT 클라이언트의 **구독** 아래에서 **주제 게시**를 선택합니다.
1. **게시** 필드에 입력 주제 이름 **device/32/data**를 입력합니다.
1. 여기에 표시된 샘플 데이터를 복사하고 주제 이름 아래의 편집 상자에 샘플 데이터를 붙여 넣습니다.
```
{
"temperature": 38,
"humidity": 80,
"barometer": 1013,
"wind": {
"velocity": 22,
"bearing": 255
}
}
```
1. MQTT 메시지를 게시하려면 **주제에 게시(Publish to topic)**를 선택합니다.
1. 문자 메시지가 전송되었는지 확인합니다.
1. MQTT 클라이언트의 **구독** 아래에서 이전에 구독한 주제 옆에 녹색 점이 있습니다.
녹색 점은 마지막으로 메시지를 보았을 때 하나 이상의 새 메시지가 수신되었음을 나타냅니다.
1. **구독** 아래에서 **device/\$1/data**를 선택하여 메시지 페이로드가 방금 게시한 것과 일치하고 다음과 같이 표시되는지 확인하세요.
```
{
"temperature": 38,
"humidity": 80,
"barometer": 1013,
"wind": {
"velocity": 22,
"bearing": 255
}
}
```
1. SNS 주제를 구독하는 데 사용한 전화를 확인하고 메시지 페이로드의 내용이 다음과 같이 표시되는지 확인합니다.
```
Device 32 reports a temperature of 38, which exceeds the limit of 30.
```
메시지 주제에서 주제 ID 요소를 변경하는 경우 메시지 주제의 해당 요소에 숫자만 포함된 경우에만 `topic(2)` 값을 숫자 값으로 캐스팅할 수 있다는 점을 기억하세요.
1. 온도가 한계를 초과하지 않는 MQTT 메시지를 전송해보세요.
1. MQTT 클라이언트의 **구독** 아래에서 **주제 게시**를 선택합니다.
1. **게시** 필드에 입력 주제 이름 **device/33/data**를 입력합니다.
1. 여기에 표시된 샘플 데이터를 복사하고 주제 이름 아래의 편집 상자에 샘플 데이터를 붙여 넣습니다.
```
{
"temperature": 28,
"humidity": 80,
"barometer": 1013,
"wind": {
"velocity": 22,
"bearing": 255
}
}
```
1. MQTT 메시지를 전송하려면 **주제 게시**를 선택합니다.
**device/\$1/data** 구독에서 전송한 메시지가 표시되어야 하지만 온도 값이 규칙 쿼리 문에서 최대 온도보다 낮기 때문에 문자 메시지를 받지 않아야 합니다.
올바른 동작이 표시되지 않으면 문제 해결 팁을 확인합니다.
### AWS Lambda 규칙 및 알림 문제 해결
예상한 결과가 표시되지 않는 경우를 대비하여 확인해야 할 몇 가지 사항이 있습니다.
+
**오류 배너가 있음**
입력 메시지를 게시할 때 오류가 나타나면 먼저 해당 오류를 수정하세요. 다음 단계는 해당 오류를 수정하는 데 도움이 될 수 있습니다.
+
**MQTT 클라이언트에서 입력 메시지가 표시되지 않음**
`device/+/data` 주제 필터를 구독한 경우 입력 메시지를 `device/32/data` 주제에 게시할 때마다 절차에 설명된 대로 해당 메시지가 MQTT 클라이언트에 나타나야 합니다.
**확인해야 할 사항**
+
**구독한 주제 필터 확인**
절차에 설명된 대로 입력 메시지 주제를 구독한 경우 게시할 때마다 입력 메시지의 복사본이 표시되어야 합니다.
메시지가 표시되지 않으면 구독한 주제 이름을 확인하고 게시한 주제와 비교합니다. 주제 이름은 대소문자를 구분하며 구독한 주제는 메시지 페이로드를 게시한 주제와 동일해야 합니다.
+
**메시지 게시 함수 확인**
MQTT 클라이언트의 **구독**에서 **device/\$1/data**를 선택하고 게시 메시지의 주제를 확인한 다음 **주제에 게시**를 선택합니다. 주제 아래의 편집 상자에서 메시지 페이로드가 메시지 목록에 나타납니다.
+
**SMS 메시지가 수신되지 않음**
규칙이 작동하려면 메시지를 수신하고 SNS 알림을 전송할 수 있도록 권한을 부여하는 올바른 정책이 있어야 하며 메시지를 수신해야 합니다.
**확인해야 할 사항**
+
**MQTT 클라이언트 AWS 리전 의 및 생성한 규칙을 확인합니다.**
MQTT 클라이언트를 실행 중인 콘솔은 생성한 규칙과 동일한 AWS 리전에 있어야 합니다.
+
**메시지 페이로드의 온도 값이 테스트 임계값을 초과하는지 확인**
규칙 쿼리 문에 정의된 대로 온도 값이 30보다 작거나 같으면 규칙은 해당 작업을 수행하지 않습니다.
+
**규칙 쿼리 문의 입력 메시지 주제 확인**
규칙이 작동하려면 규칙 쿼리 문의 FROM 절에 있는 주제 필터와 일치하는 주제 이름이 포함된 메시지를 받아야 합니다.
MQTT 클라이언트에 있는 주제의 철자와 함께 규칙 쿼리 문에서 주제 필터의 철자를 확인하세요. 주제 이름은 대/소문자를 구분하며 메시지의 주제는 규칙 쿼리 문의 주제 필터와 일치해야 합니다.
+
**입력 메시지 페이로드의 내용 확인**
규칙이 작동하려면 SELECT 문에서 선언된 메시지 페이로드에서 데이터 필드를 찾아야 합니다.
MQTT 클라이언트에 있는 메시지 페이로드의 철자와 함께 규칙 쿼리 명령문의 `temperature` 필드 철자를 확인하세요. 필드 이름은 대소문자를 구분하며 규칙 쿼리 문의 `temperature` 필드는 메시지 페이로드의 `temperature` 필드와 동일해야 합니다.
메시지 페이로드의 JSON 문서의 형식이 올바른지 확인하세요. JSON에 쉼표 누락과 같은 오류가 있으면 규칙에서 읽을 수 없습니다.
+
**Amazon SNS 알림 확인**
[1단계: SMS 문자 메시지를 전송하는 Amazon SNS 주제 생성](iot-sns-rule.md#iot-sns-rule-create-sns-topic)에서 Amazon SNS 알림을 테스트하고 알림을 테스트하여 알림이 작동하는지 확인하는 방법을 설명하는 3단계를 참조하세요.
+
**Lambda 함수 확인**
[1단계: 텍스트 메시지를 보내는 AWS Lambda 함수 생성](#iot-lambda-rule-create-lambda)에서 테스트 데이터를 사용하여 Lambda 함수를 테스트하고 Lambda 함수를 테스트하는 방법을 설명하는 5단계를 참조하세요.
+
**규칙에서 사용 중인 역할 확인**
규칙 작업에는 원래 주제를 받고 새 주제를 게시할 수 있는 권한이 있어야 합니다.
메시지 데이터를 수신하고 다시 게시하도록 규칙을 인증하는 정책은 사용된 주제에 따라 다릅니다. 메시지 데이터를 다시 게시하는 데 사용되는 주제를 변경하는 경우 규칙 작업의 역할을 업데이트하여 현재 주제와 일치하도록 정책을 업데이트해야 합니다.
문제가 의심되는 경우 규칙 재게시 작업을 편집하고 새 역할을 만듭니다. 규칙 작업에 의해 생성된 새 역할에는 이러한 작업을 수행하는 데 필요한 권한이 부여됩니다.
## 4단계: 결과 및 다음 단계 검토
**이 자습서에서는:**
+ 사용자 지정 메시지 페이로드를 사용한 Amazon SNS 알림을 보낸 Lambda 함수를 호출하는 AWS IoT 규칙을 생성했습니다.
+ 규칙 쿼리 문에서 간단한 SQL 쿼리와 함수를 사용하여 Lambda 함수에 대한 새 메시지 페이로드를 만들었습니다.
+ MQTT 클라이언트를 사용하여 AWS IoT 규칙을 테스트했습니다.
**다음 단계**
이 규칙을 사용하여 몇 가지 문자 메시지를 전송한 후 이 규칙을 실험하여 자습서의 일부 측면을 변경하면 메시지가 전송되는 시기에 영향을 받는지 확인하세요. 다음은 시작하는 데 도움이 될 몇 가지 아이디어입니다.
+ 입력 메시지의 주제에서 *device\$1id*를 변경하고 문자 메시지 내용의 영향을 관찰합니다.
+ 규칙 쿼리 문에서 선택한 필드를 변경하고, 새 메시지에서 사용하도록 Lambda 함수를 업데이트하고, 문자 메시지 내용의 영향을 관찰합니다.
+ 최대 온도 대신 최소 온도에 대한 테스트 규칙 쿼리 문에서 테스트를 변경합니다. Lambda 함수를 업데이트하여 새 메시지 형식을 지정하고 `max_temperature` 이름을 변경하는 것을 잊지 마세요.
+ AWS IoT 규칙을 개발하고 사용하는 동안 발생할 수 있는 오류를 찾는 방법에 대한 자세한 내용은 섹션을 참조하세요[모니터링 AWS IoT](monitoring_overview.md).