HskTestSvr.py

#!/usr/local/bin/python
#
#                               Copyright 2004
#                                     by
#                        The Board of Trustees of the
#                     Leland Stanford Junior University.
#                            All rights reserved.
#

__facility__ = "Online"
__abstract__ = "GLAST LAT Housekeeping server infrastructure"
__author__   = "Jim Panetta <panetta@slac.stanford.edu> SLAC - GLAST I&T"
__date__     = "07/28/04"
__version__  = "$Revision: 1.3 $"
__release__  = "$Name: R04-12-00 $"
__credits__  = "SLAC"

import LATTE.copyright_SLAC
import logging

from LATTE.monitoring              import *  
from LATTE.client.gCmdCli          import CmdCli
from LATTE.database.gLAT           import GLAT
from LATTE.database.gHSK           import GHSK
from HskCollector import *
from HskRetriever import *


latSchema = "c:/panetta/LATTE/repos/hskAEM.xml"
hskSchema = "c:/panetta/LATTE/repos/hskTestSchema.xml"
dataFile  = "c:/TEMP/database.txt"
udpServerName='testTrendingServer'
udpServerAddr='54320@239.255.1.14'


def testCollector():
  logging.basicConfig()
  logging.root.setLevel(logging.DEBUG)
  
  cmdCli = CmdCli()
  cmdCli.connect("localhost")
  
  collector = HskCollector(cmdCli)
  
  # set up LAT schema
  latDB = GLAT(cmdCli)
  latDB.readSchema(latSchema)
  
  # set up HSK schema
  hskDB = GHSK(cmdCli)
  hskDB.readSchema(hskSchema)
  hskDB.applyConfig(None)
  
  from HskRetriever import HskLatRetriever
  firstRetriever = HskLatRetriever(latDB)
  collector.addRetriever("HSK", firstRetriever)
  
  from LATTE.monitoring.HskRecorder import HskAlarmRecorder
  firstRecorder = HskAlarmRecorder(hskDB)
  collector.addRecorder(firstRecorder)
  
  from LATTE.monitoring.HskRecorder import HskFileRecorder
  secondRecorder = HskFileRecorder(hskDB, dataFile)
  collector.addRecorder(secondRecorder)
  
  from LATTE.monitoring.Recorder import UDPRecorder
  thirdRecorder=UDPRecorder()
  thirdRecorder.startUDPServer(udpServerName,udpServerAddr)
  collector.addRecorder(thirdRecorder)
  
  # from LATTE.monitoring.HskRecorder import HskAlarmRecorder
  # thirdRecorder = HskAlarmRecorder(hskDB)
  # collector.addRecorder(thirdRecorder)
  
  print "Collector delay: ", collector.getDelay()/10, " seconds"
  collector.setAcquiring(True)
  
  from time import sleep
  try:
    while 1:
      sleep(.1)
  except Exception, e:
    collector.shutdown()

  
  
  
  
  
  
  
if __name__ == '__main__':
  testCollector()

---