Veri Akışını Kaydet

Şimdi bir MQTT veri akışını alacak ve her yeni veri noktasını store listesine ekleyeceksin.

paho.mqtt kütüphanesini kullanarak subscribe.callback() ile bir veri akışına abone olabilirsin.

Her yeni mesaj, fonksiyonumuzun bir kez çağrılmasına neden olur ve bu fonksiyonun aşağıdaki argümanlara sahip olması gerekir:

client, bu geri çağrı için istemci örneği
userdata, örnek oluşturulurken ayarlanan özel kullanıcı verisi
message, bir MQTTMessage örneği. Bu egzersizde yalnızca payload niteliğiyle ilgileniyoruz.

Veriyi json.loads() kullanarak JSON metni olarak ayrıştırmalı ve store listesine eklemelisin. Daha sonra bunu bir DataFrame'e dönüştürecek ve DataFrame'i CSV dosyası olarak kaydedeceksin.

json, pandas (pd olarak), MQTT_HOST ve topic oturumunda hazır.

Bu egzersiz, kursun bir parçasıdır

Python ile IoT Verilerini Analiz Etmek

Kursa Göz Atın

Uygulamalı etkileşimli egzersiz

Bu egzersizi bu örnek kodu tamamlayarak deneyin.

# Define function to call by callback method
def ____(____):
    # Parse the message.payload
    data = ____
    store.append(data)

Kodu Düzenle ve Çalıştır