voltage = '''import os, sys, time from schainpy.controller import Project def main(): desc = "{desc}" controller = Project() controller.setup(id='200', name="{name}", description=desc) read_unit = controller.addReadUnit(datatype='Voltage', path="{path}", startDate="{startDate}", endDate="{endDate}", startTime="{startHour}", endTime="{endHour}", online=0, verbose=1, walk=0, delay=180, ) code = '[[1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1]]' nCode = '128' nBaud = '3' proc_voltage = controller.addProcUnit(name='VoltageProc', inputId=read_unit.getId()) op1 = proc_voltage.addOperation(name='selectChannels', optype='self') op1.addParameter(name='channelList', value='0, 1, 2, 3', format='intlist') op2 = proc_voltage.addOperation(name='filterByHeights', optype='self') op2.addParameter(name='window', value='4', format='int') op3 = proc_voltage.addOperation(name='ProfileSelector', optype='other') op3.addParameter(name='profileRangeList', value='32, 159', format='intList') op4 = proc_voltage.addOperation(name='Decoder', optype='other') op4.addParameter(name='code', value=code, format='intlist') op4.addParameter(name='nCode', value=nCode, format='int') op4.addParameter(name='nBaud', value=nBaud, format='int') op4.addParameter(name='mode', value='0', format='int') op5 = proc_voltage.addOperation(name='Scope', optype='external') op5.addParameter(name='id', value='30', format='int') controller.start() if __name__ == '__main__': import time start_time = time.time() main() print("--- %s seconds ---" % (time.time() - start_time)) ''' spectra = '''import os, sys, time from schainpy.controller import Project def main(): desc = "{desc}" controller = Project() controller.setup(id='300', name="{name}", description=desc) read_unit = controller.addReadUnit(datatype='Spectra', path="{path}", startDate="{startDate}", endDate="{endDate}", startTime="{startHour}", endTime="{endHour}", online=0, verbose=1, walk=0, delay=180, ) proc_spectra = controller.addProcUnit(datatype='Spectra', inputId=read_unit.getId()) proc_spectra.addParameter(name='nFFTPoints', value='128', format='int') proc_spectra.addParameter(name='nProfiles', value='128', format='int') proc_spectra.addParameter(name='pairsList', value='(0, 1), (2, 3)', format='pairslist') op1 = proc_spectra.addOperation(name='IncohInt', optype='other') op1.addParameter(name='n', value='4', format='int') op2 = proc_spectra.addOperation(name='CrossSpectraPlot', optype='external') op2.addParameter(name='id', value='10', format='int') op2.addParameter(name='zmin', value='10.0', format='float') op2.addParameter(name='zmax', value='35.0', format='float') op3 = proc_spectra.addOperation(name='RTIPlot', optype='external') op3.addParameter(name='id', value='20', format='int') op3.addParameter(name='wintitle', value='RTI', format='str') op3.addParameter(name='xmin', value='0', format='float') op3.addParameter(name='xmax', value='24', format='float') op3.addParameter(name='zmin', value='12', format='int') op3.addParameter(name='zmax', value='32', format='int') op3.addParameter(name='showprofile', value='1', format='int') op3.addParameter(name='timerange', value=str(24*60*60), format='int') op4 = proc_spectra.addOperation(name='CoherenceMap', optype='external') op4.addParameter(name='id', value='30', format='int') op4.addParameter(name='xmin', value='0.0', format='float') op4.addParameter(name='xmax', value='24.0', format='float') controller.start() if __name__ == '__main__': import time start_time = time.time() main() print("--- %s seconds ---" % (time.time() - start_time)) ''' voltagespectra = '''import os, sys, time from schainpy.controller import Project def main(): desc = "{desc}" controller = Project() controller.setup(id='400', name="{name}", description=desc) read_unit = controller.addReadUnit(datatype='Voltage', path="{path}", startDate="{startDate}", endDate="{endDate}", startTime="{startHour}", endTime="{endHour}", online=0, verbose=1, walk=0, delay=180, ) code = '[[1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [1, 1, -1], [-1, -1, 1], [-1, -1, 1], [-1, -1, 1], [1, 1, -1]]' nCode = '128' nBaud = '3' proc_voltage = controller.addProcUnit(name='VoltageProc', inputId=read_unit.getId()) op1 = proc_voltage.addOperation(name='selectChannels', optype='self') op1.addParameter(name='channelList', value='0, 1, 2, 3', format='intlist') op2 = proc_voltage.addOperation(name='filterByHeights', optype='self') op2.addParameter(name='window', value='4', format='int') op3 = proc_voltage.addOperation(name='ProfileSelector', optype='other') op3.addParameter(name='profileRangeList', value='32, 159', format='intList') op4 = proc_voltage.addOperation(name='Decoder', optype='other') op4.addParameter(name='code', value=code, format='intlist') op4.addParameter(name='nCode', value=nCode, format='int') op4.addParameter(name='nBaud', value=nBaud, format='int') op4.addParameter(name='mode', value='0', format='int') proc_spectra = controller.addProcUnit(datatype='Spectra', inputId=proc_voltage.getId()) proc_spectra.addParameter(name='nFFTPoints', value='128', format='int') proc_spectra.addParameter(name='nProfiles', value='128', format='int') proc_spectra.addParameter(name='pairsList', value='(0, 1), (2, 3)', format='pairslist') op5 = proc_spectra.addOperation(name='IncohInt', optype='other') op5.addParameter(name='n', value='4', format='int') op6 = proc_spectra.addOperation(name='CrossSpectraPlot', optype='external') op6.addParameter(name='id', value='10', format='int') op6.addParameter(name='zmin', value='10.0', format='float') op6.addParameter(name='zmax', value='35.0', format='float') op7 = proc_spectra.addOperation(name='RTIPlot', optype='external') op7.addParameter(name='id', value='20', format='int') op7.addParameter(name='wintitle', value='RTI', format='str') op7.addParameter(name='xmin', value='0', format='float') op7.addParameter(name='xmax', value='24', format='float') op7.addParameter(name='zmin', value='12', format='int') op7.addParameter(name='zmax', value='32', format='int') op7.addParameter(name='showprofile', value='1', format='int') op7.addParameter(name='timerange', value=str(24*60*60), format='int') op8 = proc_spectra.addOperation(name='CoherenceMap', optype='external') op8.addParameter(name='id', value='30', format='int') op8.addParameter(name='xmin', value='0.0', format='float') op8.addParameter(name='xmax', value='24.0', format='float') controller.start() if __name__ == '__main__': import time start_time = time.time() main() print("--- %s seconds ---" % (time.time() - start_time)) ''' 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 # ################ controller = Project() controller.setup(id='200', name="{name}", description=desc) spectra_reader = controller.addReadUnit(datatype='SpectraReader', path="{path}", startDate={startDate}, endDate={endDate}, startTime="{startHour}", endTime="{endHour}", online=0, verbose=1, walk=1, ) spectra_proc = controller.addProcUnit(datatype='Spectra', inputId=spectra_reader.getId()) parameters_proc = controller.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(controller, 16) '''