awx-perfermance/main.py

42 lines
1.3 KiB
Python

# 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()
with open(f'/usr/local/sdt/app/{args.config}/config.yaml', encoding='UTF-8') as f:
yamlData = yaml.load(f, Loader=yaml.FullLoader)
# 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')
f = open(f'/home/sdt-dev1/text.txt', 'w')
while True:
f.write(f"Config value: {yamlData['topic']}\n")
# print(f"Config value: {yamlData['topic']}")
# 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)
time.sleep(2)
# datas = json.dumps({
# "assetCode":"",
# "timestamp":0,
# "dataType":"",
# "data": dataList
# })
# mqttc.publish(f"/device-test/{yamlData['topic']}", datas) # topic, message
f.close()