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
Analyzing IoT Data in Python
Exercice interactif pratique
Essayez cet exercice en complétant cet exemple de code.
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)