기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.
자습서: AWS Lambda 함수를 사용하여 알림 형식 지정
이 자습서에서는 형식 지정 및 다른 AWS 서비스로 전송하기 위해 AWS Lambda 작업으로 MQTT 메시지 데이터를 전송하는 방법을 보여줍니다. 이 자습서에서 AWS Lambda 작업은 AWS SDK를 사용하여 에 대한 방법에 대해 자습서에서 생성한 Amazon SNS 주제로 형식 지정된 메시지를 보냅니다자습서: Amazon SNS 알림 전송.
에 대한 자습서에서는 규칙자습서: Amazon SNS 알림 전송의 쿼리 문에서 가져온 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 함수는 규칙 쿼리 문에서 데이터를 사용하여 메시지 문자열의 형식을 지정하고 SNS 의 게시
이 자습서에서 배울 내용
-
AWS Lambda 함수를 생성하고 테스트하는 방법
-
AWS Lambda 함수에서 AWS SDK를 사용하여 Amazon SNS 알림을 게시하는 방법
-
규칙 SQL 쿼리 문에서 간단한 쿼리 및 함수를 사용하는 방법
-
MQTT 클라이언트를 사용하여 AWS IoT 규칙을 테스트하는 방법
이 자습서는 완료하는 데 약 45분이 소요됩니다.
이 자습서에서 배울 내용은 다음과 같습니다.
이 자습서를 시작하기 전에 다음 사항을 확인해야 합니다.
-
설정 AWS 계정
이 자습서를 완료하려면 AWS 계정 및 AWS IoT 콘솔이 필요합니다.
-
검토된 클라이언트를 AWS IoT MQTT 사용하여 MQTT 메시지 보기
MQTT 클라이언트를 사용하여 주제를 구독하고 게시할 수 있는지 확인합니다. 이 절차에서는 MQTT 클라이언트를 사용하여 새 규칙을 테스트합니다.
-
이 섹션의 다른 규칙 자습서를 완료했습니다.
이 자습서에는 에 대한 자습서에서 생성한 SNS 알림 주제가 필요합니다자습서: Amazon SNS 알림 전송. 또한 이 섹션의 다른 규칙 관련 자습서를 완료했다고 가정합니다.
-
AWS Lambda 개요를 검토했습니다.
AWS Lambda 이전에 사용한 적이 없는 경우 AWS Lambda 및 Lambda 시작하기를 검토하여 해당 용어와 개념을 알아봅니다.
1단계: 텍스트 메시지를 보내는 AWS Lambda 함수 생성
이 자습서의 AWS Lambda 함수는 규칙 쿼리 문 결과를 수신하고 요소를 텍스트 문자열에 삽입한 다음 결과 문자열을 알림의 메시지SNS로 Amazon에 보냅니다.
규칙 작업을 사용하여 AWS IoT 알림을 보내는 방법에 대한 자습서자습서: Amazon SNS 알림 전송와 달리 이 자습서는 의 함수를 사용하여 Lambda 함수에서 알림을 보냅니다 AWS SDK. 그러나 이 자습서에서 사용되는 실제 Amazon SNS 알림 주제는 에 대한 자습서에서 사용한 것과 동일합니다자습서: Amazon SNS 알림 전송.
텍스트 메시지를 보내는 AWS Lambda 함수를 생성하려면
-
새 AWS Lambda 함수를 생성합니다.
-
AWS Lambda 콘솔
에서 함수 생성을 선택합니다. -
함수 생성(Create function)에서 블루프린트 사용(Use a blueprint)을 선택합니다.
hello-world-python
블루프린트를 검색하여 선택한 다음 구성을 선택합니다. -
기본 정보(Basic information)에서:
-
Function name(함수 이름)에 이 함수 이름(
format-high-temp-notification
)을 입력합니다. -
실행 역할 에서 AWS 정책 템플릿 에서 새 역할 생성을 선택합니다.
-
역할 이름에 새 역할의 이름(
format-high-temp-notification-role
)을 입력합니다. -
정책 템플릿 - 선택 사항 에서 Amazon 게시 정책 SNS 을 검색하고 선택합니다.
-
함수 생성(Create function)을 선택합니다.
-
-
-
블루프린트 코드를 수정하여 형식을 지정하고 Amazon SNS 알림을 전송합니다.
-
함수를 생성한 후에는 format-high-temp-notification 세부 정보 페이지가 표시됩니다. 그렇지 않은 경우 Lambda 함수
페이지에서 엽니다. -
format-high-temp-notification 세부 정보 페이지에서 구성 탭을 선택하고 함수 코드 패널로 스크롤합니다.
-
함수 코드(Function code) 창의 환경(Environment) 창에서 Python 파일(
lambda_function.py
)을 선택합니다. -
함수 코드(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 -
배포(Deploy)를 선택합니다.
-
-
새 창에서 에 대한 자습서에서 Amazon SNS 주제의 Amazon 리소스 이름(ARN)을 조회합니다자습서: Amazon SNS 알림 전송.
-
새 창에서 Amazon SNS 콘솔 의 주제 페이지를
엽니다. -
주제 페이지의 Amazon 주제 목록에서 high_temp_notice 알림 SNS 주제를 찾습니다.
-
다음 단계에서 사용할 high_temp_notice 알림 주제ARN의 를 찾습니다.
-
-
Lambda 함수에 대한 테스트 케이스 생성
-
콘솔의 Lambda 함수
페이지의 format-high-temp-notification 세부 정보 페이지에서 페이지 오른쪽 상단 모서리에 있는 테스트 이벤트 선택을 선택한 다음(비활성화된 것처럼 보이더라도) 테스트 이벤트 구성을 선택합니다. -
테스트 이벤트 구성(Configure test event)에서 새 테스트 이벤트 구성(Create new test event)을 선택합니다.
-
이벤트 이름에
SampleRuleOutput
을 입력합니다. -
이벤트 이름 아래의 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
" } -
high_temp_notice 알림 주제ARN의 가 있는 창을 참조하고 ARN 값을 복사합니다.
-
JSON 편집기의
notify_topic_arn
값을 알림 주제의 로 바꿉ARN니다.AWS IoT 규칙을 생성할 때 이 ARN 값을 다시 사용할 수 있도록 이 창을 열어 둡니다.
-
생성(Create)을 선택합니다.
-
-
샘플 데이터로 함수를 테스트합니다.
-
format-high-temp-notification 세부 정보 페이지의 오른쪽 상단 모서리에서 테스트 버튼 옆에 가 SampleRuleOutput 표시되는지 확인합니다. 그렇지 않은 경우 사용 가능한 테스트 이벤트 목록에서 선택합니다.
-
함수에 샘플 규칙 출력 메시지를 전송하려면 테스트(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 규칙을 생성하려면
-
AWS IoT 콘솔 의 규칙 허브를
엽니다. -
규칙에서 새 규칙 생성을 시작하려면 생성을 선택합니다.
-
규칙 생성의 상단 부분에서:
-
이름에 규칙 이름
wx_friendly_text
를 입력합니다.규칙 이름은 AWS 계정 및 리전 내에서 고유해야 하며 공백이 없어야 합니다. 이 이름에 밑줄 문자를 사용하여 규칙 이름의 두 단어를 구분했습니다.
-
설명에서 규칙을 설명합니다.
의미 있는 설명을 사용하면 이 규칙이 수행하는 작업과 규칙을 만든 이유를 쉽게 기억할 수 있습니다. 설명은 필요한 만큼 길어질 수 있으므로 가능한 한 자세하게 설명하세요.
-
-
규칙 생성의 규칙 쿼리 문에서:
-
SQL 버전 사용에서 을 선택합니다
2016-03-23
. -
규칙 쿼리 문 편집 상자에 쿼리 문을 입력합니다.
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이 문은 다음을 수행합니다.
-
주제 필터와 일치하고
temperature
값이 30보다 큰device/+/data
주제가 있는 MQTT 메시지를 수신합니다. -
주제 문자열에서 두 번째 요소를 선택하고 10진수로 변환한 다음
device_id
필드에 할당합니다. -
메시지 페이로드에서
temperature
값 필드를 선택하여reported_temperature
필드에 할당합니다. -
한계 값을 나타내는 상수 값
30
을 생성하고max_temperature
필드에 할당합니다. -
notify_topic_arn
필드에 대한 상수 값을 만듭니다.
-
-
high_temp_notice 알림 주제ARN의 가 있는 창을 참조하고 ARN 값을 복사합니다.
-
ARN 값 바꾸기(
arn:aws:sns:us-east-1:57EXAMPLE833:high_temp_notice
)를 알림 주제ARN의 와 함께 규칙 쿼리 문 편집기에 추가합니다.
-
-
하나 이상의 작업 설정에서:
-
이 규칙에 대한 규칙 작업 목록을 열려면 작업 추가를 선택합니다.
-
작업 선택(Select an action)에서 Lambda 함수로 메시지 전송하기(Send a message to a Lambda function)를 선택합니다.
-
작업 목록 하단에서 선택한 작업의 구성 페이지를 열려면 구성 작업을 선택합니다.
-
-
구성 작업에서:
-
함수 이름에서 선택(Select)을 클릭합니다.
-
를 선택합니다format-high-temp-notification.
-
작업 구성(Configure action) 하단에서 작업 추가(Add action)를 선택합니다.
-
규칙을 생성하려면 규칙 생성(Create a rule) 하단에서 규칙 생성(Create rule)을 선택합니다.
-
3단계: AWS IoT 규칙 및 AWS Lambda 규칙 작업 테스트
새 규칙을 테스트하려면 MQTT 클라이언트를 사용하여 이 규칙에서 사용하는 MQTT 메시지를 게시하고 구독해야 합니다.
새 창에서 MQTT 콘솔에서 클라이언트 AWS IoT
MQTT 클라이언트를 사용하여 규칙을 테스트하려면
-
MQTT 콘솔 의 AWS IoT 클라이언트
에서 입력 주제를 구독합니다. 이 경우 입니다 device/+/data
.-
MQTT 클라이언트의 구독에서 주제 구독을 선택합니다.
-
구독 주제에 입력 주제 필터
device/+/data
의 주제를 입력합니다. -
나머지 필드는 기본 설정을 유지합니다.
-
주제 구독을 선택합니다.
구독 열의 주제 게시 아래에
device/+/data
가 나타납니다.
-
-
특정 디바이스 ID
device/32/data
로 입력 주제에 메시지를 게시합니다. 와일드카드 문자가 포함된 MQTT 주제에는 게시할 수 없습니다.-
MQTT 클라이언트의 구독 에서 주제에 게시 를 선택합니다.
-
게시 필드에 입력 주제 이름
device/32/data
를 입력합니다. -
여기에 표시된 샘플 데이터를 복사하고 주제 이름 아래의 편집 상자에 샘플 데이터를 붙여 넣습니다.
{ "temperature": 38, "humidity": 80, "barometer": 1013, "wind": { "velocity": 22, "bearing": 255 } }
-
MQTT 메시지를 게시하려면 주제에 게시를 선택합니다.
-
-
문자 메시지가 전송되었는지 확인합니다.
-
MQTT 클라이언트의 구독 아래에는 이전에 구독한 주제 옆에 녹색 점이 있습니다.
녹색 점은 마지막으로 메시지를 보았을 때 하나 이상의 새 메시지가 수신되었음을 나타냅니다.
-
구독 아래에서 device/+/data를 선택하여 메시지 페이로드가 방금 게시한 것과 일치하고 다음과 같이 표시되는지 확인하세요.
{ "temperature": 38, "humidity": 80, "barometer": 1013, "wind": { "velocity": 22, "bearing": 255 } }
-
SNS 주제를 구독하는 데 사용한 휴대폰을 확인하고 메시지 페이로드의 내용이 다음과 같은지 확인합니다.
Device 32 reports a temperature of 38, which exceeds the limit of 30.
메시지 주제에서 주제 ID 요소를 변경하는 경우 메시지 주제의 해당 요소에 숫자만 포함된 경우에만
topic(2)
값을 숫자 값으로 캐스팅할 수 있다는 점을 기억하세요.
-
-
온도가 한도를 초과하지 않는 MQTT 메시지를 보내 보세요.
-
MQTT 클라이언트의 구독에서 주제에 게시를 선택합니다.
-
게시 필드에 입력 주제 이름
device/33/data
를 입력합니다. -
여기에 표시된 샘플 데이터를 복사하고 주제 이름 아래의 편집 상자에 샘플 데이터를 붙여 넣습니다.
{ "temperature": 28, "humidity": 80, "barometer": 1013, "wind": { "velocity": 22, "bearing": 255 } }
-
MQTT 메시지를 보내려면 주제에 게시를 선택합니다.
device/+/data
구독에서 전송한 메시지가 표시되어야 하지만 온도 값이 규칙 쿼리 문에서 최대 온도보다 낮기 때문에 문자 메시지를 받지 않아야 합니다.올바른 동작이 표시되지 않으면 문제 해결 팁을 확인합니다.
-
AWS Lambda 규칙 및 알림 문제 해결
예상한 결과가 표시되지 않는 경우를 대비하여 확인해야 할 몇 가지 사항이 있습니다.
-
오류 배너가 있음
입력 메시지를 게시할 때 오류가 나타나면 먼저 해당 오류를 수정하세요. 다음 단계는 해당 오류를 수정하는 데 도움이 될 수 있습니다.
-
MQTT 클라이언트에 입력 메시지가 표시되지 않습니다.
입력 메시지를
device/32/data
주제에 게시할 때마다 절차에 설명된 대로device/+/data
주제 필터를 구독한 MQTT 경우 클라이언트에 해당 메시지가 나타나야 합니다.확인해야 할 사항
-
구독한 주제 필터 확인
절차에 설명된 대로 입력 메시지 주제를 구독한 경우 게시할 때마다 입력 메시지의 복사본이 표시되어야 합니다.
메시지가 표시되지 않으면 구독한 주제 이름을 확인하고 게시한 주제와 비교합니다. 주제 이름은 대소문자를 구분하며 구독한 주제는 메시지 페이로드를 게시한 주제와 동일해야 합니다.
-
메시지 게시 함수 확인
MQTT 클라이언트의 구독에서 디바이스/+/데이터 를 선택하고 게시 메시지의 주제를 확인한 다음 주제에 게시를 선택합니다. 주제 아래의 편집 상자에서 메시지 페이로드가 메시지 목록에 나타납니다.
-
-
SMS 메시지를 받지 못했습니다.
규칙이 작동하려면 메시지를 수신하고 SNS 알림을 보낼 수 있는 권한을 부여하는 올바른 정책이 있어야 하며 메시지를 수신해야 합니다.
확인해야 할 사항
-
MQTT 클라이언트 AWS 리전 의 와 생성한 규칙을 확인합니다.
MQTT 클라이언트를 실행하는 콘솔은 생성한 규칙과 동일한 AWS 리전에 있어야 합니다.
-
메시지 페이로드의 온도 값이 테스트 임계값을 초과하는지 확인
규칙 쿼리 문에 정의된 대로 온도 값이 30보다 작거나 같으면 규칙은 해당 작업을 수행하지 않습니다.
-
규칙 쿼리 문의 입력 메시지 주제 확인
규칙이 작동하려면 규칙 쿼리 문 FROM 절의 주제 필터와 일치하는 주제 이름이 포함된 메시지를 수신해야 합니다.
규칙 쿼리 문에서 주제 필터의 철자를 MQTT 클라이언트에서 주제의 철자를 확인합니다. 주제 이름은 대/소문자를 구분하며 메시지의 주제는 규칙 쿼리 문의 주제 필터와 일치해야 합니다.
-
입력 메시지 페이로드의 내용 확인
규칙이 작동하려면 SELECT 명령문에 선언된 메시지 페이로드에서 데이터 필드를 찾아야 합니다.
규칙 쿼리 문에서
temperature
필드의 철자를 MQTT 클라이언트의 메시지 페이로드의 철자와 함께 확인합니다. 필드 이름은 대소문자를 구분하며 규칙 쿼리 문의temperature
필드는 메시지 페이로드의temperature
필드와 동일해야 합니다.메시지 페이로드의 JSON 문서 형식이 올바른지 확인합니다. JSON 에 누락된 쉼표와 같은 오류가 있는 경우 규칙은 이를 읽을 수 없습니다.
-
Amazon SNS 알림 확인
에서 Amazon SNS 알림을 테스트하고 알림을 테스트하여 알림이 작동하는지 확인하는 방법을 설명하는 3단계를 1단계: SMS 텍스트 메시지를 보내는 Amazon SNS 주제 생성참조하세요.
-
Lambda 함수 확인
1단계: 텍스트 메시지를 보내는 AWS Lambda 함수 생성에서 테스트 데이터를 사용하여 Lambda 함수를 테스트하고 Lambda 함수를 테스트하는 방법을 설명하는 5단계를 참조하세요.
-
규칙에서 사용 중인 역할 확인
규칙 작업에는 원래 주제를 받고 새 주제를 게시할 수 있는 권한이 있어야 합니다.
메시지 데이터를 수신하고 다시 게시하도록 규칙을 인증하는 정책은 사용된 주제에 따라 다릅니다. 메시지 데이터를 다시 게시하는 데 사용되는 주제를 변경하는 경우 규칙 작업의 역할을 업데이트하여 현재 주제와 일치하도록 정책을 업데이트해야 합니다.
문제가 의심되는 경우 규칙 재게시 작업을 편집하고 새 역할을 만듭니다. 규칙 작업에 의해 생성된 새 역할에는 이러한 작업을 수행하는 데 필요한 권한이 부여됩니다.
-
4단계: 결과 및 다음 단계 검토
이 자습서에서는:
-
사용자 지정 메시지 페이로드를 사용한 Amazon SNS 알림을 전송한 Lambda 함수를 호출하는 AWS IoT 규칙을 생성했습니다.
-
규칙 SQL 쿼리 문에서 간단한 쿼리와 함수를 사용하여 Lambda 함수에 대한 새 메시지 페이로드를 생성했습니다.
-
MQTT 클라이언트를 사용하여 AWS IoT 규칙을 테스트했습니다.
다음 단계
이 규칙을 사용하여 몇 가지 문자 메시지를 전송한 후 이 규칙을 실험하여 자습서의 일부 측면을 변경하면 메시지가 전송되는 시기에 영향을 받는지 확인하세요. 다음은 시작하는 데 도움이 될 몇 가지 아이디어입니다.
-
변경
device_id
입력 메시지의 주제에서 텍스트 메시지 콘텐츠의 효과를 관찰합니다. -
규칙 쿼리 문에서 선택한 필드를 변경하고, 새 메시지에서 사용하도록 Lambda 함수를 업데이트하고, 문자 메시지 내용의 영향을 관찰합니다.
-
최대 온도 대신 최소 온도에 대한 테스트 규칙 쿼리 문에서 테스트를 변경합니다. Lambda 함수를 업데이트하여 새 메시지 형식을 지정하고
max_temperature
이름을 변경하는 것을 잊지 마세요. -
AWS IoT 규칙을 개발하고 사용하는 동안 발생할 수 있는 오류를 찾는 방법에 대한 자세한 내용은 섹션을 참조하세요모니터링 AWS IoT.