TestSpectraWriteChain.py
72 lines
| 2.4 KiB
| text/x-python
|
PythonLexer
/ schainpy / TestSpectraWriteChain.py
Victor Sarmiento
|
r69 | ''' | |
| Created on 20/03/2012 | |||
| @author $Author$ | |||
| @version $Id$ | |||
| ''' | |||
| import os, sys | |||
| import time, datetime | |||
| from Model.Voltage import Voltage | |||
| from IO.VoltageIO import * | |||
| from Graphics.VoltagePlot import Osciloscope | |||
| from Model.Spectra import Spectra | |||
| from IO.SpectraIO import * | |||
| from Graphics.SpectraPlot import Spectrum | |||
| class TestSChain(): | |||
| def __init__(self): | |||
| self.setValues() | |||
| self.createObjects() | |||
| self.testSChain() | |||
| pass | |||
| def setValues(self): | |||
| self.srcPath = "/home/valentin/Tmp/RAWDATA" | |||
| self.dstPath = "/home/valentin/Tmp/RAWDATA2" | |||
| self.startDateTime = datetime.datetime(2009,11,1,00,00,0) #4 | |||
| self.endDateTime = datetime.datetime(2009,11,30,18,10,0) | |||
| def createObjects(self): | |||
| self.Obj = Spectra() | |||
| self.readerObj = SpectraReader(self.Obj) | |||
| self.writerObj = SpectraWriter(self.Obj) | |||
| self.plotObj = Spectrum(self.Obj) | |||
| if not( self.readerObj.setup(self.srcPath, self.startDateTime, self.endDateTime, expLabel='', online =0) ): | |||
| sys.exit(0) | |||
| if not( self.writerObj.setup(path=self.dstPath) ): sys.exit(0) | |||
| def testSChain(self): | |||
| ini = time.time() | |||
| while(True): | |||
| if self.readerObj.getData(): | |||
| self.plotObj.plotData( zmin=35, zmax=100, showColorbar=True, showPowerProfile=True) | |||
| ################################################################################### | |||
| #time.sleep( 2 ) | |||
| self.writerObj.putData() | |||
| ################################################################################### | |||
| if self.readerObj.flagNoMoreFiles: | |||
| break | |||
Miguel Valdez
|
r89 | if self.readerObj.flagIsNewBlock and self.readerObj.nTotalBlocks: | |
| print 'Block No %04d, Time: %s' %(self.readerObj.nTotalBlocks, | |||
|
Victor Sarmiento
|
r69 | datetime.datetime.fromtimestamp(self.readerObj.m_BasicHeader.utc)) | |
| #=============================================================== | |||
| # fin = time.time() | |||
| # print 'Tiempo de un bloque leido y escrito: [%6.5f]' %(fin - ini) | |||
| # ini = time.time() | |||
| #=============================================================== | |||
| #time.sleep(0.5) | |||
| self.plotObj.end() | |||
| if __name__ == '__main__': | |||
| TestSChain() |