import paho.mqtt.client as mqtt import json import argparse from datetime import datetime import time import yaml parser = argparse.ArgumentParser() parser.add_argument('-config',help='') args = parser.parse_args() iwith open(f'/usr/local/sdt/app/{args.config}/config.json', encoding='UTF-8') as f: # with open(f'./config.json', encoding='UTF-8') as f: jsonData = json.load(f) mqttc = mqtt.Client() # puclisher 이름 mqttc.username_pw_set("sdt", "251327") mqttc.connect("13.209.39.139", 32259) # f = open(f'/usr/local/sdt/app/{args.config}/text.txt') while True: # print(f"Config value: {yamlData['topic']}", flush=True) dataList = [] for n in range(10): data = { "timestamp": datetime.now().timestamp(), "data": [1 ,2 ,3 ,4 ,5 ,6 ,1, 1, 2, 3, 1 ,2 ,3 ,4 ,5 ,6 ,1, 1, 2, 3, 1 ,2 ,3 ,4 ,5 ,6 ,1, 1, 2, 3, 1 ,2 ,3 ,4 ,5 ,6 ,1, 1, 2, 3, 1 ,2 ,3 ,4 ,5 ,6 ,1, 1, 2, 3, 1 ,2 ,3 ,4 ,5 ,6 ,1, 1, 2, 3, 4, 5, 6, 1], } dataList.append(data) datas = json.dumps({ "assetCode":"", "timestamp":0, "dataType":"", "data": dataList }) mqttc.publish(f"/sdt-cloud/{jsonData['topic']}", datas) # topic, message time.sleep(2)