templates.py
75 lines
| 3.0 KiB
| text/x-python
|
PythonLexer
/ schaincli / templates.py
José Chávez
|
r935 | basic = '''from schainpy.controller import Project | ||
|
José Chávez
|
r934 | |||
| desc = "{desc}" | ||||
| controller = Project() | ||||
| controller.setup(id='191', name="{name}", description=desc) | ||||
|
José Chávez
|
r935 | readUnitConf = controller.addReadUnit(datatype='VoltageReader', | ||
| path="{path}", | ||||
| startDate="{startDate}", | ||||
| endDate="{endDate}", | ||||
| startTime="{startHour}", | ||||
| endTime="{endHour}", | ||||
| online=0, | ||||
| verbose=1, | ||||
| walk=1, | ||||
| ) | ||||
| procUnitConf1 = controller.addProcUnit(datatype='VoltageProc', inputId=readUnitConf.getId()) | ||||
| opObj11 = procUnitConf1.addOperation(name='ProfileSelector', optype='other') | ||||
| opObj11.addParameter(name='profileRangeList', value='120,183', format='intlist') | ||||
| opObj11 = procUnitConf1.addOperation(name='RTIPlot', optype='other') | ||||
| opObj11.addParameter(name='wintitle', value='Jicamarca Radio Observatory', format='str') | ||||
| opObj11.addParameter(name='showprofile', value='0', format='int') | ||||
| opObj11.addParameter(name='xmin', value='0', format='int') | ||||
| opObj11.addParameter(name='xmax', value='24', format='int') | ||||
| opObj11.addParameter(name='figpath', value="{figpath}", format='str') | ||||
| opObj11.addParameter(name='wr_period', value='5', format='int') | ||||
| opObj11.addParameter(name='exp_code', value='22', format='int') | ||||
| controller.start() | ||||
| ''' | ||||
| multiprocess = '''from schainpy.controller import Project, multiSchain | ||||
| desc = "{desc}" | ||||
| def fiber(cursor, skip, q, day): | ||||
| controller = Project() | ||||
| controller.setup(id='191', name="{name}", description=desc) | ||||
| readUnitConf = controller.addReadUnit(datatype='SpectraReader', | ||||
| path="{path}", | ||||
|
José Chávez
|
r936 | startDate=day, | ||
| endDate=day, | ||||
|
José Chávez
|
r935 | startTime="{startHour}", | ||
| endTime="{endHour}", | ||||
| online=0, | ||||
| queue=q, | ||||
| cursor=cursor, | ||||
| skip=skip, | ||||
| verbose=1, | ||||
| walk=1, | ||||
| ) | ||||
| procUnitConf1 = controller.addProcUnit(datatype='Spectra', inputId=readUnitConf.getId()) | ||||
| procUnitConf2 = controller.addProcUnit(datatype='ParametersProc', inputId=readUnitConf.getId()) | ||||
| opObj11 = procUnitConf2.addOperation(name='SpectralMoments', optype='other') | ||||
| opObj12 = procUnitConf2.addOperation(name='PublishData', optype='other') | ||||
| opObj12.addParameter(name='zeromq', value=1, format='int') | ||||
| opObj12.addParameter(name='verbose', value=0, format='bool') | ||||
| controller.start() | ||||
| if __name__ == '__main__': | ||||
| multiSchain(fiber, nProcess={nProcess}, startDate="{startDate}", endDate="{endDate}") | ||||
|
José Chávez
|
r934 | ''' | ||