##// END OF EJS Templates
schain
RSS
Ultima version estable de Signal Chain con envio FTP
Alexander Valdez -
r574:7052e0f65550
parent child
Show More
Show file before | Show file after | Hide comments
@@ -1,159 +1,185
1 import os, sys
1 import os, sys
2 #import timeit
2 import numpy
3 import datetime
4
5 path = os.path.split(os.getcwd())[0]
3 path = os.path.split(os.getcwd())[0]
4 path = os.path.split(path)[0]
5
6 sys.path.append(path)
6 sys.path.append(path)
7
7
8 from controller import *
8 from schainpy.controller import Project
9
9
10 desc = "150 km Jicamarca January 2015"
10 desc = "150 km Jicamarca January 2015"
11 filename = "150km_jicamarca.xml"
11 filename = "150km_jicamarca.xml"
12
12
13 controllerObj = Project()
13 controllerObj = Project()
14
14
15 controllerObj.setup(id = '191', name='test01', description=desc)
15 controllerObj.setup(id = '191', name='test01', description=desc)
16
16
17 path = '/home/operaciones/150km_jicamarca_january/RAW_EXP/2015_ISR'
17 #path = '/home/operaciones/150km_jicamarca_january/RAW_EXP/2015_ISR'
18 #path = '/media/DATOS/2015_ISR'
18 path = '/media/DATOS/2015_ISR'
19 #path = '/media/New Volume2/DATA/RAW_EXP/2015_ISR'
19 #path = '/media/New Volume2/DATA/RAW_EXP/2015_ISR'
20
20
21 figpath = '/home/operaciones/Pictures/150km_jicamarca_january'
21 figpath = '/home/operaciones/Pictures/150km_jicamarca_january'
22
22
23 remotefolder = "/home/wmaster/graficos"
24
23 readUnitConfObj = controllerObj.addReadUnit(datatype='VoltageReader',
25 readUnitConfObj = controllerObj.addReadUnit(datatype='VoltageReader',
24 path=path,
26 path=path,
25 startDate='2015/01/13',
27 startDate='2015/01/13',
26 endDate='2015/01/30',
28 endDate='2015/01/30',
27 startTime='07:55:00',
29 startTime='07:55:00',
28 endTime='23:59:59',
30 endTime='23:59:59',
29 online=1,
31 online=0,
30 delay=10,
32 delay=10,
31 walk=1)
33 walk=1)
32
34
33 opObj11 = readUnitConfObj.addOperation(name='printNumberOfBlock')
35 opObj11 = readUnitConfObj.addOperation(name='printNumberOfBlock')
34
36
35 procUnitConfObj0 = controllerObj.addProcUnit(datatype='VoltageProc', inputId=readUnitConfObj.getId())
37 procUnitConfObj0 = controllerObj.addProcUnit(datatype='VoltageProc', inputId=readUnitConfObj.getId())
36 a=[]
38 a=[]
37 for i in range(85):
39 for i in range(85):
38 if i>20:
40 if i>20:
39 a.append(i)
41 a.append(i)
40 for i in range(170):
42 for i in range(170):
41 if i>105:
43 if i>105:
42 a.append(i)
44 a.append(i)
43 for i in range(255):
45 for i in range(255):
44 if i>190:
46 if i>190:
45 a.append(i)
47 a.append(i)
46 for i in range(340):
48 for i in range(340):
47 if 339>i>275:
49 if 339>i>275:
48 a.append(i)
50 a.append(i)
49 if i==339:
51 if i==339:
50 a.append(i)
52 a.append(i)
51
53
52 b= str(a)
54 b= str(a)
53 profileIndex = b[1:][:-1]
55 profileIndex = b[1:][:-1]
54
56
55 opObj11 = procUnitConfObj0.addOperation(name='ProfileSelector', optype='other')
57 opObj11 = procUnitConfObj0.addOperation(name='ProfileSelector', optype='other')
56 #profileIndex = '0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19'
58 #profileIndex = '0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19'
57 opObj11.addParameter(name='profileList', value=profileIndex, format='intlist')
59 opObj11.addParameter(name='profileList', value=profileIndex, format='intlist')
58
60
59
61
60 # opObj11 = procUnitConfObj0.addOperation(name='ProfileSelector', optype='other')
62 # opObj11 = procUnitConfObj0.addOperation(name='ProfileSelector', optype='other')
61 # opObj11.addParameter(name='profileRangeList', value='21,84', format='intlist')
63 # opObj11.addParameter(name='profileRangeList', value='21,84', format='intlist')
62
64
63
65
64 binary28="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"
66 binary28="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"
65
67
66
68
67 CODEB=numpy.array([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])
69 CODEB=numpy.array([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])
68 x= numpy.array([ CODEB,CODEB,-CODEB,-CODEB])
70 x= numpy.array([ CODEB,CODEB,-CODEB,-CODEB])
69 code= ",".join(map(str,x.flatten()))
71 code= ",".join(map(str,x.flatten()))
70
72
71 opObj11 = procUnitConfObj0.addOperation(name='Decoder', optype='other')
73 opObj11 = procUnitConfObj0.addOperation(name='Decoder', optype='other')
72 opObj11.addParameter(name='code', value=code, format='intlist')
74 opObj11.addParameter(name='code', value=code, format='intlist')
73 opObj11.addParameter(name='nCode', value='4', format='int')
75 opObj11.addParameter(name='nCode', value='4', format='int')
74 opObj11.addParameter(name='nBaud', value='28', format='int')
76 opObj11.addParameter(name='nBaud', value='28', format='int')
75
77
76 opObj11 = procUnitConfObj0.addOperation(name='deFlip')
78 opObj11 = procUnitConfObj0.addOperation(name='deFlip')
77 opObj11.addParameter(name='channelList', value='1,3,5,7', format='intlist')
79 opObj11.addParameter(name='channelList', value='1,3,5,7', format='intlist')
78
80
79 # opObj10 = procUnitConfObj0.addOperation(name='selectHeights')
81 # opObj10 = procUnitConfObj0.addOperation(name='selectHeights')
80 # opObj10.addParameter(name='minHei', value='50', format='float')
82 # opObj10.addParameter(name='minHei', value='50', format='float')
81 # opObj10.addParameter(name='maxHei', value='150', format='float')
83 # opObj10.addParameter(name='maxHei', value='150', format='float')
82
84
83 # opObj11 = procUnitConfObj0.addOperation(name='CohInt', optype='other')
85 # opObj11 = procUnitConfObj0.addOperation(name='CohInt', optype='other')
84 # opObj11.addParameter(name='n', value='4', format='float')
86 # opObj11.addParameter(name='n', value='4', format='float')
85
87
86
88
87 # opObj11 = procUnitConfObj0.addOperation(name='Scope', optype='other')
89 # opObj11 = procUnitConfObj0.addOperation(name='Scope', optype='other')
88 # opObj11.addParameter(name='id', value='10', format='int')
90 # opObj11.addParameter(name='id', value='10', format='int')
89 # opObj11.addParameter(name='wintitle', value='Voltage', format='str')
91 # opObj11.addParameter(name='wintitle', value='Voltage', format='str')
90 # opObj11.addParameter(name='zmin', value='40', format='int')
92 # opObj11.addParameter(name='zmin', value='40', format='int')
91 # opObj11.addParameter(name='zmax', value='90', format='int')
93 # opObj11.addParameter(name='zmax', value='90', format='int')
92
94
93 #opObj11 = procUnitConfObj0.addOperation(name='Decoder', optype='other')
95 #opObj11 = procUnitConfObj0.addOperation(name='Decoder', optype='other')
94
96
95 procUnitConfObj1 = controllerObj.addProcUnit(datatype='SpectraProc', inputId=procUnitConfObj0.getId())
97 procUnitConfObj1 = controllerObj.addProcUnit(datatype='SpectraProc', inputId=procUnitConfObj0.getId())
96 procUnitConfObj1.addParameter(name='nFFTPoints', value='64', format='int')
98 procUnitConfObj1.addParameter(name='nFFTPoints', value='64', format='int')
97 procUnitConfObj1.addParameter(name='nProfiles', value='64', format='int')
99 procUnitConfObj1.addParameter(name='nProfiles', value='64', format='int')
98
100
99 #procUnitConfObj1.addParameter(name='pairsList', value='(3,7),(2,6)', format='pairsList')
101 #procUnitConfObj1.addParameter(name='pairsList', value='(3,7),(2,6)', format='pairsList')
100 procUnitConfObj1.addParameter(name='pairsList', value='(1,0),(3,2),(5,4),(7,6)', format='pairsList')
102 procUnitConfObj1.addParameter(name='pairsList', value='(1,0),(3,2),(5,4),(7,6)', format='pairsList')
101
103
102 opObj11 = procUnitConfObj1.addOperation(name='IncohInt', optype='other')
104 opObj11 = procUnitConfObj1.addOperation(name='IncohInt', optype='other')
103 opObj11.addParameter(name='timeInterval', value='60', format='float')
105 opObj11.addParameter(name='timeInterval', value='60', format='float')
104
106
105 # opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other')
107 # opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other')
106 # opObj11.addParameter(name='id', value='2001', format='int')
108 # opObj11.addParameter(name='id', value='2001', format='int')
107 # opObj11.addParameter(name='wintitle', value='150km_Jicamarca', format='str')
109 # opObj11.addParameter(name='wintitle', value='150km_Jicamarca', format='str')
108 # #opObj11.addParameter(name='channelList', value='0,1,2,3,45', format='intlist')
110 # #opObj11.addParameter(name='channelList', value='0,1,2,3,45', format='intlist')
109 # # opObj11.addParameter(name='zmin', value='0', format='int')
111 # # opObj11.addParameter(name='zmin', value='0', format='int')
110 # # opObj11.addParameter(name='zmax', value='60', format='int')
112 # # opObj11.addParameter(name='zmax', value='60', format='int')
111 # opObj11.addParameter(name='figpath', value=figpath, format='str')
113 # opObj11.addParameter(name='figpath', value=figpath, format='str')
112 # opObj11.addParameter(name='exp_code', value='13', format='int')
114 # opObj11.addParameter(name='exp_code', value='13', format='int')
113
115
114 opObj11 = procUnitConfObj1.addOperation(name='CrossSpectraPlot', optype='other')
116 opObj11 = procUnitConfObj1.addOperation(name='CrossSpectraPlot', optype='other')
115 opObj11.addParameter(name='id', value='2005', format='int')
117 opObj11.addParameter(name='id', value='2005', format='int')
116 opObj11.addParameter(name='wintitle', value='CrossSpectraPlot_LongPulse', format='str')
118 opObj11.addParameter(name='wintitle', value='CrossSpectraPlot_LongPulse', format='str')
117 opObj11.addParameter(name='phase_cmap', value='jet', format='str')
119 opObj11.addParameter(name='phase_cmap', value='jet', format='str')
118 opObj11.addParameter(name='zmin', value='20', format='int')
120 opObj11.addParameter(name='zmin', value='20', format='int')
119 opObj11.addParameter(name='zmax', value='80', format='int')
121 opObj11.addParameter(name='zmax', value='80', format='int')
120 opObj11.addParameter(name='figpath', value=figpath, format='str')
122 opObj11.addParameter(name='figpath', value=figpath, format='str')
121 opObj11.addParameter(name='exp_code', value='13', format='int')
123 opObj11.addParameter(name='exp_code', value='13', format='int')
122 opObj11.addParameter(name='figpath', value=figpath, format='str')
123 opObj11.addParameter(name='wr_period', value='2', format='int')
124 opObj11.addParameter(name='wr_period', value='2', format='int')
125 opObj11.addParameter(name='save', value='1', format='int')
126 opObj11.addParameter(name='figpath', value=figpath)
127 opObj11.addParameter(name='ftp', value='1', format='int')
128
129
130
124
131
125
132
126 opObj11 = procUnitConfObj1.addOperation(name='CoherenceMap', optype='other')
133 opObj11 = procUnitConfObj1.addOperation(name='CoherenceMap', optype='other')
127 opObj11.addParameter(name='id', value='101', format='int')
134 opObj11.addParameter(name='id', value='101', format='int')
128 opObj11.addParameter(name='wintitle', value='Coherence', format='str')
135 opObj11.addParameter(name='wintitle', value='Coherence', format='str')
129 opObj11.addParameter(name='phase_cmap', value='jet', format='str')
136 opObj11.addParameter(name='phase_cmap', value='jet', format='str')
130
137
131 opObj11.addParameter(name='xmin', value='0', format='int')
138 opObj11.addParameter(name='xmin', value='0', format='int')
132 opObj11.addParameter(name='xmax', value='24', format='int')
139 opObj11.addParameter(name='xmax', value='24', format='int')
133 opObj11.addParameter(name='figpath', value=figpath, format='str')
140 opObj11.addParameter(name='exp_code', value='13', format='int')
134 opObj11.addParameter(name='wr_period', value='2', format='int')
141 opObj11.addParameter(name='wr_period', value='2', format='int')
142 opObj11.addParameter(name='save', value='1', format='int')
143 opObj11.addParameter(name='figpath', value=figpath)
144 opObj11.addParameter(name='ftp', value='1', format='int')
145
146
147
148
149
150
135
151
136 # opObj11 = procUnitConfObj1.addOperation(name='RTIPlot', optype='other')
152 # opObj11 = procUnitConfObj1.addOperation(name='RTIPlot', optype='other')
137 # opObj11.addParameter(name='id', value='3002', format='int')
153 # opObj11.addParameter(name='id', value='3002', format='int')
138 # opObj11.addParameter(name='wintitle', value='150km_Jicamarca_LongPulse', format='str')
154 # opObj11.addParameter(name='wintitle', value='150km_Jicamarca_LongPulse', format='str')
139 # # opObj11.addParameter(name='xmin', value='20.5', format='float')
155 # # opObj11.addParameter(name='xmin', value='20.5', format='float')
140 # # opObj11.addParameter(name='xmax', value='24', format='float')
156 # # opObj11.addParameter(name='xmax', value='24', format='float')
141 # opObj11.addParameter(name='zmin', value='20', format='int')
157 # opObj11.addParameter(name='zmin', value='20', format='int')
142 # opObj11.addParameter(name='zmax', value='80', format='int')
158 # opObj11.addParameter(name='zmax', value='80', format='int')
143 # #opObj11.addParameter(name='channelList', value='0,1,2,3', format='intlist')
159 # #opObj11.addParameter(name='channelList', value='0,1,2,3', format='intlist')
144 # #opObj11.addParameter(name='channelList', value='0,1,2,3,4,5,6,7', format='intlist')
160 # #opObj11.addParameter(name='channelList', value='0,1,2,3,4,5,6,7', format='intlist')
145 # opObj11.addParameter(name='showprofile', value='0', format='int')
161 # opObj11.addParameter(name='showprofile', value='0', format='int')
146 # opObj11.addParameter(name='figpath', value=figpath, format='str')
162 # opObj11.addParameter(name='figpath', value=figpath, format='str')
147 # opObj11.addParameter(name='exp_code', value='13', format='int')
163 # opObj11.addParameter(name='exp_code', value='13', format='int')
148
164
165 procUnitConfObj2 = controllerObj.addProcUnit(name='SendToServer')
166 procUnitConfObj2.addParameter(name='server', value='jro-app.igp.gob.pe', format='str')
167 procUnitConfObj2.addParameter(name='username', value='wmaster', format='str')
168 procUnitConfObj2.addParameter(name='password', value='mst2010vhf', format='str')
169 procUnitConfObj2.addParameter(name='localfolder', value=figpath, format='str')
170 procUnitConfObj2.addParameter(name='remotefolder', value=remotefolder, format='str')
171 procUnitConfObj2.addParameter(name='ext', value='.png', format='str')
172 procUnitConfObj2.addParameter(name='period', value=60, format='int')
173 procUnitConfObj2.addParameter(name='protocol', value='ftp', format='str')
174
149 print "Escribiendo el archivo XML"
175 print "Escribiendo el archivo XML"
150 controllerObj.writeXml(filename)
176 controllerObj.writeXml(filename)
151 print "Leyendo el archivo XML"
177 print "Leyendo el archivo XML"
152 controllerObj.readXml(filename)
178 controllerObj.readXml(filename)
153
179
154 controllerObj.createObjects()
180 controllerObj.createObjects()
155 controllerObj.connectObjects()
181 controllerObj.connectObjects()
156
182
157 #timeit.timeit('controllerObj.run()', number=2)
183 #timeit.timeit('controllerObj.run()', number=2)
158
184
159 controllerObj.run() No newline at end of file
185 controllerObj.run()
General Comments 0
You need to be logged in to leave comments. Login now