##// END OF EJS Templates
Script test de pruebas actuales con el update de heading en el block 360, el parametro adicional es heading que se lee del experiment.conf
Script test de pruebas actuales con el update de heading en el block 360, el parametro adicional es heading que se lee del experiment.conf

File last commit:

r993:8e2d40d721e7
r1759:c8ee9da660f1
Show More
PPD.py
97 lines | 4.5 KiB | text/x-python | PythonLexer
import argparse
from schainpy.controller import Project, multiSchain
desc = "HF_EXAMPLE"
def fiber(cursor, skip, q, dt):
controllerObj = Project()
controllerObj.setup(id='191', name='test01', description=desc)
readUnitConfObj = controllerObj.addReadUnit(datatype='SpectraReader',
path='/home/nanosat/data/sp1_f0',
startDate=dt,
endDate=dt,
startTime="00:00:00",
endTime="23:59:59",
online=0,
#set=1426485881,
walk=1,
queue=q,
cursor=cursor,
skip=skip,
verbose=1
#timezone=-5*3600
)
# #opObj11 = readUnitConfObj.addOperation(name='printNumberOfBlock')
#
procUnitConfObj2 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId())
# procUnitConfObj2.addParameter(name='nipp', value='5', format='int')
procUnitConfObj3 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=readUnitConfObj.getId())
opObj11 = procUnitConfObj3.addOperation(name='SpectralMoments', optype='other')
#
# opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other')
# opObj11.addParameter(name='id', value='1000', format='int')
# opObj11.addParameter(name='wintitle', value='HF_Jicamarca_Spc', format='str')
# opObj11.addParameter(name='channelList', value='0', format='intlist')
# opObj11.addParameter(name='zmin', value='-120', format='float')
# opObj11.addParameter(name='zmax', value='-70', format='float')
# opObj11.addParameter(name='save', value='1', format='int')
# opObj11.addParameter(name='figpath', value=figpath, format='str')
# opObj11 = procUnitConfObj3.addOperation(name='Parameters1Plot', optype='other')
# opObj11.addParameter(name='channelList', value='0', format='intList')
# opObj11.addParameter(name='id', value='2000', format='int')
# # opObj11.addParameter(name='colormap', value='0', format='bool')
# opObj11.addParameter(name='onlySNR', value='1', format='bool')
# opObj11.addParameter(name='DOP', value='0', format='bool')
# # opObj11.addParameter(name='showSNR', value='1', format='bool')
# # opObj11.addParameter(name='SNRthresh', value='0', format='int')
# opObj11.addParameter(name='SNRmin', value='-10', format='int')
# opObj11.addParameter(name='SNRmax', value='30', format='int')
# opObj11.addParameter(name='showSNR', value='1', format='int')
# # opObj11.addParameter(name='channelList', value='0', format='intlist')
# # opObj11.addParameter(name='xmin', value='0', format='float')
# opObj11.addParameter(name='xmin', value='0', format='float')
# opObj11.addParameter(name='xmax', value='24', format='float')
# opObj11.addParameter(name='zmin', value='-110', format='float')
# opObj11.addParameter(name='zmax', value='-70', format='float')
# opObj11.addParameter(name='save', value='0', format='int')
# # opObj11.addParameter(name='figpath', value='/tmp/', format='str')
#
opObj12 = procUnitConfObj3.addOperation(name='PublishData', optype='other')
opObj12.addParameter(name='zeromq', value=1, format='int')
opObj12.addParameter(name='verbose', value=0, format='bool')
# opObj13 = procUnitConfObj3.addOperation(name='PublishData', optype='other')
# opObj13.addParameter(name='zeromq', value=1, format='int')
# opObj13.addParameter(name='server', value="juanca", format='str')
opObj12.addParameter(name='delay', value=0, format='int')
# print "Escribiendo el archivo XML"
# controllerObj.writeXml(filename)
# print "Leyendo el archivo XML"
# controllerObj.readXml(filename)
# timeit.timeit('controllerObj.run()', number=2)
controllerObj.start()
if __name__ == '__main__':
parser = argparse.ArgumentParser(description='Set number of parallel processes')
parser.add_argument('--nProcess', default=1, type=int)
args = parser.parse_args()
multiSchain(fiber, nProcess=args.nProcess, startDate='2017/01/26', endDate='2017/01/26')