diff --git a/AWX_shm_updater.py b/AWX_shm_updater.py new file mode 100644 index 0000000..8abdbe7 --- /dev/null +++ b/AWX_shm_updater.py @@ -0,0 +1,23 @@ +import numpy as np +from multiprocessing import shared_memory +import time +import json +import argparse + + +existing_shm = shared_memory.SharedMemory(name="DO-shm") + +c = np.ndarray((64,), dtype=np.int32, buffer=existing_shm.buf) + +parser = argparse.ArgumentParser() +parser.add_argument('-config',help='') +args = parser.parse_args() + +ROOT_PATH = f"/usr/local/sdt/app/{args.config}" + +while True: + with open(f"{ROOT_PATH}/config.json", 'r') as file: + jsonData = json.load(file) + for n in range(64): + c[n]=jsonData[str(n+1)] + time.sleep(2) diff --git a/AWX_shm_updater.py~ b/AWX_shm_updater.py~ new file mode 100644 index 0000000..816deef --- /dev/null +++ b/AWX_shm_updater.py~ @@ -0,0 +1,18 @@ +import numpy as np +from multiprocessing import shared_memory +import time +import json + + + +existing_shm = shared_memory.SharedMemory(name="DO-shm") + +c = np.ndarray((64,), dtype=np.int32, buffer=existing_shm.buf) + +file_path = "./config.json" +while True: + with open(file_path, 'r') as file: + jsonData = json.load(file) + for n in range(64): + c[n]=jsonData[str(n+1)] + time.sleep(2) diff --git a/AWX_shm_updater.service b/AWX_shm_updater.service new file mode 100644 index 0000000..6f1d3c8 --- /dev/null +++ b/AWX_shm_updater.service @@ -0,0 +1,10 @@ +[Unit] +Description=awx_shm_updater + +[Service] +ExecStart=/usr/bin/python3 /usr/local/sdt/app/appName/AWX_shm_updater.py -config appName +Restart=always +RestartSec=10 + +[Install] +WantedBy=multi-user.target diff --git a/AWX_shm_updater.service~ b/AWX_shm_updater.service~ new file mode 100644 index 0000000..06765be --- /dev/null +++ b/AWX_shm_updater.service~ @@ -0,0 +1,10 @@ +[Unit] +Description=awx_collector + +[Service] +ExecStart=/usr/bin/python3 /usr/local/sdt/app/appName/AWX_collector.py -config appName +Restart=always +RestartSec=10 + +[Install] +WantedBy=multi-user.target diff --git a/config.json~ b/config.json~ new file mode 100644 index 0000000..811dba0 --- /dev/null +++ b/config.json~ @@ -0,0 +1,66 @@ +{ + "1": 1, + "2": 1, + "3": 1, + "4": 1, + "5": 1, + "6": 1, + "7": 1, + "8": 1, + "9": 1, + "10": 0, + "11": 0, + "12": 0, + "13": 0, + "14": 0, + "15": 0, + "16": 1, + "17": 0, + "18": 0, + "19": 0, + "20": 0, + "21": 0, + "22": 0, + "23": 0, + "24": 0, + "25": 0, + "26": 0, + "27": 0, + "28": 0, + "29": 0, + "30": 0, + "31": 0, + "32": 0, + "33": 0, + "34": 0, + "35": 0, + "36": 1, + "37": 0, + "38": 0, + "39": 0, + "40": 0, + "41": 0, + "42": 0, + "43": 0, + "44": 0, + "45": 0, + "46": 1, + "47": 0, + "48": 0, + "49": 0, + "50": 0, + "51": 0, + "52": 0, + "53": 0, + "54": 0, + "55": 0, + "56": 1, + "57": 0, + "58": 0, + "59": 0, + "60": 0, + "61": 0, + "62": 0, + "63": 0, + "64": 0 +} diff --git a/install.sh~ b/install.sh~ new file mode 100644 index 0000000..577f9e6 --- /dev/null +++ b/install.sh~ @@ -0,0 +1,9 @@ +#!/bin/bash + +pip install -r requirements.txt +sudo sed -i "s/appName/$1/g" /usr/local/sdt/app/$1/AWX_collector.service +sudo cp /usr/local/sdt/app/$1/AWX_collector.service /etc/systemd/system/$1.service + +sudo cp /usr/local/sdt/app/$1/AWX_shm_updater.service /etc/systemd/system/AWX_shm_updater.service +sudo systemctl start $1 +sudo systemctl enable $1 diff --git a/shm_updater.py~ b/shm_updater.py~ new file mode 100644 index 0000000..af05cf2 --- /dev/null +++ b/shm_updater.py~ @@ -0,0 +1,18 @@ +import numpy as np +from multiprocessing import shared_memory +import time +import json + + + +existing_shm = shared_memory.SharedMemory(name="do_shm2") + +c = np.ndarray((32,), dtype=np.int32, buffer=existing_shm.buf) + +file_path = "./config.json" +while True: + with open(file_path, 'r') as file: + jsonData = json.load(file) + for n in range(32): + c[n]=jsonData[str(n+1)] + time.sleep(2)