##// END OF EJS Templates
schain-jc
RSS
Creo q no hice nada
J Gomez -
r932:a265a93c2e58
parent child
Show More
Show file before | Show file after | Hide comments
@@ -66,7 +66,7 def multiSchain(child, nProcess=cpu_count(), startDate=None, endDate=None, by_da
66 for process in processes:
66 for process in processes:
67 process.join()
67 process.join()
68 process.terminate()
68 process.terminate()
69 sys.exit()
69 #sys.exit()
70
70
71
71
72 class ParameterConf():
72 class ParameterConf():
Show file before | Show file after | Hide comments
@@ -3,7 +3,7 import argparse
3 from schainpy.controller import Project, multiSchain
3 from schainpy.controller import Project, multiSchain
4
4
5 desc = "HF_EXAMPLE"
5 desc = "HF_EXAMPLE"
6
6 path='/home/ci-81/Documents/DATA/HFADATA/hfdata_2017/pdata/sp1_f0'
7 def fiber(cursor, skip, q, dt):
7 def fiber(cursor, skip, q, dt):
8
8
9 controllerObj = Project()
9 controllerObj = Project()
@@ -11,7 +11,7 def fiber(cursor, skip, q, dt):
11 controllerObj.setup(id='191', name='test01', description=desc)
11 controllerObj.setup(id='191', name='test01', description=desc)
12
12
13 readUnitConfObj = controllerObj.addReadUnit(datatype='SpectraReader',
13 readUnitConfObj = controllerObj.addReadUnit(datatype='SpectraReader',
14 path='/home/nanosat/data/julia',
14 path=path,
15 startDate=dt,
15 startDate=dt,
16 endDate=dt,
16 endDate=dt,
17 startTime="00:00:00",
17 startTime="00:00:00",
@@ -29,6 +29,8 def fiber(cursor, skip, q, dt):
29 # #opObj11 = readUnitConfObj.addOperation(name='printNumberOfBlock')
29 # #opObj11 = readUnitConfObj.addOperation(name='printNumberOfBlock')
30 #
30 #
31 procUnitConfObj2 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId())
31 procUnitConfObj2 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId())
32 opObj10 = procUnitConfObj2.addOperation(name='removeInterference')
33
32 # procUnitConfObj2.addParameter(name='nipp', value='5', format='int')
34 # procUnitConfObj2.addParameter(name='nipp', value='5', format='int')
33
35
34 procUnitConfObj3 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=readUnitConfObj.getId())
36 procUnitConfObj3 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=readUnitConfObj.getId())
@@ -44,13 +46,13 def fiber(cursor, skip, q, dt):
44 # opObj11.addParameter(name='save', value='1', format='int')
46 # opObj11.addParameter(name='save', value='1', format='int')
45 # opObj11.addParameter(name='figpath', value=figpath, format='str')
47 # opObj11.addParameter(name='figpath', value=figpath, format='str')
46
48
47 opObj11 = procUnitConfObj3.addOperation(name='Parameters1Plot', optype='other')
49 # opObj11 = procUnitConfObj3.addOperation(name='Parameters1Plot', optype='other')
48 opObj11.addParameter(name='channelList', value='0', format='intList')
50 # opObj11.addParameter(name='channelList', value='0', format='intList')
49
51
50 opObj11.addParameter(name='id', value='2000', format='int')
52 # opObj11.addParameter(name='id', value='2000', format='int')
51 # opObj11.addParameter(name='colormap', value='0', format='bool')
53 # opObj11.addParameter(name='colormap', value='0', format='bool')
52 opObj11.addParameter(name='onlySNR', value='1', format='bool')
54 # opObj11.addParameter(name='onlySNR', value='1', format='bool')
53 opObj11.addParameter(name='DOP', value='0', format='bool')
55 # opObj11.addParameter(name='DOP', value='0', format='bool')
54 # opObj11.addParameter(name='showSNR', value='1', format='bool')
56 # opObj11.addParameter(name='showSNR', value='1', format='bool')
55 # opObj11.addParameter(name='SNRthresh', value='0', format='int')
57 # opObj11.addParameter(name='SNRthresh', value='0', format='int')
56 # opObj11.addParameter(name='SNRmin', value='-10', format='int')
58 # opObj11.addParameter(name='SNRmin', value='-10', format='int')
@@ -68,6 +70,7 def fiber(cursor, skip, q, dt):
68 # # opObj11.addParameter(name='figpath', value='/tmp/', format='str')
70 # # opObj11.addParameter(name='figpath', value='/tmp/', format='str')
69 #
71 #
70 opObj12 = procUnitConfObj3.addOperation(name='PublishData', optype='other')
72 opObj12 = procUnitConfObj3.addOperation(name='PublishData', optype='other')
73 #opObj12.addParameter(name='server', value='tcp://10.10.10.82:3001', format='int')
71 opObj12.addParameter(name='zeromq', value=1, format='int')
74 opObj12.addParameter(name='zeromq', value=1, format='int')
72
75
73
76
@@ -75,7 +78,7 def fiber(cursor, skip, q, dt):
75 # opObj13.addParameter(name='zeromq', value=1, format='int')
78 # opObj13.addParameter(name='zeromq', value=1, format='int')
76 # opObj13.addParameter(name='server', value="juanca", format='str')
79 # opObj13.addParameter(name='server', value="juanca", format='str')
77
80
78 opObj12.addParameter(name='delay', value=1, format='int')
81 # opObj12.addParameter(name='delay', value=1, format='int')
79
82
80
83
81 # print "Escribiendo el archivo XML"
84 # print "Escribiendo el archivo XML"
@@ -93,4 +96,4 if __name__ == '__main__':
93 parser = argparse.ArgumentParser(description='Set number of parallel processes')
96 parser = argparse.ArgumentParser(description='Set number of parallel processes')
94 parser.add_argument('--nProcess', default=1, type=int)
97 parser.add_argument('--nProcess', default=1, type=int)
95 args = parser.parse_args()
98 args = parser.parse_args()
96 multiSchain(fiber, nProcess=args.nProcess, startDate='2015/09/26', endDate='2015/09/26')
99 multiSchain(fiber, nProcess=8, startDate='2017/02/10', endDate='2017/02/12')
Show file before | Show file after | Hide comments
@@ -15,43 +15,63 if __name__ == '__main__':
15 controllerObj.setup(id='191', name='test01', description=desc)
15 controllerObj.setup(id='191', name='test01', description=desc)
16
16
17 proc1 = controllerObj.addProcUnit(name='ReceiverData')
17 proc1 = controllerObj.addProcUnit(name='ReceiverData')
18 proc1.addParameter(name='realtime', value='0', format='bool')
18 # proc1.addParameter(name='realtime', value='0', format='bool')
19 proc1.addParameter(name='plottypes', value='rti,coh,phase,snr,dop', format='str')
19 #proc1.addParameter(name='plottypes', value='rti,coh,phase,snr,dop', format='str')
20 proc1.addParameter(name='plottypes', value='rti,coh,phase,snr', format='str')
20 proc1.addParameter(name='throttle', value='10', format='int')
21 proc1.addParameter(name='throttle', value='10', format='int')
21 proc1.addParameter(name='plot_server', value='tcp://10.10.10.82:7000', format='str')
22 #proc1.addParameter(name='server', value='tcp://10.10.10.82:7000', format='str')
22 ## TODO Agregar direccion de server de publicacion a graficos como variable
23 ## TODO Agregar direccion de server de publicacion a graficos como variable
23
24
24 op1 = proc1.addOperation(name='PlotRTIData', optype='other')
25 op1 = proc1.addOperation(name='PlotRTIData', optype='other')
25 op1.addParameter(name='wintitle', value='Julia 150Km', format='str')
26 op1.addParameter(name='wintitle', value='HF System', format='str')
26 op1.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
27 op1.addParameter(name='save', value='/home/ci-81/Pictures', format='str')
27 op1.addParameter(name='show', value='0', format='bool')
28 op1.addParameter(name='show', value='0', format='bool')
29 op1.addParameter(name='zmin', value='-110', format='float')
30 op1.addParameter(name='zmax', value='-50', format='float')
28 op1.addParameter(name='colormap', value='jet', format='str')
31 op1.addParameter(name='colormap', value='jet', format='str')
29 #
32 #
30 op2 = proc1.addOperation(name='PlotCOHData', optype='other')
33 op2 = proc1.addOperation(name='PlotCOHData', optype='other')
31 op2.addParameter(name='wintitle', value='Julia 150Km', format='str')
34 op2.addParameter(name='wintitle', value='HF System', format='str')
32 op2.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
35 op2.addParameter(name='zmin', value='0.001', format='float')
36 op2.addParameter(name='zmax', value='1', format='float')
37 op2.addParameter(name='save', value='/home/ci-81/Pictures', format='str')
33 op2.addParameter(name='colormap', value='jet', format='str')
38 op2.addParameter(name='colormap', value='jet', format='str')
34 op2.addParameter(name='show', value='0', format='bool')
39 op2.addParameter(name='show', value='0', format='bool')
35 # #
40 # #
41
36 op6 = proc1.addOperation(name='PlotPHASEData', optype='other')
42 op6 = proc1.addOperation(name='PlotPHASEData', optype='other')
37 op6.addParameter(name='wintitle', value='Julia 150Km', format='str')
43 op6.addParameter(name='wintitle', value='HF System', format='str')
38 op6.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
44 op6.addParameter(name='save', value='/home/ci-81/Pictures', format='str')
39 op6.addParameter(name='show', value='1', format='bool')
45 op6.addParameter(name='show', value='1', format='bool')
40 #
46 #
47
41 # proc2 = controllerObj.addProcUnit(name='ReceiverData')
48 # proc2 = controllerObj.addProcUnit(name='ReceiverData')
42 # proc2.addParameter(name='server', value='juanca', format='str')
49 # proc2.addParameter(name='server', value='juanca', format='str')
43 # proc2.addParameter(name='plottypes', value='snr,dop', format='str')
50 # proc2.addParameter(name='plottypes', value='snr,dop', format='str')
44 #
51 #
45 op3 = proc1.addOperation(name='PlotSNRData', optype='other')
52 op3 = proc1.addOperation(name='PlotSNRData', optype='other')
46 op3.addParameter(name='wintitle', value='Julia 150Km', format='str')
53 op3.addParameter(name='wintitle', value='HF System SNR0', format='str')
47 op3.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
54 op3.addParameter(name='save', value='/home/ci-81/Pictures', format='str')
48 op3.addParameter(name='show', value='0', format='bool')
55 op3.addParameter(name='show', value='0', format='bool')
56 op3.addParameter(name='zmin', value='-10', format='int')
57 op3.addParameter(name='zmax', value='30', format='int')
58 op3.addParameter(name='SNRthresh', value='0', format='float')
49 #
59 #
50 op4 = proc1.addOperation(name='PlotDOPData', optype='other')
60 """
51 op4.addParameter(name='wintitle', value='Julia 150Km', format='str')
61 op4 = proc1.addOperation(name='PlotSNRData1', optype='other')
52 op4.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
62 op4.addParameter(name='wintitle', value='HF System SNR1', format='str')
63 op4.addParameter(name='save', value='/home/ci-81/Pictures', format='str')
53 op4.addParameter(name='show', value='0', format='bool')
64 op4.addParameter(name='show', value='0', format='bool')
54 op4.addParameter(name='colormap', value='jet', format='str')
65
66
67 op5 = proc1.addOperation(name='PlotDOPData', optype='other')
68 op5.addParameter(name='wintitle', value='HF System DOP', format='str')
69 op5.addParameter(name='save', value='/home/ci-81/Pictures', format='str')
70 op5.addParameter(name='show', value='0', format='bool')
71 op5.addParameter(name='colormap', value='jet', format='str')
72 """
73
74
55
75
56
76
57
77
Show file before | Show file after | Hide comments
@@ -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/julia" /><Parameter format="date" id="191113" name="startDate" value="2015/09/26" /><Parameter format="date" id="191114" name="endDate" value="2015/09/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="0" /><Parameter format="int" id="191119" name="skip" value="0" /><Parameter format="int" id="191120" name="delay" value="10" /><Parameter format="int" id="191121" name="walk" 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="Parameters1Plot" priority="3" type="other"><Parameter format="intlist" id="191331" name="channelList" value="0" /><Parameter format="int" id="191332" name="id" value="2000" /><Parameter format="bool" id="191333" name="onlySNR" value="1" /><Parameter format="bool" id="191334" name="DOP" value="0" /></Operation><Operation id="19134" name="PublishData" priority="4" type="other"><Parameter format="int" id="191341" name="zeromq" value="1" /><Parameter format="int" id="191342" name="delay" value="1" /></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/ci-81/Documents/DATA/HFADATA/hfdata_2017/pdata/sp1_f0" /><Parameter format="date" id="191113" name="startDate" value="2017/02/12" /><Parameter format="date" id="191114" name="endDate" value="2017/02/12" /><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="9" /><Parameter format="int" id="191119" name="skip" value="90" /><Parameter format="int" id="191120" name="delay" value="10" /><Parameter format="int" id="191121" name="walk" 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" /></Operation></ProcUnit><ProcUnit datatype="Spectra" id="1912" inputId="1911" name="SpectraProc"><Operation id="19121" name="run" priority="1" type="self" /><Operation id="19122" name="removeInterference" priority="2" type="self" /></ProcUnit></Project> No newline at end of file
General Comments 0
You need to be logged in to leave comments. Login now