BaşlayınÜcretsiz Başlayın

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

Python ile IoT Verilerini Analiz Etmek

kursunun bir parçasıdır
Kursu Görüntüle

Uygulamalı interaktif egzersiz

Bu örnek kodu tamamlayarak bu egzersizi bitirin.

# Define function to call by callback method
def ____(____):
    # Parse the message.payload
    data = ____
    store.append(data)
Kodu Düzenle ve Çalıştır