diff --git a/main.py b/main.py index 6bda0d0..15e4ccb 100644 --- a/main.py +++ b/main.py @@ -14,26 +14,26 @@ with open(f'/usr/local/sdt/app/{args.config}/config.yaml', encoding='UTF-8') as yamlData = yaml.load(f, Loader=yaml.FullLoader) -# mqttc = mqtt.Client() # puclisher 이름 -# mqttc.username_pw_set("sdt", "251327") -# mqttc.connect("13.209.39.139", 32259) +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) + # 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/{yamlData['topic']}", datas) # topic, message time.sleep(2) - # datas = json.dumps({ - # "assetCode":"", - # "timestamp":0, - # "dataType":"", - # "data": dataList - # }) - # mqttc.publish(f"/device-test/{yamlData['topic']}", datas) # topic, message