Compare commits

..

No commits in common. "main" and "test1" have entirely different histories.
main ... test1

4 changed files with 19 additions and 37 deletions

View File

@ -1,10 +0,0 @@
[Unit]
Description=awx-perfermance-arm32
[Service]
ExecStart=/usr/bin/python3 /usr/local/sdt/app/appName/main.py -config appName
Restart=always
RestartSec=10
[Install]
WantedBy=multi-user.target

10
awx-perfermance.service Normal file
View File

@ -0,0 +1,10 @@
[Unit]
Description=awx-perfermance
[Service]
ExecStart=/home/sdt/miniconda3/bin/python3 /usr/local/sdt/app/awx-perfermance/main.py
Restart=always
RestartSec=10
[Install]
WantedBy=multi-user.target

View File

@ -1,7 +1,5 @@
#!/bin/bash #!/bin/bash
sudo sed -i "s/appName/$1/g" /usr/local/sdt/app/$1/awx-perfermance-arm32.service sudo cp /usr/local/sdt/app/awx-perfermance/awx-perfermance.service /etc/systemd/system/
sudo cp /usr/local/sdt/app/$1/awx-perfermance.service /etc/systemd/system/$1.service sudo systemctl start awx-perfermance
sudo systemctl start $1 sudo systemctl enable awx-perfermance
sudo systemctl enable $1

28
main.py
View File

@ -1,16 +1,11 @@
import paho.mqtt.client as mqtt import paho.mqtt.client as mqtt
import json import json
import argparse
from datetime import datetime from datetime import datetime
import time import time
import yaml import yaml
parser = argparse.ArgumentParser() with open('/usr/local/sdt/app/awx-perfermance/config.yaml', encoding='UTF-8') as f:
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) yamlData = yaml.load(f, Loader=yaml.FullLoader)
@ -23,27 +18,16 @@ while True:
for n in range(10): for n in range(10):
data = { data = {
"timestamp": datetime.now().timestamp(), "timestamp": datetime.now().timestamp(),
"current": [0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0], "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],
"voltage": [0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0],
"do": [0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0],
"er1": [0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0],
"er2": [0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0],
} }
dataList.append(data) dataList.append(data)
time.sleep(0.1) time.sleep(0.1)
dataBody = {
"slot": 1,
"chamber": 1,
"channel": 1,
"list": dataList,
}
datas = json.dumps({ datas = json.dumps({
"modeCode": "test1", "assetCode":"",
"assetCode": "perfermance", "timestamp":0,
"dataType":"DATA", "dataType":"",
"data": dataBody "data": dataList
}) })
mqttc.publish(f"/device-data/{yamlData['topic']}", datas) # topic, message mqttc.publish(f"/device-data/{yamlData['topic']}", datas) # topic, message
# mqttc.publish(f"/device-data/perfermance", datas) # topic, message