Menyimpan Data Stream

Sekarang Anda akan mengambil data stream MQTT dan menambahkan setiap titik data baru ke daftar store.

Dengan pustaka paho.mqtt, Anda dapat berlangganan ke data stream menggunakan subscribe.callback().

Setiap pesan baru akan memicu satu pemanggilan ke fungsi kita, yang harus memiliki argumen berikut:

client, instance klien untuk callback ini
userdata, data pengguna privat yang ditetapkan saat membuat instance
message, sebuah instance MQTTMessage. Untuk latihan ini, payload adalah satu-satunya atribut yang kita butuhkan.

Anda perlu mengurai data sebagai string JSON menggunakan json.loads() dan menambahkannya ke daftar store. Selanjutnya, Anda akan mengonversinya menjadi DataFrame dan menyimpan DataFrame sebagai file CSV.

json, pandas sebagai pd, MQTT_HOST, dan topic tersedia dalam sesi Anda.

Latihan ini merupakan bagian dari kursus

Menganalisis Data IoT dengan Python

Lihat Kursus

Latihan interaktif langsung praktik

Cobalah latihan ini dengan melengkapi kode contoh ini.

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

Edit dan Jalankan Kode