缓存数据流
现在您将从 2 个能耗计数器收集数据。 这是一个非常精简的数据流，仅提供测量设备和数值，两者用逗号分隔。
格式如下：
C331,6020
由于测量本身没有时间戳，您需要依赖消息提交到 MQTT 代理时的时间。
该时间戳以 epoch 格式作为 message.timestamp 提供。
本练习是课程的一部分
用 Python 分析 IoT 数据
交互式实操练习
通过完成这段示例代码来试试这个练习。
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)