Guardar flujo de datos

Ahora vas a tomar un flujo de datos MQTT y añadir cada nuevo punto de datos a la lista store.

Con la librería paho.mqtt, puedes suscribirte a un flujo de datos usando subscribe.callback().

Cada nuevo mensaje provocará una llamada a nuestra función, que debe tener los siguientes argumentos:

client, la instancia de cliente para este callback
userdata, los datos privados del usuario establecidos al crear la instancia
message, una instancia de MQTTMessage. Para este ejercicio, payload es el único atributo que nos interesa.

Necesitas interpretar los datos como una cadena JSON usando json.loads() y añadirlos a la lista store. Luego convertirás esto en un DataFrame y guardarás el DataFrame como un archivo CSV.

json, pandas como pd, MQTT_HOST y topic están disponibles en tu sesión.

Este ejercicio forma parte del curso

Análisis de datos de IoT en Python

Ver curso

Ejercicio interactivo práctico

Prueba este ejercicio y completa el código de muestra.

# Define function to call by callback method
def ____(____):
    # Parse the message.payload
    data = ____
    store.append(data)

Editar y ejecutar código