##// END OF EJS Templates
schain
RSS
voltage DigitalRFReader funcionando
voltage DigitalRFReader funcionando
José Chávez - - Load All Authors

File last commit:

r931:9d13aae43f1b
r973:168a55cfc83e
Show More
julia_mp.py
97 lines | 4.6 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')
#
# 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 = procUnitConfObj2.addOperation(name='PublishData', optype='other')
opObj12.addParameter(name='zeromq', value=1, format='int')
# 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')