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)
