##// END OF EJS Templates
schain-jc
RSS
Multiprocessing for BLTR (sswma) data
Multiprocessing for BLTR (sswma) data
Juan C. Espinoza - - Load All Authors

File last commit:

r1113:f2689c814816
r1181:eb60268405c6
Show More
templates.py
90 lines | 3.4 KiB | text/x-python | PythonLexer
/ schainpy / cli / templates.py
History | Source | Raw |Copy content |Copy permalink
José Chávez
multiprocess added to cli
 r935 basic = '''from schainpy.controller import Project
José Chávez
primer generate basic
 r934
desc = "{desc}"
José Chávez
templates y setup actualizados
 r1078 project = Project()
project.setup(id='200', name="{name}", description=desc)
José Chávez
primer generate basic
 r934
José Chávez
templates y setup actualizados
 r1078 voltage_reader = project.addReadUnit(datatype='VoltageReader',
José Chávez
multiprocess added to cli
 r935 path="{path}",
startDate="{startDate}",
endDate="{endDate}",
startTime="{startHour}",
endTime="{endHour}",
online=0,
verbose=1,
walk=1,
)
José Chávez
templates y setup actualizados
 r1078 voltage_proc = project.addProcUnit(datatype='VoltageProc', inputId=voltage_reader.getId())
José Chávez
multiprocess added to cli
 r935
José Chávez
templates y setup actualizados
 r1078 profile = voltage_proc.addOperation(name='ProfileSelector', optype='other')
profile.addParameter(name='profileRangeList', value='120,183', format='intlist')
José Chávez
multiprocess added to cli
 r935
José Chávez
templates y setup actualizados
 r1078 rti = voltage_proc.addOperation(name='RTIPlot', optype='other')
rti.addParameter(name='wintitle', value='Jicamarca Radio Observatory', format='str')
rti.addParameter(name='showprofile', value='0', format='int')
rti.addParameter(name='xmin', value='0', format='int')
rti.addParameter(name='xmax', value='24', format='int')
rti.addParameter(name='figpath', value="{figpath}", format='str')
rti.addParameter(name='wr_period', value='5', format='int')
rti.addParameter(name='exp_code', value='22', format='int')
José Chávez
multiprocess added to cli
 r935
José Chávez
formatting, template actualizado, decimation a 300
 r1092 project.start()
José Chávez
multiprocess added to cli
 r935 '''
José Chávez
templates y setup actualizados
 r1078 multiprocess = '''from schainpy.controller import Project, MPProject
José Chávez
arreglado varios dias con mp
 r1079 from time import sleep
José Chávez
multiprocess added to cli
 r935 desc = "{desc}"
José Chávez
templates y setup actualizados
 r1078 ####################
# PLOTTER RECEIVER #
####################
plotter = Project()
plotter.setup(id='100', name='receiver', description=desc)
José Chávez
kwargs restantes. Templates y changelog actualizado
 r1080 receiver_plot = plotter.addProcUnit(name='PlotterReceiver')
receiver_plot.addParameter(name='throttle', value=20, format='int')
receiver_plot.addParameter(name='plottypes', value='rti', format='str')
José Chávez
templates y setup actualizados
 r1078
José Chávez
kwargs restantes. Templates y changelog actualizado
 r1080 rti = receiver_plot.addOperation(name='PlotRTIData', optype='other')
José Chávez
templates y setup actualizados
 r1078 rti.addParameter(name='zmin', value='-40.0', format='float')
rti.addParameter(name='zmax', value='100.0', format='float')
José Chávez
kwargs restantes. Templates y changelog actualizado
 r1080 rti.addParameter(name='decimation', value='200', format='int')
José Chávez
templates y setup actualizados
 r1078 rti.addParameter(name='xmin', value='0.0', format='int')
rti.addParameter(name='colormap', value='jet', format='str')
plotter.start()
José Chávez
arreglado varios dias con mp
 r1079 sleep(2)
José Chávez
templates y setup actualizados
 r1078 ################
# DATA EMITTER #
################
project = Project()
project.setup(id='200', name="{name}", description=desc)
spectra_reader = project.addReadUnit(datatype='SpectraReader',
path="{path}",
startDate={startDate},
endDate={endDate},
startTime="{startHour}",
endTime="{endHour}",
online=0,
verbose=1,
walk=1,
)
spectra_proc = project.addProcUnit(datatype='Spectra', inputId=spectra_reader.getId())
parameters_proc = project.addProcUnit(datatype='ParametersProc', inputId=spectra_proc.getId())
moments = parameters_proc.addOperation(name='SpectralMoments', optype='other')
publish = parameters_proc.addOperation(name='PublishData', optype='other')
publish.addParameter(name='zeromq', value=1, format='int')
publish.addParameter(name='verbose', value=0, format='bool')
MPProject(project, 16)
José Chávez
multiprocess added to cli
 r935
José Chávez
primer generate basic
 r934 '''