schain Commit - r947:cc89c3177475 · Jicamarca Repository

scripts cambiados

José Chávez -

r947:cc89c3177475

parent child

Context file:

r947:cc89c3177475

Collapse all files

schainpy/admin.py 0 0

NO CONTENT: modified file

schainpy/scripts/PPD.py +1 -1

             import argparse
             from schainpy.controller import Project, multiSchain
             desc = "HF_EXAMPLE"
             def fiber(cursor, skip, q, dt):
                 controllerObj = Project()
                 controllerObj.setup(id='191', name='test01', description=desc)
                 readUnitConfObj = controllerObj.addReadUnit(datatype='SpectraReader',
                                                              path='/home/nanosat/data/sp1_f0',
                                                              startDate=dt,
                                                              endDate=dt,
                                                              startTime="00:00:00",
                                                              endTime="23:59:59",
                                                              online=0,
                                                              #set=1426485881,
                                                              walk=1,
                                                              queue=q,
                                                              cursor=cursor,
                                                              skip=skip,
                                                              verbose=1
                                                              #timezone=-5*3600
                                                              )
                 #     #opObj11 = readUnitConfObj.addOperation(name='printNumberOfBlock')
                 #
                 procUnitConfObj2 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId())
                 # procUnitConfObj2.addParameter(name='nipp', value='5', format='int')
                 procUnitConfObj3 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=readUnitConfObj.getId())
                 opObj11 = procUnitConfObj3.addOperation(name='SpectralMoments', optype='other')
                 #
                 #     opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other')
                 #     opObj11.addParameter(name='id', value='1000', format='int')
                 #     opObj11.addParameter(name='wintitle', value='HF_Jicamarca_Spc', format='str')
                 #     opObj11.addParameter(name='channelList', value='0', format='intlist')
                 #     opObj11.addParameter(name='zmin', value='-120', format='float')
                 #     opObj11.addParameter(name='zmax', value='-70', format='float')
                 #     opObj11.addParameter(name='save', value='1', format='int')
                 #     opObj11.addParameter(name='figpath', value=figpath, format='str')
                 # opObj11 = procUnitConfObj3.addOperation(name='Parameters1Plot', optype='other')
                 # opObj11.addParameter(name='channelList', value='0', format='intList')
                 # opObj11.addParameter(name='id', value='2000', format='int')
                 # # opObj11.addParameter(name='colormap', value='0', format='bool')
                 # opObj11.addParameter(name='onlySNR', value='1', format='bool')
                 # opObj11.addParameter(name='DOP', value='0', format='bool')
                 # # opObj11.addParameter(name='showSNR', value='1', format='bool')
                 # # opObj11.addParameter(name='SNRthresh', value='0', format='int')
                 # opObj11.addParameter(name='SNRmin', value='-10', format='int')
                 # opObj11.addParameter(name='SNRmax', value='30', format='int')
                 # opObj11.addParameter(name='showSNR', value='1', format='int')
                 # # opObj11.addParameter(name='channelList', value='0', format='intlist')
                 # #     opObj11.addParameter(name='xmin', value='0', format='float')
                 # opObj11.addParameter(name='xmin', value='0', format='float')
                 # opObj11.addParameter(name='xmax', value='24', format='float')
                 # opObj11.addParameter(name='zmin', value='-110', format='float')
                 # opObj11.addParameter(name='zmax', value='-70', format='float')
                 # opObj11.addParameter(name='save', value='0', format='int')
                 # # opObj11.addParameter(name='figpath', value='/tmp/', format='str')
                 #
                 opObj12 = procUnitConfObj3.addOperation(name='PublishData', optype='other')
                 opObj12.addParameter(name='zeromq', value=1, format='int')
                 opObj12.addParameter(name='verbose', value=0, format='bool')
                 # opObj13 = procUnitConfObj3.addOperation(name='PublishData', optype='other')
                 # opObj13.addParameter(name='zeromq', value=1, format='int')
                 # opObj13.addParameter(name='server', value="juanca", format='str')
                 opObj12.addParameter(name='delay', value=0, format='int')
                 # print "Escribiendo el archivo XML"
                 # controllerObj.writeXml(filename)
                 # print "Leyendo el archivo XML"
                 # controllerObj.readXml(filename)
                 # timeit.timeit('controllerObj.run()', number=2)
                 controllerObj.start()
             if __name__ == '__main__':
                 parser = argparse.ArgumentParser(description='Set number of parallel processes')
                 parser.add_argument('--nProcess', default=1, type=int)
                 args = parser.parse_args()
-                multiSchain(fiber, nProcess=args.nProcess, startDate='2017/01/26', endDate='2017/01/28')
+                multiSchain(fiber, nProcess=args.nProcess, startDate='2017/01/26', endDate='2017/01/26')

schainpy/scripts/receiver.py +13 -11

             #!/usr/bin/env python
             '''
             Created on Jul 7, 2014
             @author: roj-idl71
             '''
             import os, sys
             from schainpy.controller import Project
             if __name__ == '__main__':
                 desc = "Segundo Test"
                 controllerObj = Project()
                 controllerObj.setup(id='191', name='test01', description=desc)
                 proc1 = controllerObj.addProcUnit(name='ReceiverData')
                 proc1.addParameter(name='realtime', value='0', format='bool')
-                proc1.addParameter(name='plottypes', value='rti,coh,phase', format='str')
+                proc1.addParameter(name='plottypes', value='rti,coh,phase,snr,dop', format='str')
                 proc1.addParameter(name='throttle', value='10', format='int')
                 proc1.addParameter(name='interactive', value='0', format='bool')
                 # proc1.addParameter(name='server', value='tcp://10.10.10.82:7000', format='str')
                 ## TODO Agregar direccion de server de publicacion a graficos como variable
+                op3 = proc1.addOperation(name='PlotSNRData', optype='other')
+                op3.addParameter(name='wintitle', value='Julia 150Km', format='str')
+                op3.addParameter(name='zmax', value='30', format='int')
+                op3.addParameter(name='zmin', value='-10', format='int')
+                op3.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
+                op3.addParameter(name='show', value='0', format='bool')
+                # #
+                op4 = proc1.addOperation(name='PlotDOPData', optype='other')
+                op4.addParameter(name='wintitle', value='Julia 150Km', format='str')
+                op4.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
+                op4.addParameter(name='show', value='0', format='bool')
+                op4.addParameter(name='colormap', value='jet', format='str')
                 op1 = proc1.addOperation(name='PlotRTIData', optype='other')
                 op1.addParameter(name='wintitle', value='Julia 150Km', format='str')
                 op1.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
                 op1.addParameter(name='show', value='0', format='bool')
                 op1.addParameter(name='colormap', value='jet', format='str')
                 #
                 op2 = proc1.addOperation(name='PlotCOHData', optype='other')
                 op2.addParameter(name='wintitle', value='Julia 150Km', format='str')
                 op2.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
                 op2.addParameter(name='colormap', value='jet', format='str')
                 op2.addParameter(name='show', value='0', format='bool')
                 # # #
                 op6 = proc1.addOperation(name='PlotPHASEData', optype='other')
                 op6.addParameter(name='wintitle', value='Julia 150Km', format='str')
                 op6.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
                 op6.addParameter(name='show', value='1', format='bool')
                 # #
                 # # proc2 = controllerObj.addProcUnit(name='ReceiverData')
                 # # proc2.addParameter(name='server', value='juanca', format='str')
                 # # proc2.addParameter(name='plottypes', value='snr,dop', format='str')
                 # #
-                # op3 = proc1.addOperation(name='PlotSNRData', optype='other')
-                # op3.addParameter(name='wintitle', value='Julia 150Km', format='str')
-                # op3.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
-                # op3.addParameter(name='show', value='0', format='bool')
-                # #
-                # op4 = proc1.addOperation(name='PlotDOPData', optype='other')
-                # op4.addParameter(name='wintitle', value='Julia 150Km', format='str')
-                # op4.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
-                # op4.addParameter(name='show', value='0', format='bool')
-                # op4.addParameter(name='colormap', value='jet', format='str')
                 controllerObj.start()

schainpy/scripts/schain.xml +1 -1

	@@ -1,1 +1,1
	1	<Project description="HF_EXAMPLE" id="191" name="test01"><ReadUnit datatype="SpectraReader" id="1911" inputId="0" name="SpectraReader"><Operation id="19111" name="run" priority="1" type="self"><Parameter format="str" id="191111" name="datatype" value="SpectraReader" /><Parameter format="str" id="191112" name="path" value="/home/nanosat/data/sp1_f0" /><Parameter format="date" id="191113" name="startDate" value="2017/01/28" /><Parameter format="date" id="191114" name="endDate" value="2017/01/28" /><Parameter format="time" id="191115" name="startTime" value="00:00:00" /><Parameter format="time" id="191116" name="endTime" value="23:59:59" /><Parameter format="int" id="191118" name="cursor" value="5" /><Parameter format="int" id="191119" name="skip" value="~~177~~" /><Parameter format="int" id="191120" name="walk" value="1" /><Parameter format="int" id="191121" name="verbose" value="1" /><Parameter format="int" id="191122" name="online" value="0" /></Operation></ReadUnit><ProcUnit datatype="ParametersProc" id="1913" inputId="1911" name="ParametersProc"><Operation id="19131" name="run" priority="1" type="self" /><Operation id="19132" name="SpectralMoments" priority="2" type="other" /><Operation id="19133" name="PublishData" priority="3" type="other"><Parameter format="int" id="191331" name="zeromq" value="1" /><Parameter format="bool" id="191332" name="verbose" value="0" /><Parameter format="int" id="191333" name="delay" value="0" /></Operation></ProcUnit><ProcUnit datatype="Spectra" id="1912" inputId="1911" name="SpectraProc"><Operation id="19121" name="run" priority="1" type="self" /></ProcUnit></Project> No newline at end of file		1	<Project description="HF_EXAMPLE" id="191" name="test01"><ReadUnit datatype="SpectraReader" id="1911" inputId="0" name="SpectraReader"><Operation id="19111" name="run" priority="1" type="self"><Parameter format="str" id="191111" name="datatype" value="SpectraReader" /><Parameter format="str" id="191112" name="path" value="/home/nanosat/data/sp1_f0" /><Parameter format="date" id="191113" name="startDate" value="2017/01/26" /><Parameter format="date" id="191114" name="endDate" value="2017/01/26" /><Parameter format="time" id="191115" name="startTime" value="00:00:00" /><Parameter format="time" id="191116" name="endTime" value="23:59:59" /><Parameter format="int" id="191118" name="cursor" value="7" /><Parameter format="int" id="191119" name="skip" value="90" /><Parameter format="int" id="191120" name="walk" value="1" /><Parameter format="int" id="191121" name="verbose" value="1" /><Parameter format="int" id="191122" name="online" value="0" /></Operation></ReadUnit><ProcUnit datatype="ParametersProc" id="1913" inputId="1911" name="ParametersProc"><Operation id="19131" name="run" priority="1" type="self" /><Operation id="19132" name="SpectralMoments" priority="2" type="other" /><Operation id="19133" name="PublishData" priority="3" type="other"><Parameter format="int" id="191331" name="zeromq" value="1" /><Parameter format="bool" id="191332" name="verbose" value="0" /><Parameter format="int" id="191333" name="delay" value="0" /></Operation></ProcUnit><ProcUnit datatype="Spectra" id="1912" inputId="1911" name="SpectraProc"><Operation id="19121" name="run" priority="1" type="self" /></ProcUnit></Project> No newline at end of file

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages