mqttpublisher.py

import paho.mqtt.client as mqtt
import time
import random
import pandas as pd
import json

clientId = "smartbuilding"
broker_address = "test.mosquitto.org"
broker_port = 1883

client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION1, clientId)
client.connect(broker_address, broker_port)
topic = "sensor_data"

df = pd.read_csv("data/demo_data2.csv")


def publish_sensor_data():
    for i in range(len(df)):

        data = {}
        for col in df.columns:
            data[col] = df[col][i]

        client.publish(topic, payload=json.dumps(data))
        print("published!")
        time.sleep(0.2)


while True:
    publish_sensor_data()
    # time.sleep(0.1)
client.disconnect()