pythonMQQTdatasender.py
No OneTemporary
Actions

Authored By

Unknown

Size

1 KB

Referenced Files

None

Subscribers

None

pythonMQQTdatasender.py
View Options

	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")