|
|
'''
|
|
|
|
|
|
$Author: murco $
|
|
|
$Id: testSchainSpecExp.py 147 2012-10-30 22:50:56Z murco $
|
|
|
'''
|
|
|
|
|
|
import os, sys
|
|
|
import time, datetime
|
|
|
|
|
|
path = os.path.split(os.getcwd())[0]
|
|
|
sys.path.append(path)
|
|
|
|
|
|
|
|
|
from Data.JROData import Spectra
|
|
|
from IO.SpectraIO import *
|
|
|
from Processing.SpectraProcessor import *
|
|
|
|
|
|
|
|
|
|
|
|
class TestSChain:
|
|
|
|
|
|
def __init__(self):
|
|
|
self.setValues()
|
|
|
self.createObjects()
|
|
|
self.testSChain()
|
|
|
|
|
|
def setValues(self):
|
|
|
# self.path = "/Users/jro/Documents/RadarData/MST_ISR/MST"
|
|
|
## self.path = "/home/roj-idl71/Data/RAWDATA/IMAGING"
|
|
|
# self.path = "/Users/danielangelsuarezmunoz/Data/EW_Drifts"
|
|
|
# self.path = "/Users/danielangelsuarezmunoz/Data/IMAGING"
|
|
|
self.path = "/home/daniel/RadarData/IMAGING"
|
|
|
|
|
|
self.startDate = datetime.date(2012,3,1)
|
|
|
self.endDate = datetime.date(2012,3,30)
|
|
|
|
|
|
self.startTime = datetime.time(0,0,0)
|
|
|
self.endTime = datetime.time(14,1,1)
|
|
|
|
|
|
# paramatros para Escritura de Pdata
|
|
|
self.wrpath = "/home/daniel/RadarData/test_wr2"
|
|
|
self.blocksPerFile = 5
|
|
|
|
|
|
|
|
|
|
|
|
def createObjects(self):
|
|
|
|
|
|
self.readerObj = SpectraReader()
|
|
|
|
|
|
self.specObj1 = self.readerObj.setup(
|
|
|
path = self.path,
|
|
|
startDate = self.startDate,
|
|
|
endDate = self.endDate,
|
|
|
startTime = self.startTime,
|
|
|
endTime = self.endTime,
|
|
|
expLabel = '',
|
|
|
online = 0)
|
|
|
|
|
|
self.specObjProc = SpectraProcessor()
|
|
|
|
|
|
self.specObj2 = self.specObjProc.setup(dataInObj = self.specObj1)
|
|
|
|
|
|
|
|
|
|
|
|
def testSChain(self):
|
|
|
|
|
|
ini = time.time()
|
|
|
|
|
|
while(True):
|
|
|
self.readerObj.getData()
|
|
|
|
|
|
self.specObjProc.init()
|
|
|
|
|
|
self.specObjProc.writeData(self.wrpath,self.blocksPerFile)
|
|
|
#
|
|
|
if self.readerObj.flagNoMoreFiles:
|
|
|
break
|
|
|
|
|
|
if self.readerObj.flagIsNewBlock:
|
|
|
print 'Block No %04d, Time: %s' %(self.readerObj.nTotalBlocks,
|
|
|
datetime.datetime.fromtimestamp(self.readerObj.basicHeaderObj.utc))
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
TestSChain()
|
