##// END OF EJS Templates
schain
RSS
Modificación a kmamisr para ejecutarse en la versión 3, creación de scripts con terminación v3 para difereciarlos, se comentó la linea #720 de JroIO_param.py debido a que reiniciaba la lista de archivos, ocasionando la reescritura del archivo hdf5. Alguna otra modificación aparente es producto de algunas variaciones en espacios al usar la función print()
Modificación a kmamisr para ejecutarse en la versión 3, creación de scripts con terminación v3 para difereciarlos, se comentó la linea #720 de JroIO_param.py debido a que reiniciaba la lista de archivos, ocasionando la reescritura del archivo hdf5. Alguna otra modificación aparente es producto de algunas variaciones en espacios al usar la función print()
José Chávez - - Load All Authors

File last commit:

r954:94be3372cea7
r1279:c53fe2a4a291
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')