Enregistrer le flux de données

Vous allez maintenant utiliser un flux de données MQTT et ajouter chaque nouveau point de données à la liste store.

Avec la bibliothèque paho.mqtt, vous pouvez vous abonner à un flux de données à l'aide de subscribe.callback().

Chaque nouveau message déclenchera un appel à votre fonction, qui doit accepter les paramètres suivants :

client, l'instance du client pour ce rappel
userdata, les données privées de l'utilisateur définies lors de la création de l'instance
message, une instance de MQTTMessage. Pour cet exercice, payload est le seul attribut qui nous intéresse.

Vous devez analyser les données sous forme de chaîne JSON à l'aide de json.loads() et les ajouter à la liste store. Vous convertirez ensuite le tout en DataFrame et enregistrerez la DataFrame en fichier CSV.

json, pandas sous pd, MQTT_HOST et topic sont disponibles dans votre session.

Cette activité fait partie du cours

Analyse de données IoT avec Python

Voir le cours

Exercice interactif pratique

Essayez cet exercice en complétant ce code d’exemple.

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

Modifier et exécuter le code