Enregistrer le flux de données

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

Grâce à la bibliothèque paho.mqtt, vous pouvez vous abonner à un flux de données avec subscribe.callback().

Chaque nouveau message entraînera un appel à votre fonction, qui doit accepter les paramètres suivants :

client, l’instance cliente pour ce rappel (callback)
userdata, les données utilisateur privées 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 en chaîne JSON avec json.loads() et les ajouter à la liste store. Vous convertirez ensuite le tout en DataFrame et enregistrerez ce DataFrame dans un fichier CSV.

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

Cet exercice fait partie du cours

<cours>Analyzing IoT Data in Python</cours>

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