import sdtcloudpubsub import time import uuid import random sdtcloud = sdtcloudpubsub.sdtcloudpubsub() mqttClient = sdtcloud.setClient(f"device-app-{uuid.uuid1()}") # parameter is client ID(string) def runAction(): while True: msg = [{ "room_id": "room1", "sensor": "power", "value": random.randint(100, 1000) }, { "room_id": "room2", "sensor": "power", "value": random.randint(100, 1000) }] sdtcloud.pubMessage(mqttClient, msg) time.sleep(2) if __name__ == "__main__": runAction()