##// END OF EJS Templates
schain
RSS
Cambio en la lectura de archivos, se incluyó detección de cambio de experimento
Cambio en la lectura de archivos, se incluyó detección de cambio de experimento
José Chávez - - Load All Authors

File last commit:

r993:8e2d40d721e7
r1373:fa4c334951aa
Show More
PPD.py
97 lines | 4.5 KiB | text/x-python | PythonLexer
/ schainpy / scripts / PPD.py
History | Source | Raw |Copy content |Copy permalink
jespinoza
add multiSchain (@jchavez)
 r892 import argparse
from schainpy.controller import Project, multiSchain
desc = "HF_EXAMPLE"
def fiber(cursor, skip, q, dt):
controllerObj = Project()
controllerObj.setup(id='191', name='test01', description=desc)
readUnitConfObj = controllerObj.addReadUnit(datatype='SpectraReader',
José Chávez
scripts?
 r993 path='/home/nanosat/data/sp1_f0',
startDate=dt,
endDate=dt,
startTime="00:00:00",
endTime="23:59:59",
online=0,
#set=1426485881,
walk=1,
queue=q,
cursor=cursor,
skip=skip,
verbose=1
#timezone=-5*3600
)
jespinoza
add multiSchain (@jchavez)
 r892
# #opObj11 = readUnitConfObj.addOperation(name='printNumberOfBlock')
#
procUnitConfObj2 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId())
José Chávez
checking misspelled kwargs in operations/processing units
 r929 # procUnitConfObj2.addParameter(name='nipp', value='5', format='int')
José Chávez
ningun cambio
 r927 procUnitConfObj3 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=readUnitConfObj.getId())
opObj11 = procUnitConfObj3.addOperation(name='SpectralMoments', optype='other')
jespinoza
add multiSchain (@jchavez)
 r892
#
# 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')
José Chávez
finishing day, need testing
 r931 # opObj11 = procUnitConfObj3.addOperation(name='Parameters1Plot', optype='other')
# opObj11.addParameter(name='channelList', value='0', format='intList')
José Chávez
checking misspelled kwargs in operations/processing units
 r929
José Chávez
finishing day, need testing
 r931 # 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')
José Chávez
checking misspelled kwargs in operations/processing units
 r929 # opObj11.addParameter(name='SNRmin', value='-10', format='int')
# opObj11.addParameter(name='SNRmax', value='30', format='int')
# opObj11.addParameter(name='showSNR', value='1', format='int')
José Chávez
funcionando todo
 r898 # # 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')
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897
jespinoza
add multiSchain (@jchavez)
 r892 # opObj11.addParameter(name='zmin', value='-110', format='float')
# opObj11.addParameter(name='zmax', value='-70', format='float')
# opObj11.addParameter(name='save', value='0', format='int')
José Chávez
cambiados los kwargs para cada operacion/unidad de procesamiento
 r897 # # opObj11.addParameter(name='figpath', value='/tmp/', format='str')
#
José Chávez
ningun cambio
 r927 opObj12 = procUnitConfObj3.addOperation(name='PublishData', optype='other')
jespinoza
add multiSchain (@jchavez)
 r892 opObj12.addParameter(name='zeromq', value=1, format='int')
José Chávez
finishing day, need testing
 r931 opObj12.addParameter(name='verbose', value=0, format='bool')
jespinoza
add multiSchain (@jchavez)
 r892
José Chávez
nada
 r913
José Chávez
funcionando en mi compu
 r900 # opObj13 = procUnitConfObj3.addOperation(name='PublishData', optype='other')
# opObj13.addParameter(name='zeromq', value=1, format='int')
# opObj13.addParameter(name='server', value="juanca", format='str')
José Chávez
funcionando todo
 r898
José Chávez
finishing day, need testing
 r931 opObj12.addParameter(name='delay', value=0, format='int')
José Chávez
funcionando todo
 r898
jespinoza
add multiSchain (@jchavez)
 r892 # print "Escribiendo el archivo XML"
# controllerObj.writeXml(filename)
# print "Leyendo el archivo XML"
# controllerObj.readXml(filename)
# timeit.timeit('controllerObj.run()', number=2)
José Chávez
funcionando todo
 r898 controllerObj.start()
jespinoza
add multiSchain (@jchavez)
 r892
if __name__ == '__main__':
parser = argparse.ArgumentParser(description='Set number of parallel processes')
José Chávez
receiver data modificado para web
 r904 parser.add_argument('--nProcess', default=1, type=int)
jespinoza
add multiSchain (@jchavez)
 r892 args = parser.parse_args()
José Chávez
scripts cambiados
 r947 multiSchain(fiber, nProcess=args.nProcess, startDate='2017/01/26', endDate='2017/01/26')