Compare commits
12 Commits
Author | SHA1 | Date |
---|---|---|
이수준 | e9cc931753 | |
이수준 | 50b007cb75 | |
이수준 | e0b44b8aff | |
이수준 | 40365eb8e0 | |
이수준 | 4cfb891eba | |
이수준 | ca8c28c252 | |
이수준 | ed2394fde0 | |
이수준 | 5304b586aa | |
이수준 | 5c3c10356f | |
이수준 | 9ef21a24ce | |
이수준 | af5d932441 | |
이수준 | 84f6d9341f |
|
@ -0,0 +1,6 @@
|
|||
{
|
||||
"hw": "intel",
|
||||
"cpu": 12,
|
||||
"memory": 32,
|
||||
"gpu": "2080TI"
|
||||
}
|
|
@ -0,0 +1,9 @@
|
|||
{
|
||||
"topic": "performance",
|
||||
"id": "sdt",
|
||||
"password": "11223344",
|
||||
"host": {
|
||||
"address": "192.168.100.200",
|
||||
"hostname": "sdt"
|
||||
}
|
||||
}
|
|
@ -1 +0,0 @@
|
|||
topic: perfermance
|
|
@ -1,5 +1,7 @@
|
|||
#!/bin/bash
|
||||
|
||||
set -e
|
||||
|
||||
sudo sed -i "s/appName/$1/g" /usr/local/sdt/app/$1/awx-perfermance.service
|
||||
sudo cp /usr/local/sdt/app/$1/awx-perfermance.service /etc/systemd/system/$1.service
|
||||
sudo systemctl start $1
|
||||
|
|
47
main.py
47
main.py
|
@ -1,4 +1,4 @@
|
|||
# import paho.mqtt.client as mqtt
|
||||
import paho.mqtt.client as mqtt
|
||||
import json
|
||||
import argparse
|
||||
|
||||
|
@ -10,32 +10,31 @@ 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)
|
||||
with 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')
|
||||
# f = open(f'./text.txt', 'w')
|
||||
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:
|
||||
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)
|
||||
# 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)
|
||||
|
||||
|
||||
# datas = json.dumps({
|
||||
# "assetCode":"",
|
||||
# "timestamp":0,
|
||||
# "dataType":"",
|
||||
# "data": dataList
|
||||
# })
|
||||
# mqttc.publish(f"/device-test/{yamlData['topic']}", datas) # topic, message
|
||||
|
|
Loading…
Reference in New Issue