##// END OF EJS Templates
schain
RSS
Spectralmoments improvements: mode_fit to select gaussian fitting for 150Km experiment and avoid it for ESF experiment. JULIADriftsEstimation improvements: 150 Km statistics for cleaning data
Spectralmoments improvements: mode_fit to select gaussian fitting for 150Km experiment and avoid it for ESF experiment. JULIADriftsEstimation improvements: 150 Km statistics for cleaning data
jespinoza - - Load All Authors

File last commit:

r1396:f39ad5b721a3
r1714:afa9767980a0
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,
jespinoza
Merge EW-Drifts
 r1396 # set=1426485881,
José Chávez
reworked
 r954 delay=10,
walk=1,
queue=q,
cursor=cursor,
skip=skip,
jespinoza
Merge EW-Drifts
 r1396 # timezone=-5*3600
José Chávez
reworked
 r954 )
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')