Fazer cache do fluxo de dados
Agora você vai coletar dados de 2 medidores de energia. Este é um fluxo de dados bem minimalista, que fornece apenas o dispositivo de medição e o valor, separados por vírgula.
Fica assim:
C331,6020
Como não há horário na própria medição, você precisa confiar no momento em que a mensagem foi enviada ao broker MQTT.
Esse timestamp está disponível como message.timestamp em formato epoch.
Este exercicio faz parte do curso
Analisando Dados de IoT em Python
exercicio interativo prático
Tente este exercicio completando este código de exemplo.
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)