@@ -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