데이터 스트림 캐싱
이제 두 개의 에너지 카운터에서 데이터를 수집해 보겠습니다. 이 데이터 스트림은 매우 단순하며, 측정 장치와 값만 쉼표로 구분해 제공합니다.
형식은 다음과 같습니다:
C331,6020
측정값 자체에는 시간이 없기 때문에, MQTT 브로커에 메시지가 전송된 시간을 사용해야 합니다.
이 타임스탬프는 epoch 형식으로 message.timestamp 에서 확인할 수 있습니다.
이 연습은 강의의 일부입니다
Python으로 IoT 데이터 분석하기
실습형 인터랙티브 연습
이 예제를 이 샘플 코드를 완성하여 풀어보세요.
cache = []
def on_message(client, userdata, message):
# Combine timestamp and payload
data = f"{____.____},{____.____}"
# Append data to cache
____.____(____)
# Connect function to mqtt datastream
subscribe.callback(on_message, topics="datacamp/energy", hostname=MQTT_HOST)