GraphFromCSV.py

import time
import os
from os.path import exists
from datetime import datetime
import pandas as pd
import numpy as np

shareDir = "/home/pi/EnviromentShare/"
if not exists(shareDir):
  os.mkdir(shareDir)

TGraph = shareDir + "Temperature_graph.txt"
titleT = "\n\t\tTemperature [deg C]\t"
fixedDigitsT = "{:<5}"
dpT = 2

HGraph = shareDir + "Humidity_graph.txt"
titleH = "\n\t\tHumidity [%]\t"
fixedDigitsH = "{:<5}"
dpH = 2

PGraph = shareDir + "Pressure_graph.txt"
titleP = "\n\t\tPressure [kPa]\t"
fixedDigitsP = "{:<10}"
dpP = 4

numRows = 10

def createGraphFile(gName, avData, numCols, numRows, gTitle, timeNow, fixedDigits, dp):
  f = open(gName, "w")
  Max = avData.max()
  Min = avData.min()
  Range = Max - Min + 0.01	# +0.01 to avoid div0
  newData = [0]*numCols		# newData contains the row which eat column should have a "#"
  i = 0				# i is the index of the column being processed
  numHour = 0			# numHour is how many hours of valid data have been processed

  while i < int(avData.index[-1]) + 1:	# count through as many times as the largest hour in the data
    if i == int(avData.index[numHour]):	# if the index is equal to the next hour to be processed
      newData[i] = numRows*(float(avData[numHour]) - Min)/Range
      numHour += 1
    else:
      newData[i] = -1
    i += 1
# newData is now complete, each column containsa value indicating the row where the "#" should be. -1 for invalid data

  f.write(gTitle + timeNow + "\n")
  for y in range(numRows,-1,-1):
    f.write(fixedDigits.format(str(round(Min + y*(Range/numRows),dp))) + "\t")	# Y axis values
    for x in range(numCols):	# cycle through each X value
      if int(newData[x]) == y:	# if X and Y align, place a "#"
        f.write(".#")
      else:
        f.write(". ")
    f.write(".\n")

  f.write(fixedDigits.format("") + "\t")	# align X axis values to graph
  for hr in range(0,numCols,2):			# write each even hour
    f.write(str(hr) + "  ")
    if hr < 10:
      f.write(" ")				# adjust for single vs double digits

  f.write("\n")
  f.close()

run = 1
while run:
#  run = 0
  timeNow = datetime.now().strftime("%y_%m_%d")
  RtimeNow = timeNow[6:8] + timeNow[2:5] +timeNow[5] + timeNow[0:2]
#  RtimeNow = datetime.now().strftime("%d_%m_%y")
#  timeNow = "22_09_22"
  filename = shareDir + timeNow + "_data.csv"
  if not exists(filename):
    print( "Sleeping until file is ready")

  else:
    df = pd.read_csv(filename)
    df['Hour'] = df['Time']
    for i in range(df.shape[0]):
      try:
        df['Hour'] = df['Hour'].replace(df['Hour'].iloc[i],df['Hour'].iloc[i].split(":")[0])
      except:
        print ("Sad")
    numCols = int(df['Hour'].iloc[-1]) + 1
    colDiv = int(df.shape[0]/numCols)

    avTemp = round(df.groupby('Hour')['Temperature'].mean(), dpT)
    createGraphFile(TGraph, avTemp, numCols, numRows, titleT, RtimeNow, fixedDigitsT, dpT)

    avHumi = round(df.groupby('Hour')['Humidity'].mean(), 2)
    createGraphFile(HGraph, avHumi, numCols, numRows, titleH, RtimeNow, fixedDigitsH, dpH)

    avPres = round(df.groupby('Hour')['Pressure'].mean(), 4)
    createGraphFile(PGraph, avPres, numCols, numRows, titleP, RtimeNow, fixedDigitsP, dpP)

  time.sleep(1800)