Mettre en cache le flux de données
Vous allez maintenant collecter des données à partir de 2 compteurs d’énergie. Il s’agit d’un flux de données très minimaliste, qui ne fournit que l’identifiant du dispositif de mesure et la valeur, séparés par une virgule.
Cela ressemble à ceci :
C331,6020
Comme l’horodatage n’est pas inclus dans la mesure elle-même, vous devez vous fier à l’heure à laquelle le message a été envoyé au courtier MQTT.
Cet horodatage est disponible sous message.timestamp au format epoch.
Cet exercice fait partie du cours
<cours>Analyzing IoT Data in Python</cours>Exercice interactif pratique
Essayez cet exercice en complétant ce code d’exemple.
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)