##// END OF EJS Templates
schain
RSS
Use of delays instead of input queue to keep dataouts and avoid loose of them
Use of delays instead of input queue to keep dataouts and avoid loose of them
George Yong - - Load All Authors

File last commit:

r1182:78b9f3217839
r1245:1ee18bfa3eb6
Show More
templates.py
269 lines | 13.0 KiB | text/x-python | PythonLexer
/ schainpy / cli / templates.py
History | Source | Raw |Copy content |Copy permalink
George Yong
New templates for CLI (Task #1402)
 r1182 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))
José Chávez
primer generate basic
 r934
José Chávez
multiprocess added to cli
 r935 '''
George Yong
New templates for CLI (Task #1402)
 r1182
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))
'''
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 #
################
George Yong
New templates for CLI (Task #1402)
 r1182 controller = Project()
controller.setup(id='200', name="{name}", description=desc)
José Chávez
templates y setup actualizados
 r1078
George Yong
New templates for CLI (Task #1402)
 r1182 spectra_reader = controller.addReadUnit(datatype='SpectraReader',
José Chávez
templates y setup actualizados
 r1078 path="{path}",
startDate={startDate},
endDate={endDate},
startTime="{startHour}",
endTime="{endHour}",
online=0,
verbose=1,
walk=1,
)
George Yong
New templates for CLI (Task #1402)
 r1182 spectra_proc = controller.addProcUnit(datatype='Spectra', inputId=spectra_reader.getId())
José Chávez
templates y setup actualizados
 r1078
George Yong
New templates for CLI (Task #1402)
 r1182 parameters_proc = controller.addProcUnit(datatype='ParametersProc', inputId=spectra_proc.getId())
José Chávez
templates y setup actualizados
 r1078 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')
George Yong
New templates for CLI (Task #1402)
 r1182 MPProject(controller, 16)
José Chávez
multiprocess added to cli
 r935
José Chávez
primer generate basic
 r934 '''