|
|
basic = '''from schainpy.controller import Project
|
|
|
|
|
|
desc = "{desc}"
|
|
|
|
|
|
controller = Project()
|
|
|
controller.setup(id='191', name="{name}", description=desc)
|
|
|
|
|
|
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}",
|
|
|
startDate=day,
|
|
|
endDate=day,
|
|
|
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}")
|
|
|
|
|
|
|
|
|
'''
|
|
|
|
