@@ -0,0 +1,205 | |||
|
1 | #! /usr/bin/python | |
|
2 | #! /usr/bin/env python | |
|
3 | ||
|
4 | import os, sys | |
|
5 | import time | |
|
6 | ||
|
7 | path = os.path.dirname(os.getcwd()) | |
|
8 | path = os.path.dirname(path) | |
|
9 | sys.path.insert(0, path) | |
|
10 | ||
|
11 | from schainpy.controller import Project | |
|
12 | ||
|
13 | desc = "AMISR Experiment" | |
|
14 | ||
|
15 | filename = "amisr_reader.xml" | |
|
16 | ||
|
17 | controllerObj = Project() | |
|
18 | ||
|
19 | controllerObj.setup(id = '191', name='eej_proc', description=desc) | |
|
20 | ||
|
21 | ||
|
22 | path = os.path.join(os.environ['HOME'],'amisr') | |
|
23 | # path = '/media/signalchain/HD-PXU2/AMISR_JULIA_MODE' | |
|
24 | # path = '/media/soporte/E9F4-F053/AMISR/Data/NoiseTest/EEJ' | |
|
25 | # path = '/media/soporte/E9F4-F053/AMISR/Data/EEJ' | |
|
26 | path = '/mnt/data_amisr' | |
|
27 | #path = '/media/soporte/AMISR_104' | |
|
28 | #figpath = os.path.join(os.environ['HOME'],'Pictures/amisr/test/proc/eej') | |
|
29 | #figpath = '/media/soporte/E9F4-F053/AMISR/Data/JULIA/EEJ' | |
|
30 | figpath = '/home/soporte/Data/EEJ' | |
|
31 | remotefolder = "/home/wmaster/graficos" | |
|
32 | ||
|
33 | xmin = '07' | |
|
34 | xmax = '18' | |
|
35 | ymin ='30' | |
|
36 | ymax ='300' | |
|
37 | dbmin = '45' #'60'#'55' #'40' #noise esf eej | |
|
38 | dbmax = '65' #'70' #'55' | |
|
39 | show = '1' | |
|
40 | ||
|
41 | 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' | |
|
42 | nCode = '1' | |
|
43 | nBaud = '28' | |
|
44 | ||
|
45 | ||
|
46 | today = time.strftime("%Y/%m/%d") | |
|
47 | ||
|
48 | ||
|
49 | readUnitConfObj = controllerObj.addReadUnit(datatype='AMISRReader', | |
|
50 | path=path, | |
|
51 | startDate=today, #'2014/10/07', | |
|
52 | endDate=today, #'2014/10/07', | |
|
53 | startTime='07:01:30',#'07:00:00', | |
|
54 | endTime='17:55:00',#'15:00:00', | |
|
55 | walk=0, | |
|
56 | code = code, | |
|
57 | nCode = nCode, | |
|
58 | nBaud = nBaud, | |
|
59 | timezone='lt', | |
|
60 | online=1) | |
|
61 | ||
|
62 | #AMISR Processing Unit | |
|
63 | ||
|
64 | #Voltage Processing Unit | |
|
65 | procUnitConfObjBeam0 = controllerObj.addProcUnit(datatype='VoltageProc', inputId=readUnitConfObj.getId()) | |
|
66 | opObj10 = procUnitConfObjBeam0.addOperation(name='setRadarFrequency') | |
|
67 | opObj10.addParameter(name='frequency', value='445e6', format='float') #changed on Dic 3, 15:40h | |
|
68 | #opObj10.addParameter(name='frequency', value='440e6', format='float') | |
|
69 | ||
|
70 | # opObj12 = procUnitConfObjBeam0.addOperation(name='selectHeights') | |
|
71 | # opObj12.addParameter(name='minHei', value='0', format='float') | |
|
72 | ||
|
73 | ||
|
74 | opObj11 = procUnitConfObjBeam0.addOperation(name='Decoder', optype='other') | |
|
75 | opObj11.addParameter(name='code', value=code, format='floatlist') | |
|
76 | opObj11.addParameter(name='nCode', value=nCode, format='int') | |
|
77 | opObj11.addParameter(name='nBaud', value=nBaud, format='int') | |
|
78 | ||
|
79 | ||
|
80 | #Spectra Unit Processing, getting spectras with nProfiles and nFFTPoints | |
|
81 | procUnitConfObjSpectraBeam0 = controllerObj.addProcUnit(datatype='SpectraProc', inputId=procUnitConfObjBeam0.getId()) | |
|
82 | procUnitConfObjSpectraBeam0.addParameter(name='nFFTPoints', value=16, format='int') | |
|
83 | # | |
|
84 | opObj11 = procUnitConfObjSpectraBeam0.addOperation(name='IncohInt', optype='other') | |
|
85 | opObj11.addParameter(name='n', value='150', format='int') | |
|
86 | #opObj11.addParameter(name='timeInterval', value='30', format='float') | |
|
87 | ||
|
88 | ||
|
89 | ||
|
90 | #Noise Estimation | |
|
91 | opObj11 = procUnitConfObjSpectraBeam0.addOperation(name='getNoise') | |
|
92 | opObj11.addParameter(name='minHei', value='100', format='float') | |
|
93 | opObj11.addParameter(name='maxHei', value='280', format='float') | |
|
94 | #opObj11.addParameter(name='minHei', value='15', format='float') | |
|
95 | #opObj11.addParameter(name='maxHei', value='20', format='float') | |
|
96 | ||
|
97 | ||
|
98 | #SpectraPlot | |
|
99 | opObj11 = procUnitConfObjSpectraBeam0.addOperation(name='SpectraPlot', optype='other') | |
|
100 | opObj11.addParameter(name='id', value='1', format='int') | |
|
101 | opObj11.addParameter(name='wintitle', value='EEJ AMISR', format='str') | |
|
102 | opObj11.addParameter(name='ymin', value=ymin, format='int') | |
|
103 | opObj11.addParameter(name='ymax', value=ymax, format='int') | |
|
104 | opObj11.addParameter(name='zmin', value=dbmin, format='int') | |
|
105 | opObj11.addParameter(name='zmax', value=dbmax, format='int') | |
|
106 | opObj11.addParameter(name='save', value='0', format='bool') | |
|
107 | opObj11.addParameter(name='figpath', value = figpath, format='str') | |
|
108 | opObj11.addParameter(name='ftp', value='1', format='int') | |
|
109 | opObj11.addParameter(name='wr_period', value='2', format='int') | |
|
110 | opObj11.addParameter(name='exp_code', value='21', format='int') | |
|
111 | opObj11.addParameter(name='sub_exp_code', value='3', format='int') | |
|
112 | opObj11.addParameter(name='ftp_wei', value='0', format='int') | |
|
113 | opObj11.addParameter(name='plot_pos', value='0', format='int') | |
|
114 | ||
|
115 | # #RTIPlot | |
|
116 | # #title0 = 'RTI AMISR Beam 0' | |
|
117 | opObj11 = procUnitConfObjSpectraBeam0.addOperation(name='RTIPlot', optype='other') | |
|
118 | opObj11.addParameter(name='id', value='2', format='int') | |
|
119 | opObj11.addParameter(name='wintitle', value='EEJ AMISR', format='str') | |
|
120 | opObj11.addParameter(name='showprofile', value='0', format='int') | |
|
121 | opObj11.addParameter(name='xmin', value=xmin, format='float') | |
|
122 | opObj11.addParameter(name='xmax', value=xmax, format='float') | |
|
123 | opObj11.addParameter(name='ymin', value=ymin, format='int') | |
|
124 | opObj11.addParameter(name='ymax', value=ymax, format='int') | |
|
125 | opObj11.addParameter(name='zmin', value=dbmin, format='int') | |
|
126 | opObj11.addParameter(name='zmax', value=dbmax, format='int') | |
|
127 | opObj11.addParameter(name='save', value='1', format='bool') | |
|
128 | opObj11.addParameter(name='figpath', value = figpath, format='str') | |
|
129 | opObj11.addParameter(name='show', value = show, format='bool') | |
|
130 | opObj11.addParameter(name='ftp', value='1', format='int') | |
|
131 | opObj11.addParameter(name='wr_period', value='2', format='int') | |
|
132 | opObj11.addParameter(name='exp_code', value='21', format='int') | |
|
133 | opObj11.addParameter(name='sub_exp_code', value='3', format='int') | |
|
134 | opObj11.addParameter(name='ftp_wei', value='0', format='int') | |
|
135 | opObj11.addParameter(name='plot_pos', value='0', format='int') | |
|
136 | ||
|
137 | # #send to server | |
|
138 | procUnitConfObj2 = controllerObj.addProcUnit(name='SendToServer') | |
|
139 | #procUnitConfObj2.addParameter(name='server', value='jro-app.igp.gob.pe', format='str') | |
|
140 | procUnitConfObj2.addParameter(name='server', value='10.10.120.125', format='str') | |
|
141 | procUnitConfObj2.addParameter(name='username', value='wmaster', format='str') | |
|
142 | procUnitConfObj2.addParameter(name='password', value='mst2010vhf', format='str') | |
|
143 | procUnitConfObj2.addParameter(name='localfolder', value=figpath, format='str') | |
|
144 | procUnitConfObj2.addParameter(name='remotefolder', value=remotefolder, format='str') | |
|
145 | procUnitConfObj2.addParameter(name='ext', value='.png', format='str') | |
|
146 | procUnitConfObj2.addParameter(name='period', value='300', format='int') | |
|
147 | procUnitConfObj2.addParameter(name='protocol', value='ssh', format='str') | |
|
148 | ||
|
149 | ||
|
150 | # #Noise | |
|
151 | #title0 = 'RTI AMISR Beam 0' | |
|
152 | # opObj11 = procUnitConfObjSpectraBeam0.addOperation(name='Noise', optype='other') | |
|
153 | # opObj11.addParameter(name='id', value='3', format='int') | |
|
154 | # opObj11.addParameter(name='wintitle', value='EEJ AMISR', format='str') | |
|
155 | # opObj11.addParameter(name='showprofile', value='0', format='int') | |
|
156 | # opObj11.addParameter(name='xmin', value=xmin, format='float') | |
|
157 | # opObj11.addParameter(name='xmax', value=xmax, format='float') | |
|
158 | # opObj11.addParameter(name='ymin', value=dbmin, format='int') | |
|
159 | # opObj11.addParameter(name='ymax', value=dbmax, format='int') | |
|
160 | # opObj11.addParameter(name='save', value='0', format='bool') | |
|
161 | # opObj11.addParameter(name='figpath', value = figpath, format='str') | |
|
162 | # opObj11.addParameter(name='show', value = show, format='bool') | |
|
163 | ||
|
164 | ||
|
165 | # #For saving Pdata (doesn't work with amisr data yet!) | |
|
166 | # opObj11 = procUnitConfObjSpectraBeam0.addOperation(name='SpectraWriter', optype='other') | |
|
167 | # opObj11.addParameter(name='path', value=figpath) | |
|
168 | # opObj11.addParameter(name='blocksPerFile', value='10', format='int') | |
|
169 | # opObj11.addParameter(name='datatype', value="4", format="int") #size of data to be saved | |
|
170 | # | |
|
171 | # | |
|
172 | # # procUnitConfObj2 = controllerObj.addProcUnit(name='SendToServer') | |
|
173 | # # procUnitConfObj2.addParameter(name='server', value='jro-app.igp.gob.pe', format='str') | |
|
174 | # # procUnitConfObj2.addParameter(name='username', value='wmaster', format='str') | |
|
175 | # # procUnitConfObj2.addParameter(name='password', value='mst2010vhf', format='str') | |
|
176 | # # procUnitConfObj2.addParameter(name='localfolder', value=pathFigure, format='str') | |
|
177 | # # procUnitConfObj2.addParameter(name='remotefolder', value=remotefolder, format='str') | |
|
178 | # # procUnitConfObj2.addParameter(name='ext', value='.png', format='str') | |
|
179 | # # procUnitConfObj2.addParameter(name='period', value=5, format='int') | |
|
180 | # # procUnitConfObj2.addParameter(name='protocol', value='ftp', format='str') | |
|
181 | # #----------------------------------------------------------------------------------------------- | |
|
182 | # procUnitConfObj2 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=procUnitConfObjSpectraBeam0.getId()) | |
|
183 | # opObj20 = procUnitConfObj2.addOperation(name='GetMoments') | |
|
184 | # | |
|
185 | # opObj12 = procUnitConfObj2.addOperation(name='HDF5Writer', optype='other') | |
|
186 | # opObj12.addParameter(name='path', value=figpath+'/plots') | |
|
187 | # opObj12.addParameter(name='blocksPerFile', value='10', format='int') | |
|
188 | # opObj12.addParameter(name='metadataList',value='type,inputUnit,heightList',format='list') | |
|
189 | # opObj12.addParameter(name='dataList',value='data_param,data_SNR,utctime',format='list') | |
|
190 | # opObj12.addParameter(name='mode',value='1',format='int') | |
|
191 | ||
|
192 | ||
|
193 | ||
|
194 | # print "Escribiendo el archivo XML" | |
|
195 | # controllerObj.writeXml(path +'/'+filename) | |
|
196 | # print "Leyendo el archivo XML" | |
|
197 | # controllerObj.readXml(path +'/'+filename) | |
|
198 | ||
|
199 | controllerObj.createObjects() | |
|
200 | controllerObj.connectObjects() | |
|
201 | controllerObj.run() | |
|
202 | ||
|
203 | #21 3 pm | |
|
204 | ||
|
205 |
General Comments 0
You need to be logged in to leave comments.
Login now