##// END OF EJS Templates
schain-jc
RSS
Review last commit
Review last commit
George Yong - - Load All Authors

File last commit:

r1182:78b9f3217839
r1186:29f68a738921 merge
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 '''