##// END OF EJS Templates
Modificación a kmamisr para ejecutarse en la versión 3, creación de scripts con terminación v3 para difereciarlos, se comentó la linea #720 de JroIO_param.py debido a que reiniciaba la lista de archivos, ocasionando la reescritura del archivo hdf5. Alguna otra modificación aparente es producto de algunas variaciones en espacios al usar la función print()
Modificación a kmamisr para ejecutarse en la versión 3, creación de scripts con terminación v3 para difereciarlos, se comentó la linea #720 de JroIO_param.py debido a que reiniciaba la lista de archivos, ocasionando la reescritura del archivo hdf5. Alguna otra modificación aparente es producto de algunas variaciones en espacios al usar la función print()

File last commit:

r1182:78b9f3217839
r1279:c53fe2a4a291
Show More
templates.py
269 lines | 13.0 KiB | text/x-python | PythonLexer
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 '''