डेटा स्ट्रीम्स का परिचय

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

Matthias Voppichler

IT Developer

डेटा स्ट्रीम क्या है

निरंतर डेटा स्ट्रीम
उदाहरण
- Twitter संदेश
- ऑनलाइन न्यूज़ आर्टिकल्स
- वीडियो स्ट्रीम्स
- सेंसर डेटा (IoT)
- मार्केट ऑर्डर्स (फाइनेंशियल)

डेटा स्ट्रीम क्या है

निरंतर डेटा स्ट्रीम
उदाहरण
- Twitter संदेश
- ऑनलाइन न्यूज़ आर्टिकल्स
- वीडियो स्ट्रीम्स
- सेंसर डेटा (IoT)
- मार्केट ऑर्डर्स (फाइनेंशियल)

MQTT

मैसेज प्रोटोकॉल
पब्लिश/सब्सक्राइब
स्मॉल फुटप्रिंट

Server -> मैसेज ब्रोकर की तरह कार्य करता है

Client:

ब्रोकर से कनेक्ट होता है
डेटा पब्लिश करता है
टॉपिक्स को सब्सक्राइब करता है

Message Queuing Telemetry Transport

MQTT डेटा फ्लो - प्रोड्यूसर से -> ब्रोकर तक -> कंज्यूमर्स तक

Python लाइब्रेरी

Eclipse Paho™ MQTT Python Client

# Import MQTT library
import paho.mqtt

अधिक जानकारी और डॉक्यूमेंटेशन GitHub पर उपलब्ध है https://github.com/eclipse/paho.mqtt.python

सिंगल मैसेज

import paho.mqtt.subscribe as subscribe
msg = subscribe.simple("paho/test/simple", 
                       hostname="test.mosquitto.org")

print(f"{msg.topic}, {msg.payload}")

आउटपुट:

paho/test/simple, {"time": 1549481572, "humidity": 77, "temp": 21}

कॉलबैक

def on_message(client, userdata, message):

    print(f"{message.topic} : {message.payload}")

आर्ग्युमेंट्स

client - क्लाइंट इंस्टेंस
userdata - प्राइवेट यूज़र डेटा
message - MQTTMessage का इंस्टेंस

कॉलबैक

import paho.mqtt.subscribe as subscribe


subscribe.callback(on_message, 
                   topics="datacamp/roomtemp", 
                   hostname="test.mosquitto.org")

MQTT Subscribe

import paho.mqtt.subscribe as subscribe

def on_message(client, userdata, message):
    print("{} : {}".format(message.topic, message.payload))

subscribe.callback(on_message, 
                   topics="datacamp/roomtemp", 
                   hostname="test.mosquitto.org")

datacamp/roomtemp : b'{"time": 1543344857, "hum": 34, "temp": 24}'
datacamp/roomtemp : b'{"time": 1543344858, "hum": 35, "temp": 23}'
datacamp/roomtemp : b'{"time": 1543344860, "hum": 36, "temp": 22}'
datacamp/roomtemp : b'{"time": 1543344946, "hum": 37, "temp": 22}'
datacamp/roomtemp : b'{"time": 1543345010, "hum": 36, "temp": 13}'

अभ्यास करते हैं!

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