testSchainSpecExp.py
84 lines
| 2.3 KiB
| text/x-python
|
PythonLexer
/ schainpy2 / testSchainSpecExp.py
|
r126 | ''' | |
$Author$ | |||
$Id$ | |||
''' | |||
|
r122 | ||
import os, sys | |||
import time, datetime | |||
path = os.path.split(os.getcwd())[0] | |||
sys.path.append(path) | |||
|
r124 | ||
|
r144 | from Data.JROData import Spectra | |
|
r122 | from IO.SpectraIO import * | |
|
r124 | from Processing.SpectraProcessor import * | |
|
r122 | ||
class TestSChain: | |||
def __init__(self): | |||
self.setValues() | |||
self.createObjects() | |||
self.testSChain() | |||
def setValues(self): | |||
|
r126 | # 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" | |||
|
r122 | ||
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) | |||
|
r124 | ||
# paramatros para Escritura de Pdata | |||
|
r126 | self.wrpath = "/home/daniel/RadarData/test_wr2" | |
|
r124 | self.blocksPerFile = 5 | |
|
r126 | ||
|
r124 | ||
|
r122 | ||
def createObjects(self): | |||
self.readerObj = SpectraReader() | |||
|
r124 | self.specObj1 = self.readerObj.setup( | |
|
r122 | path = self.path, | |
startDate = self.startDate, | |||
endDate = self.endDate, | |||
startTime = self.startTime, | |||
endTime = self.endTime, | |||
expLabel = '', | |||
online = 0) | |||
|
r126 | ||
|
r124 | self.specObjProc = SpectraProcessor() | |
self.specObj2 = self.specObjProc.setup(dataInObj = self.specObj1) | |||
|
r122 | ||
def testSChain(self): | |||
ini = time.time() | |||
while(True): | |||
self.readerObj.getData() | |||
|
r124 | ||
self.specObjProc.init() | |||
|
r126 | self.specObjProc.writeData(self.wrpath,self.blocksPerFile) | |
# | |||
|
r122 | if self.readerObj.flagNoMoreFiles: | |
break | |||
if self.readerObj.flagIsNewBlock: | |||
print 'Block No %04d, Time: %s' %(self.readerObj.nTotalBlocks, | |||
|
r124 | datetime.datetime.fromtimestamp(self.readerObj.basicHeaderObj.utc)) | |
|
r122 | ||
if __name__ == '__main__': | |||
TestSChain() |