|
|
basic = '''from schainpy.controller import Project
|
|
|
|
|
|
desc = "{desc}"
|
|
|
project = Project()
|
|
|
project.setup(id='200', name="{name}", description=desc)
|
|
|
|
|
|
voltage_reader = project.addReadUnit(datatype='VoltageReader',
|
|
|
path="{path}",
|
|
|
startDate="{startDate}",
|
|
|
endDate="{endDate}",
|
|
|
startTime="{startHour}",
|
|
|
endTime="{endHour}",
|
|
|
online=0,
|
|
|
verbose=1,
|
|
|
walk=1,
|
|
|
)
|
|
|
|
|
|
voltage_proc = project.addProcUnit(datatype='VoltageProc', inputId=voltage_reader.getId())
|
|
|
|
|
|
profile = voltage_proc.addOperation(name='ProfileSelector', optype='other')
|
|
|
profile.addParameter(name='profileRangeList', value='120,183', format='intlist')
|
|
|
|
|
|
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')
|
|
|
|
|
|
|
|
|
controller.start()
|
|
|
'''
|
|
|
|
|
|
multiprocess = '''from schainpy.controller import Project, MPProject
|
|
|
from time import sleep
|
|
|
desc = "{desc}"
|
|
|
|
|
|
####################
|
|
|
# PLOTTER RECEIVER #
|
|
|
####################
|
|
|
plotter = Project()
|
|
|
plotter.setup(id='100', name='receiver', description=desc)
|
|
|
|
|
|
receiver_plot = plotter.addProcUnit(name='PlotterReceiver')
|
|
|
receiver_plot.addParameter(name='throttle', value=20, format='int')
|
|
|
receiver_plot.addParameter(name='plottypes', value='rti', format='str')
|
|
|
|
|
|
rti = receiver_plot.addOperation(name='PlotRTIData', optype='other')
|
|
|
rti.addParameter(name='zmin', value='-40.0', format='float')
|
|
|
rti.addParameter(name='zmax', value='100.0', format='float')
|
|
|
rti.addParameter(name='decimation', value='200', format='int')
|
|
|
rti.addParameter(name='xmin', value='0.0', format='int')
|
|
|
rti.addParameter(name='colormap', value='jet', format='str')
|
|
|
|
|
|
plotter.start()
|
|
|
|
|
|
sleep(2)
|
|
|
|
|
|
################
|
|
|
# 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)
|
|
|
|
|
|
|
|
|
'''
|
|
|
|
