source: pvrrd/rrdCreate.py @ 206

#!/usr/bin/env python

'''
 create RRD databases in this directory for the PVs named
'''
########### SVN repository information ###################
# $Date: 2010-08-18 20:28:25 +0000 (Wed, 18 Aug 2010) $
# $Author: jemian $
# $Revision: 206 $
# $HeadURL$
# $Id: rrdCreate.py 206 2010-08-18 20:28:25Z jemian $
########### SVN repository information ###################

#**************************************************************************

import xmlSupport
import rrdtool
import os.path

#**************************************************************************

def rrdcreate(rrd, args):
    '''format & execute rrdtool.create() on the argument list'''
    cmd = "rrdtool.create("
    cmd += "'" + rrd + "'"
    for item in args:
        cmd += ", '" + item.strip() + "'"
    cmd += ")"
    eval(cmd)

#**************************************************************************

def createdb(rrdFile, props, pvEntry):
    '''define the RRD for the given PV'''
    arr = []
    arr.append('--step')
    arr.append(props['spans']['baseStep'])
    rrd = props['rrd']
    # use a generic variable name (EPICS) since the file name is descriptive
    str = 'DS:EPICS'
    str += ':' + rrd['DST']
    str += ':' + rrd['heartbeat']
    str += ':' + pvEntry['min']
    str += ':' + pvEntry['max']
    arr.append(str)
    for item in ('AVERAGE', 'MIN', 'MAX'):
        for spanName in props['spans']['names']:
            span = props['spans'][spanName]
            str = 'RRA'
            str += ':' + item
            for it in ('xff', 'steps', 'rows'):
                str += ':' + span[it]
            arr.append(str)
    rrdcreate(rrdFile, arr)

#**************************************************************************

cfg = xmlSupport.readConfigurationXML('/home/joule/WEB33/www/rrd')

for pvEntry in cfg['pvList']:
    rrd = os.path.join(
      cfg['properties']['subdirs']['rrd_file_dir'],
      pvEntry['fileRoot'] + '.rrd'
    )
    # only create those RRD files that do not already exist
    if (os.path.exists(rrd) == False):
        print "creating " + rrd
        createdb(rrd, cfg['properties'], pvEntry)