MQTT 단일 메시지
다음과 같은 상황을 가정해 보세요: MQTT 브로커 주소와 토픽 이름을 받았고, 데이터 스트림의 내용을 저장하는 코드를 작성해야 합니다.
먼저, 단일 메시지를 수신해 메시지가 어떤 형식인지 확인하세요.
그다음 메시지를 출력해 살펴보며 데이터를 어떻게 처리할지 판단합니다.
이는 다음 연습 문제에서 데이터 스트림에 구독하고 여러 메시지를 수집하기 위한 기초가 됩니다.
이 연습은 강의의 일부입니다
Python으로 IoT 데이터 분석하기
연습 안내
- MQTT 라이브러리
paho.mqtt.subscribe를subscribe로 임포트하세요. - 토픽
"datacamp/iot/simple"에서 메시지 한 개를 가져와msg에 저장하세요. - 메시지에서 토픽과 페이로드를 쉼표로 구분해 출력하세요.
실습형 인터랙티브 연습
이 예제를 이 샘플 코드를 완성하여 풀어보세요.
# Import mqtt library
import ____ as ____
# Retrieve one message
msg = ____.____(____, hostname="mqtt.datacamp.com")
# Print topic and payload
print(f"{____}, {____}")