@@ -44,12 +44,12 @@

 import os

 import sys

 import signal

-import subprocess

 import multiprocessing

 import time

 import calendar

 import json

 from urllib.request import urlopen

+import rrdbase

    ### ENVIRONMENT ###

@@ -60,7 +60,7 @@ _USE_RADMON_TIMESTAMP = True

    ### DEFAULT RADIATION MONITOR URL ###

 _DEFAULT_RADIATION_MONITOR_URL = \

-    "{your radiation monitor url}"

+    "http://192.168.1.24"

     ### FILE AND FOLDER LOCATIONS ###

@@ -75,10 +75,14 @@ _RRD_FILE = "/home/%s/database/radmonData.rrd" % _USER

     ### GLOBAL CONSTANTS ###

-# max number of failed data requests allowed

-_MAX_FAILED_DATA_REQUESTS = 3

+# maximum number of failed data requests allowed

+_MAX_FAILED_DATA_REQUESTS = 2

+# maximum number of http request retries  allowed

+_MAX_HTTP_RETRIES = 5

+# delay time between http request retries

+_HTTP_RETRY_DELAY = 1.119

 # interval in seconds between data requests

-_DEFAULT_DATA_REQUEST_INTERVAL = 2

+_DEFAULT_DATA_REQUEST_INTERVAL = 5

 # number seconds to wait for a response to HTTP request

 _HTTP_REQUEST_TIMEOUT = 3

@@ -96,12 +100,13 @@ _CHART_HEIGHT = 150

 # turn on or off of verbose debugging information

 verboseMode = False

 debugMode = False

+reportUpdateFails = False

 # The following two items are used for detecting system faults

 # and radiation monitor online or offline status.

 # count of failed attempts to get data from radiation monitor

 failedUpdateCount = 0

-# detected status of radiation monitor device

+httpRetries = 0

 radmonOnline = False

 # status of reset command to radiation monitor

@@ -111,6 +116,9 @@ radiationMonitorUrl = _DEFAULT_RADIATION_MONITOR_URL

 # web update frequency

 dataRequestInterval = _DEFAULT_DATA_REQUEST_INTERVAL

+# rrdtool database interface handler

+rrdb = None

+

   ###  PRIVATE METHODS  ###

 def getTimeStamp():

@@ -120,7 +128,7 @@ def getTimeStamp():

     Returns: string containing the time stamp

     """

     return time.strftime( "%m/%d/%Y %T", time.localtime() )

-##end def

+## end def

 def setStatusToOffline():

     """Set the detected status of the radiation monitor to

@@ -139,7 +147,7 @@ def setStatusToOffline():

     if radmonOnline:

         print('%s radiation monitor offline' % getTimeStamp())

     radmonOnline = False

-##end def

+## end def

 def terminateAgentProcess(signal, frame):

     """Send a message to log when the agent process gets killed

@@ -149,11 +157,13 @@ def terminateAgentProcess(signal, frame):

            signal, frame - dummy parameters

        Returns: nothing

     """

+    # Inform downstream clients by removing output data file.

+    if os.path.exists(_OUTPUT_DATA_FILE):

+       os.remove(_OUTPUT_DATA_FILE)

     print('%s terminating radmon agent process' % \

               (getTimeStamp()))

-    setStatusToOffline()

     sys.exit(0)

-##end def

+## end def

   ###  PUBLIC METHODS  ###

@@ -165,8 +175,9 @@ def getRadiationData(dData):

        Returns: a string containing the radiation data if successful,

                 or None if not successful

     """

-    sUrl = radiationMonitorUrl

+    global httpRetries

+    sUrl = radiationMonitorUrl

     if remoteDeviceReset:

         sUrl += "/reset" # reboot the radiation monitor

     else:

@@ -187,19 +198,31 @@ def getRadiationData(dData):

         # If no response is received from the device, then assume that

         # the device is down or unavailable over the network.  In

         # that case return None to the calling function.

-        if verboseMode:

-            print("%s getRadiationData: %s" % (getTimeStamp(), exError))

-        return False

-    ##end try

+        httpRetries += 1

+

+        if reportUpdateFails:

+            print("%s " % getTimeStamp(), end='')

+        if reportUpdateFails or verboseMode:

+            print("http request failed (%d): %s" % \

+                (httpRetries, exError))

+

+        if httpRetries > _MAX_HTTP_RETRIES:

+            httpRetries = 0

+            return False

+        else:

+            time.sleep(_HTTP_RETRY_DELAY)

+            return getRadiationData(dData)

+    ## end try

     if debugMode:

         print(content)

     if verboseMode:

         print("http request successful: %.4f sec" % requestTime)

+    httpRetries = 0

     dData['content'] = content

     return True

-##end def

+## end def

 def parseDataString(dData):

     """Parse the data string returned by the radiation monitor

@@ -233,7 +256,7 @@ def parseDataString(dData):

     dData['serverMode'] = _SERVER_MODE

     return True

-##end def

+## end def

 def convertData(dData):

     """Convert individual radiation data items as necessary.

@@ -247,26 +270,27 @@ def convertData(dData):

             # device to epoch local time in seconds.

             ts_utc = time.strptime(dData['UTC'], "%H:%M:%S %m/%d/%Y")

             epoch_local_sec = calendar.timegm(ts_utc)

-            dData['ELT'] = epoch_local_sec

         else:

             # Use a timestamp generated by the requesting server (this)

             # instead of the timestamp provided by the radiation monitoring

             # device.  Using the server generated timestamp prevents errors

             # that occur when the radiation monitoring device fails to

             # synchronize with a valid NTP time server.

-            dData['ELT'] = time.time()

+            epoch_local_sec = time.time()

         dData['date'] = \

-            time.strftime("%m/%d/%Y %T", time.localtime(dData['ELT']))      

+            time.strftime("%m/%d/%Y %T", time.localtime(epoch_local_sec))      

         dData['mode'] = dData.pop('Mode').lower()

-        dData['uSvPerHr'] = '%.2f' % float(dData.pop('uSv/hr'))

+        dData['uSvPerHr'] = '%.2f' % float(dData['uSv/hr'])

+        # The rrdtool database stores whole units, so convert uSv to Sv.

+        dData['SvPerHr'] = float(dData.pop('uSv/hr')) * 1.0E-06

     except Exception as exError:

         print("%s data conversion failed: %s" % (getTimeStamp(), exError))

         return False

     return True

-##end def

+## end def

 def writeOutputFile(dData):

     """Write radiation data items to the output data file, formatted as 

@@ -321,124 +345,18 @@ def setRadmonStatus(updateSuccess):

             print('%s radiation monitor online' % getTimeStamp())

             radmonOnline = True

         return

-    elif failedUpdateCount == _MAX_FAILED_DATA_REQUESTS - 1:

+    else:

+        # The last attempt failed, so update the failed attempts

+        # count.

+        failedUpdateCount += 1

+

+    if failedUpdateCount == _MAX_FAILED_DATA_REQUESTS:

         # Max number of failed data requests, so set

         # device status to offline.

         setStatusToOffline()

-    ## end if

-    failedUpdateCount += 1

-##end def

-

-    ### DATABASE FUNCTIONS ###

-

-def updateDatabase(dData):

-    """

-    Update the rrdtool database by executing an rrdtool system command.

-    Format the command using the data extracted from the radiation

-    monitor response.   

-    Parameters: dData - dictionary object containing data items to be

-                        written to the rr database file

-    Returns: True if successful, False otherwise

-    """

-    global remoteDeviceReset

-

-    # The RR database stores whole units, so convert uSv to Sv.

-    SvPerHr = float(dData['uSvPerHr']) * 1.0E-06 

-

-    # Format the rrdtool update command.

-    strCmd = "rrdtool update %s %s:%s:%s" % \

-                       (_RRD_FILE, dData['ELT'], dData['CPM'], SvPerHr)

-    if debugMode:

-        print("%s" % strCmd) # DEBUG

-

-    # Run the command as a subprocess.

-    try:

-        subprocess.check_output(strCmd, shell=True,  \

-                             stderr=subprocess.STDOUT)

-    except subprocess.CalledProcessError as exError:

-        print("%s: rrdtool update failed: %s" % \

-                    (getTimeStamp(), exError.output))

-        if exError.output.find("illegal attempt to update using time") > -1:

-            remoteDeviceReset = True

-            print("%s: rebooting radiation monitor" % (getTimeStamp()))

-        return False

-

-    if verboseMode and not debugMode:

-        print("database update successful")

-

-    return True

-##end def

-

-def createGraph(fileName, dataItem, gLabel, gTitle, gStart,

-                lower, upper, addTrend, autoScale):

-    """Uses rrdtool to create a graph of specified radmon data item.

-       Parameters:

-           fileName - name of file containing the graph

-           dataItem - data item to be graphed

-           gLabel - string containing a graph label for the data item

-           gTitle - string containing a title for the graph

-           gStart - beginning time of the graphed data

-           lower - lower bound for graph ordinate #NOT USED

-           upper - upper bound for graph ordinate #NOT USED

-           addTrend - 0, show only graph data

-                      1, show only a trend line

-                      2, show a trend line and the graph data

-           autoScale - if True, then use vertical axis auto scaling

-               (lower and upper parameters are ignored), otherwise use

-               lower and upper parameters to set vertical axis scale

-       Returns: True if successful, False otherwise

-    """

-    gPath = _CHARTS_DIRECTORY + fileName + ".png"

-    trendWindow = { 'end-1day': 7200,

-                    'end-4weeks': 172800,

-                    'end-12months': 604800 }

- 

-    # Format the rrdtool graph command.

-

-    # Set chart start time, height, and width.

-    strCmd = "rrdtool graph %s -a PNG -s %s -e now -w %s -h %s " \

-             % (gPath, gStart, _CHART_WIDTH, _CHART_HEIGHT)

-   

-    # Set the range and scaling of the chart y-axis.

-    if lower < upper:

-        strCmd  +=  "-l %s -u %s -r " % (lower, upper)

-    elif autoScale:

-        strCmd += "-A "

-    strCmd += "-Y "

-

-    # Set the chart ordinate label and chart title. 

-    strCmd += "-v %s -t %s " % (gLabel, gTitle)

- 

-    # Show the data, or a moving average trend line over

-    # the data, or both.

-    strCmd += "DEF:dSeries=%s:%s:LAST " % (_RRD_FILE, dataItem)

-    if addTrend == 0:

-        strCmd += "LINE1:dSeries#0400ff "

-    elif addTrend == 1:

-        strCmd += "CDEF:smoothed=dSeries,%s,TREND LINE2:smoothed#006600 " \

-                  % trendWindow[gStart]

-    elif addTrend == 2:

-        strCmd += "LINE1:dSeries#0400ff "

-        strCmd += "CDEF:smoothed=dSeries,%s,TREND LINE2:smoothed#006600 " \

-                  % trendWindow[gStart]

-     

-    if debugMode:

-        print("\n%s" % strCmd) # DEBUG

-    

-    # Run the formatted rrdtool command as a subprocess.

-    try:

-        result = subprocess.check_output(strCmd, \

-                     stderr=subprocess.STDOUT,   \

-                     shell=True)

-    except subprocess.CalledProcessError as exError:

-        print("rrdtool graph failed: %s" % (exError.output))

-        return False

-

-    if verboseMode:

-        print("rrdtool graph: %s" % result.decode('utf-8'), end='')

-    return True

+## end def

-##end def

+    ### GRAPH FUNCTIONS ###

 def generateGraphs():

     """Generate graphs for display in html documents.

@@ -448,21 +366,21 @@ def generateGraphs():

     autoScale = False

     # past 24 hours

-    createGraph('24hr_cpm', 'CPM', 'counts\ per\ minute', 

+    rrdb.createAutoGraph('24hr_cpm', 'CPM', 'counts\ per\ minute', 

                 'CPM\ -\ Last\ 24\ Hours', 'end-1day', 0, 0, 2, autoScale)

-    createGraph('24hr_svperhr', 'SvperHr', 'Sv\ per\ hour',

+    rrdb.createAutoGraph('24hr_svperhr', 'SvperHr', 'Sv\ per\ hour',

                 'Sv/Hr\ -\ Last\ 24\ Hours', 'end-1day', 0, 0, 2, autoScale)

     # past 4 weeks

-    createGraph('4wk_cpm', 'CPM', 'counts\ per\ minute',

+    rrdb.createAutoGraph('4wk_cpm', 'CPM', 'counts\ per\ minute',

                 'CPM\ -\ Last\ 4\ Weeks', 'end-4weeks', 0, 0, 2, autoScale)

-    createGraph('4wk_svperhr', 'SvperHr', 'Sv\ per\ hour',

+    rrdb.createAutoGraph('4wk_svperhr', 'SvperHr', 'Sv\ per\ hour',

                 'Sv/Hr\ -\ Last\ 4\ Weeks', 'end-4weeks', 0, 0, 2, autoScale)

     # past year

-    createGraph('12m_cpm', 'CPM', 'counts\ per\ minute',

+    rrdb.createAutoGraph('12m_cpm', 'CPM', 'counts\ per\ minute',

                 'CPM\ -\ Past\ Year', 'end-12months', 0, 0, 2, autoScale)

-    createGraph('12m_svperhr', 'SvperHr', 'Sv\ per\ hour',

+    rrdb.createAutoGraph('12m_svperhr', 'SvperHr', 'Sv\ per\ hour',

                 'Sv/Hr\ -\ Past\ Year', 'end-12months', 0, 0, 2, autoScale)

-##end def

+## end def

 def getCLarguments():

     """Get command line arguments.  There are four possible arguments

@@ -473,7 +391,7 @@ def getCLarguments():

        Returns: nothing

     """

     global verboseMode, debugMode, dataRequestInterval, \

-           radiationMonitorUrl

+           radiationMonitorUrl, reportUpdateFails

     index = 1

     while index < len(sys.argv):

@@ -482,8 +400,16 @@ def getCLarguments():

         elif sys.argv[index] == '-d':

             verboseMode = True

             debugMode = True

-        elif sys.argv[index] == '-t':

-            dataRequestInterval = abs(int(sys.argv[index + 1]))

+        elif sys.argv[index] == '-r':

+            reportUpdateFails = True

+

+        # Update period and url options

+        elif sys.argv[index] == '-p':

+            try:

+                dataRequestInterval = abs(float(sys.argv[index + 1]))

+            except:

+                print("invalid polling period")

+                exit(-1)

             index += 1

         elif sys.argv[index] == '-u':

             radiationMonitorUrl = sys.argv[index + 1]

@@ -492,42 +418,49 @@ def getCLarguments():

             index += 1

         else:

             cmd_name = sys.argv[0].split('/')

-            print("Usage: %s [-d] [-t seconds] [-u url}" % cmd_name[-1])

+            print("Usage: %s [-d] [-p seconds] [-u url}" % cmd_name[-1])

             exit(-1)

         index += 1

-##end def

+## end def

-def main():

+def setup():

     """Handles timing of events and acts as executive routine managing

        all other functions.

        Parameters: none

        Returns: nothing

     """

-    signal.signal(signal.SIGTERM, terminateAgentProcess)

-    signal.signal(signal.SIGINT, terminateAgentProcess)

-

-    print('===================')

-    print('%s starting up radmon agent process' % \

-                  (getTimeStamp()))

-

-    # last time output JSON file updated

-    lastDataRequestTime = -1

-    # last time charts generated

-    lastChartUpdateTime = - 1

-    # last time the rrdtool database updated

-    lastDatabaseUpdateTime = -1

+    global rrdb

     ## Get command line arguments.

     getCLarguments()

+    print('====================================================')

+    print('%s starting up radmon agent process' % \

+                  (getTimeStamp()))

+

     ## Exit with error if rrdtool database does not exist.

     if not os.path.exists(_RRD_FILE):

         print('rrdtool database does not exist\n' \

               'use createRadmonRrd script to ' \

               'create rrdtool database\n')

         exit(1)

- 

-    ## main loop

+

+    signal.signal(signal.SIGTERM, terminateAgentProcess)

+    signal.signal(signal.SIGINT, terminateAgentProcess)

+

+    # Define object for calling rrdtool database functions.

+    rrdb = rrdbase.rrdbase( _RRD_FILE, _CHARTS_DIRECTORY, _CHART_WIDTH, \

+                            _CHART_HEIGHT, verboseMode, debugMode )

+## end def

+

+def loop():

+     # last time output JSON file updated

+    lastDataRequestTime = -1

+    # last time charts generated

+    lastChartUpdateTime = - 1

+    # last time the rrdtool database updated

+    lastDatabaseUpdateTime = -1

+

     while True:

         currentTime = time.time() # get current time in seconds

@@ -558,7 +491,8 @@ def main():

                            _DATABASE_UPDATE_INTERVAL):   

                 lastDatabaseUpdateTime = currentTime

                 ## Update the round robin database with the parsed data.

-                result = updateDatabase(dData)

+                result = rrdb.updateDatabase(dData['date'], \

+                             dData['CPM'], dData['SvPerHr'])

             # Set the radmon status to online or offline depending on the

             # success or failure of the above operations.

@@ -586,9 +520,9 @@ def main():

         if remainingTime > 0.0:

             time.sleep(remainingTime)

     ## end while

-    return

 ## end def

 if __name__ == '__main__':

-    main()

+    setup()

+    loop()

new file mode 100644

@@ -0,0 +1,290 @@

+#!/usr/bin/python3 -u

+#

+# Module: rrdbase.py

+#

+# Description: This module acts as an interface between the agent module

+# the rrdtool command line app.  Interface functions provide for updating

+# the rrdtool database and for creating charts. This module acts as a

+# library module that can be imported into and called from other

+# Python programs.

+#     

+# Copyright 2021 Jeff Owrey

+#    This program is free software: you can redistribute it and/or modify

+#    it under the terms of the GNU General Public License as published by

+#    the Free Software Foundation, either version 3 of the License, or

+#    (at your option) any later version.

+#

+#    This program is distributed in the hope that it will be useful,

+#    but WITHOUT ANY WARRANTY; without even the implied warranty of

+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

+#    GNU General Public License for more details.

+#

+#    You should have received a copy of the GNU General Public Licensef

+#    along with this program.  If not, see http://www.gnu.org/license.

+#

+# Revision History

+#   * v30 17 Oct 2021 by J L Owrey; first release

+#

+#2345678901234567890123456789012345678901234567890123456789012345678901234567890

+

+import subprocess

+import time

+

+class rrdbase:

+

+    def __init__(self, rrdFile, chartsDirectory, chartWidth, \

+                 chartHeight, verboseMode, debugMode):

+        """Initialize instance variables that remain constant throughout

+           the life of this object instance.  These items are set by the

+           calling module.

+           Parameters:

+             rrdFile - the path to the rrdtool database file

+             chartsDirectory - the path to the folder to contain charts

+             chartWidth - the width of charts in pixels

+             chartHeight - the height of charts  in pixels

+             verboseMode - verbose output

+             debugMode - full debug output

+           Returns: nothing

+        """

+        self.rrdFile = rrdFile

+        self.chartsDirectory = chartsDirectory

+        self.chartWidth = chartWidth

+        self.chartHeight = chartHeight

+        self.verboseMode = verboseMode

+        self.debugMode = debugMode

+    ## end def

+

+    def getTimeStamp():

+        """Sets the error message time stamp to the local system time.

+           Parameters: none

+           Returns: string containing the time stamp

+        """

+        return time.strftime('%m/%d/%Y %H:%M:%S', time.localtime())

+    ## end def

+

+    def getEpochSeconds(sTime):

+        """Converts the time stamp supplied in the weather data string

+           to seconds since 1/1/1970 00:00:00.

+           Parameters: 

+               sTime - the time stamp to be converted must be formatted

+                       as %m/%d/%Y %H:%M:%S

+           Returns: epoch seconds

+        """

+        try:

+            t_sTime = time.strptime(sTime, '%m/%d/%Y %H:%M:%S')

+        except Exception as exError:

+            print('%s getEpochSeconds: %s' % \

+                  (rrdbase.getTimeStamp(), exError))

+            return None

+        tSeconds = int(time.mktime(t_sTime))

+        return tSeconds

+    ## end def

+

+    def updateDatabase(self, *tData):

+        """Updates the rrdtool round robin database with data supplied in

+           the weather data string.

+           Parameters:

+               tData - a tuple object containing the data items to be written

+                       to the rrdtool database

+           Returns: True if successful, False otherwise

+        """

+        # Get the time stamp supplied with the data.  This must always be

+        # the first element of the tuple argument passed to this function.

+        tData = list(tData)

+        date = tData.pop(0)

+        # Convert the time stamp to unix epoch seconds.

+        try:

+            time = rrdbase.getEpochSeconds(date)

+        # Trap any data conversion errors.

+        except Exception as exError:

+            print('%s updateDatabase error: %s' % \

+                  (rrdbase.getTimeStamp(), exError))

+            return False

+

+        # Create the rrdtool command for updating the rrdtool database.  Add a

+        # '%s' format specifier for each data item remaining in tData. 

+        # Note that this is the list remaining after the

+        # first item (the date) has been removed by the above code.

+        strFmt = 'rrdtool update %s %s' + ':%s' * len(tData)

+        strCmd = strFmt % ((self.rrdFile, time,) + tuple(tData))

+

+        if self.debugMode:

+            print('%s' % strCmd) # DEBUG

+

+        # Run the formatted command as a subprocess.

+        try:

+            subprocess.check_output(strCmd, stderr=subprocess.STDOUT, \

+                                    shell=True)

+        except subprocess.CalledProcessError as exError:

+            print('%s rrdtool update failed: %s' % \

+                  (rrdbase.getTimeStamp(), exError.output.decode('utf-8')))

+            return False

+

+        if self.verboseMode and not self.debugMode:

+            print('database update successful')

+

+        return True

+    ## end def

+

+    def createWeaGraph(self, fileName, dataItem, gLabel, gTitle, gStart,

+                        lower, upper, addTrend, autoScale):

+        """Uses rrdtool to create a graph of specified weather data item.

+           Graphs are for display in html documents.

+           Parameters:

+               fileName - name of graph file

+               dataItem - the weather data item to be graphed

+               gLabel - string containing a graph label for the data item

+               gTitle - string containing a title for the graph

+               gStart - time from now when graph starts

+               lower - lower bound for graph ordinate

+               upper - upper bound for graph ordinate

+               addTrend - 0, show only graph data

+                          1, show only a trend line

+                          2, show a trend line and the graph data

+               autoScale - if True, then use vertical axis auto scaling

+                   (lower and upper parameters are ignored), otherwise use

+                   lower and upper parameters to set vertical axis scale

+           Returns: True if successful, False otherwise

+        """

+        gPath = self.chartsDirectory + fileName + '.png'

+

+        # Format the rrdtool graph command.

+

+        # Set chart start time, height, and width.

+        strCmd = 'rrdtool graph %s -a PNG -s %s -e \'now\' -w %s -h %s ' \

+                 % (gPath, gStart, self.chartWidth, self.chartHeight)

+       

+        # Set the range and scaling of the chart y-axis.

+        if lower < upper:

+            strCmd  +=  '-l %s -u %s -r ' % (lower, upper)

+        elif autoScale:

+            strCmd += '-A '

+        strCmd += '-Y '

+

+        # Set the chart ordinate label and chart title. 

+        strCmd += '-v %s -t %s ' % (gLabel, gTitle)

+

+        # Show the data, or a moving average trend line, or both.

+        strCmd += 'DEF:dSeries=%s:%s:AVERAGE ' % (self.rrdFile, dataItem)

+        if addTrend == 0:

+            strCmd += 'LINE1:dSeries#0400ff '

+        elif addTrend == 1:

+            strCmd += 'CDEF:smoothed=dSeries,86400,TREND LINE2:smoothed#006600 '

+        elif addTrend == 2:

+            strCmd += 'LINE1:dSeries#0400ff '

+            strCmd += 'CDEF:smoothed=dSeries,86400,TREND LINE2:smoothed#006600 '

+

+        # if wind plot show color coded wind direction

+        if dataItem == 'windspeedmph':

+            strCmd += 'DEF:wDir=%s:winddir:AVERAGE ' % (_RRD_FILE)

+            strCmd += 'VDEF:wMax=dSeries,MAXIMUM '

+            strCmd += 'CDEF:wMaxScaled=dSeries,0,*,wMax,+,-0.15,* '

+            strCmd += 'CDEF:ndir=wDir,337.5,GE,wDir,22.5,LE,+,wMaxScaled,0,IF '

+            strCmd += 'CDEF:nedir=wDir,22.5,GT,wDir,67.5,LT,*,wMaxScaled,0,IF '

+            strCmd += 'CDEF:edir=wDir,67.5,GE,wDir,112.5,LE,*,wMaxScaled,0,IF '

+            strCmd += 'CDEF:sedir=wDir,112.5,GT,wDir,157.5,LT,*,wMaxScaled,0,IF '

+            strCmd += 'CDEF:sdir=wDir,157.5,GE,wDir,202.5,LE,*,wMaxScaled,0,IF '

+            strCmd += 'CDEF:swdir=wDir,202.5,GT,wDir,247.5,LT,*,wMaxScaled,0,IF '

+            strCmd += 'CDEF:wdir=wDir,247.5,GE,wDir,292.5,LE,*,wMaxScaled,0,IF '

+            strCmd += 'CDEF:nwdir=wDir,292.5,GT,wDir,337.5,LT,*,wMaxScaled,0,IF '

+      

+            strCmd += 'AREA:ndir#0000FF:N '    # Blue

+            strCmd += 'AREA:nedir#1E90FF:NE '  # DodgerBlue

+            strCmd += 'AREA:edir#00FFFF:E '    # Cyan

+            strCmd += 'AREA:sedir#00FF00:SE '  # Lime

+            strCmd += 'AREA:sdir#FFFF00:S '    # Yellow

+            strCmd += 'AREA:swdir#FF8C00:SW '  # DarkOrange 

+            strCmd += 'AREA:wdir#FF0000:W '    # Red

+            strCmd += 'AREA:nwdir#FF00FF:NW '  # Magenta

+        ##end if

+        

+        if self.debugMode:

+            print('%s' % strCmd) # DEBUG

+        

+        # Run the formatted rrdtool command as a subprocess.

+        try:

+            result = subprocess.check_output(strCmd, \

+                         stderr=subprocess.STDOUT,   \

+                         shell=True)

+        except subprocess.CalledProcessError as exError:

+            print('rrdtool graph failed: %s' % (exError.output.decode('utf-8')))

+            return False

+

+        if self.verboseMode:

+            print('rrdtool graph: %s' % result.decode('utf-8')) #, end='')

+

+        return True

+    ## end def

+

+    def createAutoGraph(self, fileName, dataItem, gLabel, gTitle, gStart,

+                    lower, upper, addTrend, autoScale):

+        """Uses rrdtool to create a graph of specified radmon data item.

+           Parameters:

+               fileName - name of file containing the graph

+               dataItem - data item to be graphed

+               gLabel - string containing a graph label for the data item

+               gTitle - string containing a title for the graph

+               gStart - beginning time of the graphed data

+               lower - lower bound for graph ordinate #NOT USED

+               upper - upper bound for graph ordinate #NOT USED

+               addTrend - 0, show only graph data

+                          1, show only a trend line

+                          2, show a trend line and the graph data

+               autoScale - if True, then use vertical axis auto scaling

+                   (lower and upper parameters are ignored), otherwise use

+                   lower and upper parameters to set vertical axis scale

+           Returns: True if successful, False otherwise

+        """

+        gPath = self.chartsDirectory + fileName + ".png"

+        trendWindow = { 'end-1day': 7200,

+                        'end-4weeks': 172800,

+                        'end-12months': 604800 }

+     

+        # Format the rrdtool graph command.

+

+        # Set chart start time, height, and width.

+        strCmd = "rrdtool graph %s -a PNG -s %s -e now -w %s -h %s " \

+                 % (gPath, gStart, self.chartWidth, self.chartHeight)

+       

+        # Set the range and scaling of the chart y-axis.

+        if lower < upper:

+            strCmd  +=  "-l %s -u %s -r " % (lower, upper)

+        elif autoScale:

+            strCmd += "-A "

+        strCmd += "-Y "

+

+        # Set the chart ordinate label and chart title. 

+        strCmd += "-v %s -t %s " % (gLabel, gTitle)

+     

+        # Show the data, or a moving average trend line over

+        # the data, or both.

+        strCmd += "DEF:dSeries=%s:%s:LAST " % (self.rrdFile, dataItem)

+        if addTrend == 0:

+            strCmd += "LINE1:dSeries#0400ff "

+        elif addTrend == 1:

+            strCmd += "CDEF:smoothed=dSeries,%s,TREND LINE2:smoothed#006600 " \

+                      % trendWindow[gStart]

+        elif addTrend == 2:

+            strCmd += "LINE1:dSeries#0400ff "

+            strCmd += "CDEF:smoothed=dSeries,%s,TREND LINE2:smoothed#006600 " \

+                      % trendWindow[gStart]

+         

+        if self.debugMode:

+            print("%s" % strCmd) # DEBUG

+        

+        # Run the formatted rrdtool command as a subprocess.

+        try:

+            result = subprocess.check_output(strCmd, \

+                         stderr=subprocess.STDOUT,   \

+                         shell=True)

+        except subprocess.CalledProcessError as exError:

+            print("rrdtool graph failed: %s" % (exError.output.decode('utf-8')))

+            return False

+

+        if self.verboseMode:

+            print("rrdtool graph: %s" % result.decode('utf-8')) #, end='')

+        return True

+

+    ##end def

+## end class

+