diff --git a/apps/ccam/sample_data/20180529_BrokenSystem/pythonMQQTdatasender.py b/apps/ccam/sample_data/20180529_BrokenSystem/pythonMQQTdatasender.py old mode 100644 new mode 100755 index 8cc716f..5e75b48 --- a/apps/ccam/sample_data/20180529_BrokenSystem/pythonMQQTdatasender.py +++ b/apps/ccam/sample_data/20180529_BrokenSystem/pythonMQQTdatasender.py @@ -1,45 +1,47 @@ +#!/usr/bin/env python3 + import paho.mqtt.publish as publish from numpy import genfromtxt import itertools ################ SETUP ################ listOfSignals = [["Voltage", "Voltage.csv"], ["Temp1", "Temp1.csv"], ["Temp2", "Temp2.csv"], ["SharkyS", "SharkyS.csv"], ["SharkyB", "SharkyB.csv"], ["Dyna", "Dyna.csv"], ["Riels", "Riels.csv"]] ################# RUN ################# lengthOfLongestSignal = 0 signalsAreOfDiffLength = False allSignalData = [] msgs = [] for signal in listOfSignals: data_np = genfromtxt(signal[1], delimiter=',') data = data_np.tolist() if len(data) > lengthOfLongestSignal: if lengthOfLongestSignal > 0: signalsAreOfDiffLength = True lengthOfLongestSignal = len(data) allSignalData.append([signal[0],data]) if signalsAreOfDiffLength: print(">>> WARNING >>> Signal files are of different length") for i in range(lengthOfLongestSignal): for signal in allSignalData: if i < len(signal[1]): msg = (signal[0], signal[1][i]) msgs.append(msg) publish.multiple(msgs, hostname="localhost", port=1883, client_id="", keepalive=60, will=None, auth=None, tls=None, transport="tcp") -print("Finished sending data") \ No newline at end of file +print("Finished sending data") diff --git a/apps/ccam/sample_data/20180529_BrokenSystem/requirements.txt b/apps/ccam/sample_data/20180529_BrokenSystem/requirements.txt new file mode 100644 index 0000000..c63255f --- /dev/null +++ b/apps/ccam/sample_data/20180529_BrokenSystem/requirements.txt @@ -0,0 +1,2 @@ +numpy +paho.mqtt