शुरू करेंमुफ़्त में शुरू करें

डेटास्ट्रीम सहेजें

अब आप एक MQTT डेटा स्ट्रीम लेंगे और आने वाले हर नए डेटा पॉइंट को सूची store में जोड़ेंगे.

लाइब्रेरी paho.mqtt का उपयोग करके, आप subscribe.callback() से किसी डेटा स्ट्रीम को सब्सक्राइब कर सकते हैं.

हर नया संदेश हमारी फ़ंक्शन को एक कॉल ट्रिगर करेगा, जिसमें ये आर्ग्युमेंट होने चाहिए:

  • client, इस कॉलबैक के लिए क्लाइंट इंस्टेंस
  • userdata, इंस्टेंस बनाते समय सेट किया गया प्राइवेट यूज़र डेटा
  • message, MQTTMessage का इंस्टेंस. इस अभ्यास में हमें सिर्फ़ payload एट्रिब्यूट में रुचि है.

आपको json.loads() से डेटा को JSON स्ट्रिंग की तरह पार्स करना है और उसे सूची store में जोड़ना है. इसके बाद इसे DataFrame में बदलें और DataFrame को CSV फ़ाइल के रूप में सहेजें.

json, pandas as pd, MQTT_HOST और topic आपकी सेशन में उपलब्ध हैं.

यह अभ्यास पाठ्यक्रम का हिस्सा है

Python में IoT डेटा का विश्लेषण

पाठ्यक्रम देखें

इंटरैक्टिव व्यावहारिक अभ्यास

इस अभ्यास को इस नमूना कोड को पूरा करके आज़माएँ।

# Define function to call by callback method
def ____(____):
    # Parse the message.payload
    data = ____
    store.append(data)
कोड संपादित करें और चलाएँ