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 callbackuserdata, los datos privados del usuario establecidos al crear la instanciamessage, una instancia deMQTTMessage. Para este ejercicio,payloades 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
ejercicio interactivo práctico
Prueba este ejercicio completando este código de ejemplo.
# Define function to call by callback method
def ____(____):
# Parse the message.payload
data = ____
store.append(data)