##// END OF EJS Templates
schain
RSS
agregado metodos a header class
agregado metodos a header class
José Chávez - - Load All Authors

File last commit:

r951:c6971afb3131
r980:ea5ace19bd59
Show More
julia_mp.py
94 lines | 4.3 KiB | text/x-python | PythonLexer
/ schainpy / scripts / julia_mp.py
History | Source | Raw |Copy content |Copy permalink
José Chávez
finishing day, need testing
 r931 import argparse
Juan C. Valdez
test script using MP
 r867
José Chávez
finishing day, need testing
 r931 from schainpy.controller import Project, multiSchain
Juan C. Valdez
test script using MP
 r867
José Chávez
finishing day, need testing
 r931 desc = "HF_EXAMPLE"
Juan C. Valdez
test script using MP
 r867
José Chávez
finishing day, need testing
 r931 def fiber(cursor, skip, q, dt):
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
José Chávez
finishing day, need testing
 r931 controllerObj = Project()
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
José Chávez
finishing day, need testing
 r931 controllerObj.setup(id='191', name='test01', description=desc)
readUnitConfObj = controllerObj.addReadUnit(datatype='SpectraReader',
path='/home/nanosat/data/julia',
startDate=dt,
endDate=dt,
startTime="00:00:00",
endTime="23:59:59",
online=0,
#set=1426485881,
delay=10,
walk=1,
queue=q,
cursor=cursor,
skip=skip,
#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')
#
José Chávez
ultimo cambio
 r951 opObj11 = procUnitConfObj2.addOperation(name='RTIPlot', optype='other')
opObj11.addParameter(name='id', value='1000', format='int')
opObj11.addParameter(name='wintitle', value='HF_Jicamarca_Spc', format='str')
opObj11.addParameter(name='xmin', value='0', format='int')
opObj11.addParameter(name='xmax', value='24', format='int')
José Chávez
finishing day, need testing
 r931
# 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')
#
José Chávez
ultimo cambio
 r951 # opObj12 = procUnitConfObj2.addOperation(name='PublishData', optype='other')
# opObj12.addParameter(name='zeromq', value=1, format='int')
José Chávez
finishing day, need testing
 r931 # opObj12.addParameter(name='server', value='tcp://10.10.10.82:7000', format='str')
# 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=1, format='int')
# print "Escribiendo el archivo XML"
# controllerObj.writeXml(filename)
# print "Leyendo el archivo XML"
# controllerObj.readXml(filename)
# timeit.timeit('controllerObj.run()', number=2)
Juan C. Valdez
test script using MP
 r867
controllerObj.start()
José Chávez
cambios de prueba
 r890
José Chávez
finishing day, need testing
 r931 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='2016/08/19', endDate='2016/08/19')