자습서: AWS Lambda 함수를 사용하여 알림 형식 지정 - AWS IoT Core

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

자습서: AWS Lambda 함수를 사용하여 알림 형식 지정

이 자습서에서는 MQTT 메시지 데이터를 AWS Lambda 액션으로 전송하여 형식을 지정하고 다른 AWS 서비스로 보내는 방법을 보여줍니다. 이 자습서에서는 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 함수는 규칙 쿼리문의 데이터를 사용하여 메시지 문자열의 형식을 지정하고 AWS SDK의 SNS 게시 함수를 호출하여 알림을 생성합니다.

이 자습서에서 배울 내용
  • 함수 생성 및 테스트 방법 AWS Lambda

  • AWS Lambda 함수에서 AWS SDK를 사용하여 Amazon SNS 알림을 게시하는 방법

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

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

이 자습서는 완료하는 데 약 45분이 소요됩니다.

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

    이 튜토리얼을 완료하려면 AWS 계정 및 AWS IoT 콘솔이 필요합니다.

  • 검토된 MQTT 클라이언트에서 MQTT 메시지를 확인하세요 AWS IoT .

    MQTT 클라이언트를 사용하여 주제를 구독하고 게시할 수 있는지 확인하세요. 이 절차에서는 MQTT 클라이언트를 사용하여 새 규칙을 테스트합니다.

  • 이 섹션의 다른 규칙 자습서를 완료했습니다.

    이 자습서에는 자습서: Amazon SNS 알림 전송 수행 방법에 대한 자습서에서 생성한 SNS 알림 주제가 필요합니다. 또한 이 섹션의 다른 규칙 관련 자습서를 완료했다고 가정합니다.

  • AWS Lambda 개요를 검토했습니다.

    AWS Lambda 이전에 Lambda를 사용해 본 적이 없다면 Lambda 시작하기를 AWS Lambda검토하여 Lambda의 용어와 개념을 알아보십시오.

1단계: 텍스트 메시지를 보내는 AWS Lambda 함수 생성

이 자습서의 AWS Lambda 함수는 규칙 쿼리 문의 결과를 수신하고, 요소를 텍스트 문자열에 삽입하고, 결과 문자열을 알림의 메시지로 Amazon SNS에 보냅니다.

AWS IoT 규칙 작업을 사용하여 알림을 전송하는 자습서: Amazon SNS 알림 전송 방법에 대한 자습서와 달리 이 자습서에서는 SDK의 함수를 사용하여 Lambda 함수에서 알림을 보냅니다. AWS 그러나 이 자습서에서 사용된 실제 Amazon SNS 알림 주제는 자습서: Amazon SNS 알림 전송 수행 방법에 대한 자습서에서 사용한 것과 동일합니다.

문자 메시지를 보내는 AWS Lambda 함수를 만들려면
  1. 새 AWS Lambda 함수를 생성합니다.

    1. AWS Lambda 콘솔에서 함수 생성을 선택합니다.

    2. 함수 생성(Create function)에서 블루프린트 사용(Use a blueprint)을 선택합니다.

      hello-world-python 블루프린트를 검색하여 선택한 다음 구성을 선택합니다.

    3. 기본 정보(Basic information)에서:

      1. Function name(함수 이름)에 이 함수 이름(format-high-temp-notification)을 입력합니다.

      2. 실행 역할에서 AWS 정책 템플릿에서 새 역할 생성을 선택합니다.

      3. 역할 이름에 새 역할의 이름(format-high-temp-notification-role)을 입력합니다.

      4. 정책 템플릿 - 선택 사항에서 Amazon SNS 게시 정책을 검색하고 선택합니다.

      5. 함수 생성을 선택합니다.

  2. 블루프린트 코드를 수정하여 Amazon SNS 알림의 형식을 지정하고 전송합니다.

    1. 함수를 생성한 후에는 format-high-temp-notification세부정보 페이지가 표시됩니다. 그렇지 않은 경우 Lambda 함수 페이지에서 엽니다.

    2. format-high-temp-notification세부정보 페이지에서 구성 탭을 선택하고 함수 코드 패널로 스크롤합니다.

    3. 함수 코드(Function code) 창의 환경(Environment) 창에서 Python 파일(lambda_function.py)을 선택합니다.

    4. 함수 코드(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
    5. 배포(Deploy)를 선택합니다.

  3. 새 창에서 자습서: Amazon SNS 알림 전송 수행 방법에 대한 자습서에서 Amazon SNS 주제의 Amazon 리소스 이름(ARN)을 조회합니다.

    1. 새 창에서 Amazon SNS 콘솔의 주제 페이지를 엽니다.

    2. 주제 페이지에서 Amazon SNS 주제 목록에서 high_temp_notice 알림 주제를 찾습니다.

    3. 다음 단계에서 사용할 high_temp_notice 알림 주제의 ARN을 찾습니다.

  4. Lambda 함수에 대한 테스트 케이스 생성

    1. 콘솔의 Lambda Functions 페이지에 있는 세부 정보 페이지에서 페이지 오른쪽 상단에 있는 테스트 이벤트 선택 (비활성화된 것처럼 보이지만) 을 선택한 다음 테스트 이벤트 구성을 선택합니다. format-high-temp-notification

    2. 테스트 이벤트 구성(Configure test event)에서 새 테스트 이벤트 구성(Create new test event)을 선택합니다.

    3. 이벤트 이름SampleRuleOutput을 입력합니다.

    4. 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" }
    5. high_temp_notice 알림 주제의 ARN이 있는 창을 참조하여 ARN 값을 복사합니다.

    6. JSON 편집기의 notify_topic_arn 값을 알림 주제의 ARN으로 바꿉니다.

      AWS IoT 규칙을 생성할 때 이 ARN 값을 다시 사용할 수 있도록 이 창을 열어 두세요.

    7. 생성(Create)을 선택합니다.

  5. 샘플 데이터로 함수를 테스트합니다.

    1. format-high-temp-notification세부 정보 페이지의 오른쪽 상단에서 테스트 버튼 옆에 SampleRuleOutput표시되는지 확인합니다. 그렇지 않은 경우 사용 가능한 테스트 이벤트 목록에서 선택합니다.

    2. 함수에 샘플 규칙 출력 메시지를 전송하려면 테스트(Test)를 선택합니다.

함수와 알림이 모두 작동하면 알림을 구독한 휴대 전화에서 문자 메시지를 받습니다.

휴대 전화에서 문자 메시지를 받지 못한 경우 작업 결과를 확인하세요. 함수 코드 패널의 실행 결과 탭에서 응답을 검토하여 발생한 오류를 찾습니다. 함수가 휴대폰으로 알림을 전송할 때까지 다음 단계로 이행하지 마세요.

2단계: 규칙 동작이 포함된 AWS IoTAWS 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

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

  3. 규칙 생성의 상단 부분에서:

    1. 이름에 규칙 이름 wx_friendly_text를 입력합니다.

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

    2. 설명에서 규칙을 설명합니다.

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

  4. 규칙 생성규칙 쿼리 문에서:

    1. SQL 버전 사용에서 2016-03-23를 선택합니다.

    2. 규칙 쿼리 문 편집 상자에 쿼리 문을 입력합니다.

      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 필드에 대한 상수 값을 만듭니다.

    3. high_temp_notice 알림 주제의 ARN이 있는 창을 참조하여 ARN 값을 복사합니다.

    4. 규칙 쿼리 문 편집기의 ARN 값(arn:aws:sns:us-east-1:57EXAMPLE833:high_temp_notice)을 알림 주제의 ARN으로 바꿉니다.

  5. 하나 이상의 작업 설정에서:

    1. 이 규칙에 대한 규칙 작업 목록을 열려면 작업 추가를 선택합니다.

    2. 작업 선택(Select an action)에서 Lambda 함수로 메시지 전송하기(Send a message to a Lambda function)를 선택합니다.

    3. 작업 목록 하단에서 선택한 작업의 구성 페이지를 열려면 구성 작업을 선택합니다.

  6. 구성 작업에서:

    1. 함수 이름에서 선택(Select)을 클릭합니다.

    2. 선택하세요 format-high-temp-notification.

    3. 작업 구성(Configure action) 하단에서 작업 추가(Add action)를 선택합니다.

    4. 규칙을 생성하려면 규칙 생성(Create a rule) 하단에서 규칙 생성(Create rule)을 선택합니다.

3단계: AWS IoT 규칙 및 AWS Lambda 규칙 조치 테스트

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

새 창에서 AWS IoT 콘솔의 MQTT 클라이언트를 엽니다. 이제 MQTT 클라이언트의 구성을 그대로 유지하면서 규칙을 편집할 수 있습니다. MQTT 클라이언트를 떠나 콘솔의 다른 페이지로 이동하면 구독 또는 메시지 로그가 손실됩니다.

MQTT 클라이언트를 사용하여 규칙을 테스트하려면
  1. AWS IoT 콘솔의 MQTT 클라이언트에서 입력 주제(이 경우 device/+/data)를 구독합니다.

    1. MQTT 클라이언트에서 구독 아래에서 주제 구독을 선택합니다.

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

    3. 나머지 필드는 기본 설정을 유지합니다.

    4. 주제 구독을 선택합니다.

      구독 열의 주제 게시 아래에 device/+/data가 나타납니다.

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

    1. MQTT 클라이언트의 구독 아래에서 주제 게시를 선택합니다.

    2. 게시 필드에 입력 주제 이름 device/32/data를 입력합니다.

    3. 여기에 표시된 샘플 데이터를 복사하고 주제 이름 아래의 편집 상자에 샘플 데이터를 붙여 넣습니다.

      { "temperature": 38, "humidity": 80, "barometer": 1013, "wind": { "velocity": 22, "bearing": 255 } }
    4. MQTT 메시지를 게시하려면 주제에 게시(Publish to topic)를 선택합니다.

  3. 문자 메시지가 전송되었는지 확인합니다.

    1. MQTT 클라이언트의 구독 아래에서 이전에 구독한 주제 옆에 녹색 점이 있습니다.

      녹색 점은 마지막으로 메시지를 보았을 때 하나 이상의 새 메시지가 수신되었음을 나타냅니다.

    2. 구독 아래에서 device/+/data를 선택하여 메시지 페이로드가 방금 게시한 것과 일치하고 다음과 같이 표시되는지 확인하세요.

      { "temperature": 38, "humidity": 80, "barometer": 1013, "wind": { "velocity": 22, "bearing": 255 } }
    3. SNS 주제를 구독하는 데 사용한 전화를 확인하고 메시지 페이로드의 내용이 다음과 같이 표시되는지 확인합니다.

      Device 32 reports a temperature of 38, which exceeds the limit of 30.

      메시지 주제에서 주제 ID 요소를 변경하는 경우 메시지 주제의 해당 요소에 숫자만 포함된 경우에만 topic(2) 값을 숫자 값으로 캐스팅할 수 있다는 점을 기억하세요.

  4. 온도가 한계를 초과하지 않는 MQTT 메시지를 전송해보세요.

    1. MQTT 클라이언트의 구독 아래에서 주제 게시를 선택합니다.

    2. 게시 필드에 입력 주제 이름 device/33/data를 입력합니다.

    3. 여기에 표시된 샘플 데이터를 복사하고 주제 이름 아래의 편집 상자에 샘플 데이터를 붙여 넣습니다.

      { "temperature": 28, "humidity": 80, "barometer": 1013, "wind": { "velocity": 22, "bearing": 255 } }
    4. MQTT 메시지를 전송하려면 주제 게시를 선택합니다.

    device/+/data 구독에서 전송한 메시지가 표시되어야 하지만 온도 값이 규칙 쿼리 문에서 최대 온도보다 낮기 때문에 문자 메시지를 받지 않아야 합니다.

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

AWS Lambda 규칙 및 알림 문제 해결

예상한 결과가 표시되지 않는 경우를 대비하여 확인해야 할 몇 가지 사항이 있습니다.

  • 오류 배너가 있음

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

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

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

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

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

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

    • 메시지 게시 함수 확인

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

  • SMS 메시지가 수신되지 않음

    규칙이 작동하려면 메시지를 수신하고 SNS 알림을 전송할 수 있도록 권한을 부여하는 올바른 정책이 있어야 하며 메시지를 수신해야 합니다.

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

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

    • 메시지 페이로드의 온도 값이 테스트 임계값을 초과하는지 확인

      규칙 쿼리 문에 정의된 대로 온도 값이 30보다 작거나 같으면 규칙은 해당 작업을 수행하지 않습니다.

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

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

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

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

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

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

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

    • Amazon SNS 알림 확인

      1단계: SMS 문자 메시지를 전송하는 Amazon SNS 주제 생성에서 Amazon SNS 알림을 테스트하고 알림을 테스트하여 알림이 작동하는지 확인하는 방법을 설명하는 3단계를 참조하세요.

    • 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.