자습서: 디바이스를 AWS IoT Core 사용하여에 AWS IoT 디바이스 연결 SDK

1. 연습을 시작하기 전에 디바이스의 AWS IoT Core 자습서 시작하기 자습서에서 이 명령을 실행하여 연습에 필요한 모든 것이 준비되었는지 확인하세요.

   cd ~/aws-iot-device-sdk-python-v2/samples
   python3 pubsub.py --topic topic_1 --ca_file ~/certs/Amazon-root-CA-1.pem --cert ~/certs/device.pem.crt --key ~/certs/private.pem.key --endpoint your-iot-endpoint
   

   시작하기 자습서에서 본 것과 동일한 출력이 표시되어야 합니다.

2. 이 연습에서는 다음 명령행 파라미터를 변경합니다.

   작업	명령줄 파라미터	Effect
   추가	--message ""	수신 대기만 하도록 pubsub.py 구성
   추가	--count 2	두 개의 메시지를 받은 후 프로그램 종료
   변경	--topic device/+/details	구독할 주제 필터 정의

   초기 명령줄을 이렇게 변경하면 이 명령줄이 생성됩니다. 디바이스의 터미널 창에 이 명령을 입력합니다.

   python3 pubsub.py --message "" --count 2 --topic device/+/details --ca_file ~/certs/Amazon-root-CA-1.pem --cert ~/certs/device.pem.crt --key ~/certs/private.pem.key --endpoint your-iot-endpoint
   

   프로그램은 다음과 같이 표시되어야 합니다.

   Connecting to a3qexamplesffp-ats.iot.us-west-2.amazonaws.com with client ID 'test-24d7cdcc-cc01-458c-8488-2d05849691e1'...
   Connected!
   Subscribing to topic 'device/+/details'...
   Subscribed with QoS.AT_LEAST_ONCE
   Waiting for all messages to be received...
   

   터미널에 이와 같은 항목이 표시되면 디바이스가 준비되고 주제 이름이 device(으)로 시작하고 /detail(으)로 끝나는 메시지를 수신 대기 중인 것입니다. 그럼 테스트해 보겠습니다.

3. 다음은 디바이스에서 수신할 수 있는 몇 가지 메시지입니다.

   주제 이름	메시지 페이로드
   device/temp/details	{ "desiredTemp": 20, "currentTemp": 15 }
   device/light/details	{ "desiredLight": 100, "currentLight": 50 }

4. AWS IoT 콘솔에서 MQTT 테스트 클라이언트를 사용하여 이전 단계에서 설명한 메시지를 디바이스로 전송합니다.

   1. AWS IoT 콘솔에서 MQTT 테스트 클라이언트를 엽니다.

   2. 주제 구독(Subscribe to a topic)의 Subscription topic field(구독 주제 필드)에 주제 필터 device/+/details를 입력한 다음 주제 구독(Subscribe to topic)을 선택합니다.

   3. MQTT 테스트 클라이언트의 구독 열에서 device/+/details를 선택합니다.

   4. 위 표의 각 주제에 대해 MQTT 테스트 클라이언트에서 다음을 수행합니다.

      1. 게시(Publish)에서 테이블의 주제 이름(Topic name) 열에 있는 값을 입력합니다.

      2. 주제 이름 아래의 메시지 페이로드 필드에 테이블의 메시지 페이로드(Message payload) 열에 있는 값을 입력합니다.

      3. pubsub.py가 실행 중인 터미널 창을 보고 MQTT 테스트 클라이언트에서 주제에 게시를 선택합니다.

      터미널 창에서 pubsub.py가 메시지를 수신했음을 확인해야 합니다.

메시지 주제를 평가하려면

1. pubsub.py를 pubsub2.py에 복사합니다.

2. 선호하는 텍스트 편집기 또는 pubsub2.py에서를 엽니다IDE.

3. pubsub2.py에서 on_message_received 함수를 찾습니다.

4. on_message_received에서 print("Received message로 시작하는 줄 뒤와 global received_count로 시작하는 줄 앞에 다음 코드를 삽입합니다.

       topic_parsed = False
       if "/" in topic:
           parsed_topic = topic.split("/")
           if len(parsed_topic) == 3:
               # this topic has the correct format
               if (parsed_topic[0] == 'device') and (parsed_topic[2] == 'details'):
                   # this is a topic we care about, so check the 2nd element
                   if (parsed_topic[1] == 'temp'):
                       print("Received temperature request: {}".format(payload))
                       topic_parsed = True
                   if (parsed_topic[1] == 'light'):
                       print("Received light request: {}".format(payload))
                       topic_parsed = True
       if not topic_parsed:
           print("Unrecognized message topic.")
   

5. 변경 사항을 저장하고 이 명령줄을 사용하여 수정된 프로그램을 실행합니다.

   python3 pubsub2.py --message "" --count 2 --topic device/+/details --ca_file ~/certs/Amazon-root-CA-1.pem --cert ~/certs/device.pem.crt --key ~/certs/private.pem.key --endpoint your-iot-endpoint
   

6. AWS IoT 콘솔에서 MQTT 테스트 클라이언트를 엽니다.

7. 주제 구독(Subscribe to a topic)의 Subscription topic field(구독 주제 필드)에 주제 필터 device/+/details를 입력한 다음 주제 구독(Subscribe to topic)을 선택합니다.

8. MQTT 테스트 클라이언트의 구독 열에서 device/+/details를 선택합니다.

9. 이 표의 각 주제에 대해 MQTT 테스트 클라이언트에서 다음을 수행합니다.

   주제 이름	메시지 페이로드
   device/temp/details	{ "desiredTemp": 20, "currentTemp": 15 }
   device/light/details	{ "desiredLight": 100, "currentLight": 50 }

   1. 게시(Publish)에서 테이블의 주제 이름(Topic name) 열에 있는 값을 입력합니다.

   2. 주제 이름 아래의 메시지 페이로드 필드에 테이블의 메시지 페이로드(Message payload) 열에 있는 값을 입력합니다.

   3. pubsub.py가 실행 중인 터미널 창을 보고 MQTT 테스트 클라이언트에서 주제에 게시를 선택합니다.

   터미널 창에서 pubsub.py가 메시지를 수신했음을 확인해야 합니다.

이 연습의 메시지를 모니터링하도록 MQTT 테스트 클라이언트를 준비하려면

1. 주제 구독(Subscribe to a topic)의 Subscription topic field(구독 주제 필드)에 주제 필터 device/data를 입력한 다음 주제 구독(Subscribe to topic)을 선택합니다.

2. MQTT 테스트 클라이언트의 구독 열에서 디바이스/데이터를 선택합니다.

3. MQTT 테스트 클라이언트 창을 열어 두어 디바이스에서 메시지를 기다립니다.

pubsub.py 샘플 앱으로 JSON 문서를 보내려면

1. 디바이스에서 pubsub.py를 pubsub3.py로 복사합니다.

2. 게시하는 메시지의 형식을 변경하도록 pubsub3.py를 편집합니다.

   1. 텍스트 편집기에서 pubsub3.py을(를) 엽니다.

   2. 다음 코드 행을 찾습니다.

      message = "{} [{}]".format(message_string, publish_count)

   3. 다음과 같이 변경하세요.

      message = "{}".format(message_string)

   4. 다음 코드 행을 찾습니다.

      message_json = json.dumps(message)

   5. 다음과 같이 변경하세요.

      message = "{}".json.dumps(json.loads(message))

   6. 변경 내용을 저장합니다.

3. 디바이스에서 이 명령을 실행하여 메시지를 두 번 전송합니다.

   python3 pubsub3.py  --ca_file ~/certs/Amazon-root-CA-1.pem  --cert ~/certs/device.pem.crt  --key ~/certs/private.pem.key  --topic device/data  --count 2 --message '{"timestamp":1601048303,"sensorId":28,"sensorData":[{"sensorName":"Wind speed","sensorValue":34.2211224}]}'  --endpoint your-iot-endpoint
   

4. MQTT 테스트 클라이언트에서 다음과 같이 메시지 페이로드의 JSON 문서를 해석하고 형식을 지정했는지 확인합니다.