保存数据流
现在，您将获取一个 MQTT 数据流，并把每个新数据点追加到列表 store 中。
使用 paho.mqtt 库，您可以通过 subscribe.callback() 订阅数据流。
每条新消息都会调用一次我们的函数。该函数需要包含以下参数：
client，此回调的客户端实例；userdata，创建实例时设置的私有用户数据；message，MQTTMessage的实例。在本练习中，我们只关注其属性payload。
您需要使用 json.loads() 将数据解析为 JSON 字符串，并将其追加到列表 store 中。
随后，将其转换为 DataFrame，并把该 DataFrame 保存为 CSV 文件。
json、pandas（导入为 pd）、MQTT_HOST 和 topic 已在您的会话中可用。
本练习是课程的一部分
用 Python 分析 IoT 数据
交互式实操练习
通过完成这段示例代码来试试这个练习。
# Define function to call by callback method
def ____(____):
# Parse the message.payload
data = ____
store.append(data)