jacktotalrunner.py
143 lines
| 5.7 KiB
| text/x-python
|
PythonLexer
ebocanegra
|
r965 | import os, sys | ||
| from pytz import timezone | ||||
| path = os.path.dirname(os.getcwd()) | ||||
| path = os.path.dirname(path) | ||||
| print path | ||||
| sys.path.insert(0, path) # Para usar las librerias del eclipse. | ||||
| from schainpy.controller import Project | ||||
| # from __main__ import time | ||||
| #path = os.path.split(os.getcwd())[0] | ||||
| #sys.path.append(path) | ||||
| # import scipy.io as sio | ||||
| # import pprint | ||||
| # import numpy | ||||
| # import time | ||||
| # import os | ||||
| # import h5py | ||||
| # import re | ||||
| # import tables | ||||
| # | ||||
| # from model.data.jrodata import * | ||||
| # from model.proc.jroproc_base import ProcessingUnit, Operation | ||||
| # from model.io.jroIO_base import * | ||||
| # controllerObj = Project() | ||||
| # controllerObj.setup(id = '191', name='test01', description=desc) | ||||
| #from controller import * | ||||
| desc = "DBS Experiment Test" | ||||
| filename = "DBStest.xml" | ||||
| controllerObj = Project() | ||||
| controllerObj.setup(id = '191', name='test01', description=desc) | ||||
| #path = 'F:\CIRI Data\processed' | ||||
| #path='/media/4B514E8903EBC487/CIRI Data/processed' | ||||
| #path='/home/ciri/ciri_online' | ||||
| #offline program | ||||
| #path='/home/ciri/.gvfs/SFTP for radar on 192.168.1.161/media/dataswap/huancayo/20150701/processed' | ||||
| #online program | ||||
| path='/home/ciri/.gvfs/SFTP for radar on 192.168.1.161/media/dataswap/huancayo/processed' | ||||
| #pathFigure = 'C:\Users\jdk5273\Documents\LiClipseWorkspace' | ||||
| pathFigure='/home/ciri/Pictures/ciri' | ||||
| xmin = '0' | ||||
| xmax = '24' | ||||
| startTime = '00:00:00' | ||||
| remotefolder = "/home/wmaster/graficos" | ||||
| readUnitConfObj = controllerObj.addReadUnit(datatype='matoffReader', | ||||
| path=path, | ||||
| startDate='2015/05/30', | ||||
| endDate='2015/05/30', | ||||
| startTime=startTime, | ||||
| endTime='23:59:59', | ||||
| online=1, | ||||
| delay=5, | ||||
| walk=0) | ||||
| procUnitConfObj1 = controllerObj.addProcUnit(datatype='SpectraProc', inputId=readUnitConfObj.getId()) | ||||
| # opObj14 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other') | ||||
| # opObj14.addParameter(name='id', value='1', format='int') | ||||
| # opObj14.addParameter(name='wintitle', value='Con interf', format='str') | ||||
| # opObj14.addParameter(name='save', value='0', format='bool') | ||||
| # opObj14.addParameter(name='figpath', value=pathFigure, format='str') | ||||
| opObj11 = procUnitConfObj1.addOperation(name='IncohInt', optype='other') | ||||
| opObj11.addParameter(name='n', value='60', format='int') | ||||
| opObj14 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other') | ||||
| opObj14.addParameter(name='id', value='2', format='int') | ||||
| opObj14.addParameter(name='wintitle', value='Con interf', format='str') | ||||
| opObj14.addParameter(name='save', value='1', format='bool') | ||||
| opObj14.addParameter(name='figpath', value=pathFigure, format='str') | ||||
| opObj14.addParameter(name='zmin', value='-30', format='int') | ||||
| opObj14.addParameter(name='zmax', value='0', format='int') | ||||
| opObj14.addParameter(name='exp_code', value='29', format='int') | ||||
| opObj14.addParameter(name='wr_period', value='1', format='int') | ||||
| opObj14.addParameter(name='save', value='1', format='int') | ||||
| opObj14.addParameter(name='ftp', value='1', format='int') | ||||
| opObj14 = procUnitConfObj1.addOperation(name='CrossSpectraPlot', optype='other') | ||||
| opObj14.addParameter(name='id', value='4', format='int') | ||||
| opObj14.addParameter(name='wintitle', value='Con interf', format='str') | ||||
| opObj14.addParameter(name='phase_cmap', value='jet', format='str') | ||||
| opObj14.addParameter(name='save', value='1', format='bool') | ||||
| opObj14.addParameter(name='figpath', value=pathFigure, format='str') | ||||
| opObj14.addParameter(name='zmin', value='-30', format='int') | ||||
| opObj14.addParameter(name='zmax', value='0', format='int') | ||||
| opObj14.addParameter(name='exp_code', value='29', format='int') | ||||
| opObj14.addParameter(name='wr_period', value='1', format='int') | ||||
| opObj14.addParameter(name='save', value='1', format='int') | ||||
| opObj14.addParameter(name='ftp', value='1', format='int') | ||||
| opObj12 = procUnitConfObj1.addOperation(name='RTIPlot', optype='other') | ||||
| opObj12.addParameter(name='id', value='3', format='int') | ||||
| opObj12.addParameter(name='wintitle', value='RTI Plot', format='str') | ||||
| opObj12.addParameter(name='save', value='1', format='bool') | ||||
| opObj12.addParameter(name='figpath', value = pathFigure, format='str') | ||||
| opObj12.addParameter(name='xmin', value=xmin, format='float') | ||||
| opObj12.addParameter(name='xmax', value=xmax, format='float') | ||||
| opObj12.addParameter(name='zmin', value='-30', format='int') | ||||
| opObj12.addParameter(name='zmax', value='0', format='int') | ||||
| opObj12.addParameter(name='exp_code', value='29', format='int') | ||||
| opObj12.addParameter(name='wr_period', value='1', format='int') | ||||
| opObj12.addParameter(name='save', value='1', format='int') | ||||
| opObj12.addParameter(name='ftp', value='1', format='int') | ||||
| # | ||||
| procUnitConfObj2 = controllerObj.addProcUnit(name='SendToServer') | ||||
| procUnitConfObj2.addParameter(name='server', value='jro-app.igp.gob.pe', format='str') | ||||
| procUnitConfObj2.addParameter(name='username', value='wmaster', format='str') | ||||
| procUnitConfObj2.addParameter(name='password', value='mst2010vhf', format='str') | ||||
| procUnitConfObj2.addParameter(name='localfolder', value=pathFigure, format='str') | ||||
| procUnitConfObj2.addParameter(name='remotefolder', value=remotefolder, format='str') | ||||
| procUnitConfObj2.addParameter(name='ext', value='.png', format='str') | ||||
| procUnitConfObj2.addParameter(name='period', value=5, format='int') | ||||
| procUnitConfObj2.addParameter(name='protocol', value='ftp', format='str') | ||||
| #-------------------------------------------------------------------------------------------------- | ||||
| print "Escribiendo el archivo XML" | ||||
| controllerObj.writeXml(filename) | ||||
| print "Leyendo el archivo XML" | ||||
| controllerObj.readXml(filename) | ||||
| controllerObj.createObjects() | ||||
| controllerObj.connectObjects() | ||||
| controllerObj.run() | ||||