Cache de flujo de datos
Ahora vas a recopilar datos de 2 contadores de energía. Este es un flujo de datos muy minimalista, que solo proporciona el identificador del dispositivo de medida y el valor, separados por una coma.
Tiene este aspecto:
C331,6020
Como la medición no incluye la hora, necesitas basarte en el momento en que el mensaje se envió al broker MQTT.
Esta marca temporal está disponible como message.timestamp en formato epoch.
Este ejercicio forma parte del curso
Análisis de datos de IoT en Python
Ejercicio interactivo práctico
Prueba este ejercicio y completa el código de muestra.
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)