Mettre en cache le flux de données
Vous allez maintenant recueillir 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 de l'appareil 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é transmis au courtier MQTT.
Cet horodatage est disponible sous message.timestamp au format epoch.
Cette activité fait partie du cours
Analyse de données IoT avec Python
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)