##// END OF EJS Templates
schain-jc
RSS
reworked
reworked
José Chávez - - Load All Authors

File last commit:

r954:94be3372cea7
r954:94be3372cea7
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',
José Chávez
reworked
 r954 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
)
José Chávez
finishing day, need testing
 r931
# #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
algunos cambios en roj
 r953 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
algunos cambios en roj
 r953 # 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')