डेटा स्ट्रीम कैश करें
अब आप 2 एनर्जी काउंटर से डेटा इकट्ठा करेंगे. यह एक बहुत ही मिनिमलिस्टिक डेटा स्ट्रीम है, जो केवल मापन डिवाइस और वैल्यू देता है, जिन्हें कॉमा से अलग किया गया है.
यह कुछ इस तरह दिखता है:
C331,6020
क्योंकि मापन में समय शामिल नहीं है, इसलिए आपको उस समय पर निर्भर रहना होगा जब मैसेज MQTT broker को सबमिट किया गया था.
यह टाइमस्टैम्प 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)