##// END OF EJS Templates
schain-jc
RSS
merge con cli
José Chávez -
r1035:b65644e03ac2 merge
parent child
Show More
Side by Side Unified
Context file:
r1035:b65644e03ac2 Loading diff...:
Show file before | Show file after | Hide comments
@@ -0,0 +1,94
1 import argparse
2
3 from schainpy.controller import Project, multiSchain
4
5 desc = "HF_EXAMPLE"
6
7 def fiber(cursor, skip, q, dt):
8
9 controllerObj = Project()
10
11 controllerObj.setup(id='191', name='test01', description=desc)
12
13 readUnitConfObj = controllerObj.addReadUnit(datatype='SpectraReader',
14 path='/home/nanosat/data/julia',
15 startDate=dt,
16 endDate=dt,
17 startTime="00:00:00",
18 endTime="23:59:59",
19 online=0,
20 #set=1426485881,
21 delay=10,
22 walk=1,
23 queue=q,
24 cursor=cursor,
25 skip=skip,
26 #timezone=-5*3600
27 )
28
29 # #opObj11 = readUnitConfObj.addOperation(name='printNumberOfBlock')
30 #
31 procUnitConfObj2 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId())
32 # procUnitConfObj2.addParameter(name='nipp', value='5', format='int')
33
34 # procUnitConfObj3 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=readUnitConfObj.getId())
35 # opObj11 = procUnitConfObj3.addOperation(name='SpectralMoments', optype='other')
36
37 #
38 opObj11 = procUnitConfObj2.addOperation(name='RTIPlot', optype='other')
39 opObj11.addParameter(name='id', value='1000', format='int')
40 opObj11.addParameter(name='wintitle', value='HF_Jicamarca_Spc', format='str')
41 opObj11.addParameter(name='xmin', value='0', format='int')
42 opObj11.addParameter(name='xmax', value='24', format='int')
43
44 # opObj11 = procUnitConfObj3.addOperation(name='Parameters1Plot', optype='other')
45 # opObj11.addParameter(name='channelList', value='0', format='intList')
46 #
47 # opObj11.addParameter(name='id', value='2000', format='int')
48 # # opObj11.addParameter(name='colormap', value='0', format='bool')
49 # opObj11.addParameter(name='onlySNR', value='1', format='bool')
50 # opObj11.addParameter(name='DOP', value='0', format='bool')
51 # opObj11.addParameter(name='showSNR', value='1', format='bool')
52 # opObj11.addParameter(name='SNRthresh', value='0', format='int')
53 # opObj11.addParameter(name='SNRmin', value='-10', format='int')
54 # opObj11.addParameter(name='SNRmax', value='30', format='int')
55
56 # opObj11.addParameter(name='showSNR', value='1', format='int')
57 # # opObj11.addParameter(name='channelList', value='0', format='intlist')
58 # # opObj11.addParameter(name='xmin', value='0', format='float')
59 # opObj11.addParameter(name='xmin', value='0', format='float')
60 # opObj11.addParameter(name='xmax', value='24', format='float')
61
62 # opObj11.addParameter(name='zmin', value='-110', format='float')
63 # opObj11.addParameter(name='zmax', value='-70', format='float')
64 # opObj11.addParameter(name='save', value='0', format='int')
65 # # opObj11.addParameter(name='figpath', value='/tmp/', format='str')
66 #
67 # opObj12 = procUnitConfObj2.addOperation(name='PublishData', optype='other')
68 # opObj12.addParameter(name='zeromq', value=1, format='int')
69 # opObj12.addParameter(name='server', value='tcp://10.10.10.82:7000', format='str')
70
71
72 # opObj13 = procUnitConfObj3.addOperation(name='PublishData', optype='other')
73 # opObj13.addParameter(name='zeromq', value=1, format='int')
74 # opObj13.addParameter(name='server', value="juanca", format='str')
75
76 # opObj12.addParameter(name='delay', value=1, format='int')
77
78
79 # print "Escribiendo el archivo XML"
80 # controllerObj.writeXml(filename)
81 # print "Leyendo el archivo XML"
82 # controllerObj.readXml(filename)
83
84
85 # timeit.timeit('controllerObj.run()', number=2)
86
87 controllerObj.start()
88
89
90 if __name__ == '__main__':
91 parser = argparse.ArgumentParser(description='Set number of parallel processes')
92 parser.add_argument('--nProcess', default=1, type=int)
93 args = parser.parse_args()
94 multiSchain(fiber, nProcess=args.nProcess, startDate='2016/08/19', endDate='2016/08/19')
Show file before | Show file after | Hide comments
@@ -0,0 +1,6
1 [Desktop Entry]
2 Encoding=UTF-8
3 Name=Link to
4 Type=Link
5 URL=file:///home/nanosat/schain/schainpy/utils/parameters.txt
6 Icon=text-plain
Show file before | Show file after | Hide comments
This diff has been collapsed as it changes many lines, (1177 lines changed) Show them Hide them
@@ -0,0 +1,1177
1
2 global_type_string = 'string'
3 global_type_integer = 'int'
4 global_type_floatList = 'floatList'
5 global_type_pairsList = 'pairsList'
6 global_type_boolean = 'bolean'
7 global_type_float = 'float'
8 global_type_colormap = 'colormap'
9 global_type_list = 'list'
10 global_type_integer_or_list = 'integer_or_list'
11
12 #BeaconPhase
13 parameters = {
14 'id': global_type_string,
15 'wintitle': global_type_string,
16 'pairsList': global_type_pairsList,
17 'showprofile': global_type_boolean,
18 'xmin': global_type_float,
19 'xmax': global_type_float,
20 'ymin': global_type_float,
21 'ymax': global_type_float,
22 'hmin': global_type_float,
23 'hmax': global_type_float,
24 'timerange': global_type_float,
25 'save': global_type_boolean,
26 'figpath': global_type_string,
27 'figfile': global_type_string,
28 'show': global_type_boolean,
29 'ftp': global_type_boolean,
30 'wr_period': global_type_integer,
31 'server': global_type_string,
32 'folder': global_type_string,
33 'username': global_type_string,
34 'password': global_type_string,
35 'ftp_wei': global_type_integer,
36 'exp_code': global_type_integer,
37 'sub_exp_code': global_type_integer,
38 'plot_pos': global_type_integer,
39 }
40
41
42 #BeamSelector
43 parameters = {
44 'beam': global_type_string,
45 }
46
47
48 #CohInt
49 parameters = {
50 'n': global_type_integer,
51 'timeInterval': global_type_float,
52 'overlapping': global_type_boolean,
53 'byblock': global_type_boolean
54 }
55
56
57 #CoherenceMap
58 parameters = {
59 'id': global_type_string,
60 'wintitle': global_type_string,
61 'pairsList': global_type_pairsList,
62 'showprofile': global_type_boolean,
63 'xmin': global_type_float,
64 'xmax': global_type_float,
65 'ymin': global_type_float,
66 'ymax': global_type_float,
67 'zmin': global_type_float,
68 'zmax': global_type_float,
69 'timerange': global_type_float,
70 'phase_min': global_type_float,
71 'phase_max': global_type_float,
72 'save': global_type_boolean,
73 'figpath': global_type_string,
74 'figfile': global_type_string,
75 'ftp': global_type_boolean,
76 'wr_period': global_type_integer,
77 'coherence_cmap': global_type_colormap,
78 'phase_cmap': global_type_colormap,
79 'show': global_type_boolean,
80 'server': global_type_string,
81 'folder': global_type_string,
82 'username': global_type_string,
83 'password': global_type_string,
84 'ftp_wei': global_type_integer,
85 'exp_code': global_type_integer,
86 'sub_exp_code': global_type_integer,
87 'plot_pos': global_type_integer,
88 }
89
90
91 #CombineProfiles
92 parameters = {
93 'n': global_type_integer,
94 }
95
96
97 #CorrectSMPhases
98 parameters = {
99 'phaseOffsets': global_type_pairsList,
100 'hmin': global_type_float,
101 'hmax': global_type_float,
102 'azimuth': global_type_float,
103 'channelPositions': global_type_pairsList,
104 }
105
106
107 #CorrelationPlot
108 parameters = {
109 'id': global_type_string,
110 'wintitle': global_type_string,
111 'channelList': global_type_list,
112 'showprofile': global_type_boolean,
113 'xmin': global_type_float,
114 'xmax': global_type_float,
115 'ymin': global_type_float,
116 'ymax': global_type_float,
117 'zmin': global_type_float,
118 'zmax': global_type_float,
119 'save': global_type_boolean,
120 'figpath': global_type_string,
121 'figfile': global_type_string,
122 'show': global_type_boolean,
123 'ftp': global_type_boolean,
124 'wr_period': global_type_integer,
125 'server': global_type_string,
126 'folder': global_type_string,
127 'username': global_type_string,
128 'password': global_type_string,
129 'ftp_wei': global_type_integer,
130 'exp_code': global_type_integer,
131 'sub_exp_code': global_type_integer,
132 'plot_pos': global_type_integer,
133 'realtime': global_type_boolean,
134 }
135
136
137 #CrossSpectraPlot
138 parameters = {
139 'id': global_type_string,
140 'wintitle': global_type_string,
141 'pairsList': global_type_pairsList,
142 'xmin': global_type_float,
143 'xmax': global_type_float,
144 'ymin': global_type_float,
145 'ymax': global_type_float,
146 'zmin': global_type_float,
147 'zmax': global_type_float,
148 'coh_min': global_type_float,
149 'coh_max': global_type_float,
150 'phase_min': global_type_float,
151 'phase_max': global_type_float,
152 'save': global_type_boolean,
153 'figpath': global_type_string,
154 'figfile': global_type_string,
155 'ftp': global_type_boolean,
156 'wr_period': global_type_integer,
157 'power_cmap': global_type_colormap,
158 'coherence_cmap': global_type_colormap,
159 'phase_cmap': global_type_colormap,
160 'show': global_type_boolean,
161 'server': global_type_string,
162 'folder': global_type_string,
163 'username': global_type_string,
164 'password': global_type_string,
165 'ftp_wei': global_type_integer,
166 'exp_code': global_type_integer,
167 'sub_exp_code': global_type_integer,
168 'plot_pos': global_type_integer,
169 'xaxis': global_type_string,
170 }
171
172
173 #Decoder
174 parameters = {
175 'code': global_type_list,
176 'nCode': global_type_integer,
177 'nBaud': global_type_integer,
178 'mode': global_type_integer,
179 'osamp': global_type_float,
180 }
181
182
183 #EWDriftsEstimation
184 parameters = {
185 'zenith': global_type_list,
186 'zenithCorrection': global_type_float,
187 }
188
189
190 #EWDriftsPlot
191 parameters = {
192 'id': global_type_string,
193 'wintitle': global_type_string,
194 'channelList': global_type_list,
195 'xmin': global_type_float,
196 'xmax': global_type_float,
197 'ymin': global_type_float,
198 'ymax': global_type_float,
199 'zmin': global_type_float,
200 'zmax': global_type_float,
201 'zmaxVertfloat': global_type_float,
202 'zminVertfloat': global_type_float,
203 'zmaxZonafloat': global_type_float,
204 'zminZonafloat': global_type_float,
205 'timerange': global_type_float,
206 'SNRthresh': global_type_float,
207 'SNRmin': global_type_float,
208 'SNRmax': global_type_float,
209 'SNR_1': global_type_boolean,
210 'save': global_type_boolean,
211 'figpath': global_type_string,
212 'lastone': global_type_float,
213 'figfile': global_type_string,
214 'ftp': global_type_string,
215 'wr_period': global_type_integer,
216 'show': global_type_string,
217 'server': global_type_string,
218 'folder': global_type_string,
219 'username': global_type_string,
220 'password': global_type_string,
221 'ftp_wei': global_type_integer,
222 'exp_code': global_type_integer,
223 'sub_exp_code': global_type_integer,
224 'plot_pos': global_type_integer,
225 }
226
227
228 Figure
229 # parameters = {
230 # : global_type_string,
231 # }
232
233
234 #FitsWriter
235 parameters = {
236 'path': global_type_string,
237 'dataBlocksPerFile': global_type_integer,
238 'metadatafile': global_type_string,
239 }
240
241
242 #IncohInt
243 parameters = {
244 'n': global_type_float,
245 'timeInterval': global_type_integer,
246 'overlapping': global_type_boolean,
247 }
248
249
250 #IncohInt4SpectraHeis
251 parameters = {
252 'n': global_type_float,
253 'timeInterval': global_type_integer,
254 'overlapping': global_type_boolean,
255 }
256
257
258 #MomentsPlot
259 parameters = {
260 'id': global_type_string,
261 'wintitle': global_type_string,
262 'channelList': global_type_list,
263 'showprofile': global_type_boolean,
264 'xmin': global_type_float,
265 'xmax': global_type_float,
266 'ymin': global_type_float,
267 'ymax': global_type_float,
268 'zmin': global_type_float,
269 'zmax': global_type_float,
270 'save': global_type_boolean,
271 'figpath': global_type_string,
272 'figfile': global_type_string,
273 'show': global_type_boolean,
274 'ftp': global_type_boolean,
275 'wr_period': global_type_integer,
276 'server': global_type_string,
277 'folder': global_type_string,
278 'username': global_type_string,
279 'password': global_type_string,
280 'ftp_wei': global_type_string,
281 'exp_code': global_type_integer,
282 'sub_exp_code': global_type_integer,
283 'plot_pos': global_type_integer,
284 'realtime': global_type_boolean,
285 }
286
287
288 #NSMeteorDetection1Plot
289 parameters = {
290 'id': global_type_string,
291 'wintitle': global_type_string,
292 'channelList': global_type_list,
293 'showprofile': global_type_boolean,
294 'xmin': global_type_float,
295 'xmax': global_type_float,
296 'ymin': global_type_float,
297 'ymax': global_type_float,
298 'SNRmin': global_type_float,
299 'SNRmax': global_type_float,
300 'vmin': global_type_float,
301 'vmax': global_type_float,
302 'wmin': global_type_float,
303 'wmax': global_type_float,
304 'mode': global_type_string,
305 'save': global_type_boolean,
306 'figpath': global_type_string,
307 'figfile': global_type_string,
308 'show': global_type_boolean,
309 'ftp': global_type_string,
310 'wr_period': global_type_integer,
311 'server': global_type_string,
312 'folder': global_type_string,
313 'username': global_type_string,
314 'password': global_type_string,
315 'ftp_wei': global_type_integer,
316 'exp_code': global_type_integer,
317 'sub_exp_code': global_type_integer,
318 'plot_pos': global_type_integer,
319 'realtime': global_type_boolean,
320 'xaxis': global_type_string,
321 }
322
323
324 #NSMeteorDetection2Plot
325 parameters = {
326 'id': global_type_string,
327 'wintitle': global_type_string,
328 'channelList': global_type_list,
329 'showprofile': global_type_boolean,
330 'xmin': global_type_float,
331 'xmax': global_type_float,
332 'ymin': global_type_float,
333 'ymax': global_type_float,
334 'SNRmin': global_type_float,
335 'SNRmax': global_type_float,
336 'vmin': global_type_float,
337 'vmax': global_type_float,
338 'wmin': global_type_float,
339 'wmax': global_type_float,
340 'mode': global_type_string,
341 'save': global_type_boolean,
342 'figpath': global_type_string,
343 'figfile': global_type_string,
344 'show': global_type_string,
345 'ftp': global_type_boolean,
346 'wr_period': global_type_integer,
347 'server': global_type_string,
348 'folder': global_type_string,
349 'username': global_type_string,
350 'password': global_type_string,
351 'ftp_wei': global_type_integer,
352 'exp_code': global_type_integer,
353 'sub_exp_code': global_type_integer,
354 'plot_pos': global_type_integer,
355 'realtime': global_type_boolean,
356 'xaxis': global_type_string,
357 }
358
359
360 #Noise
361 parameters = {
362 'id': global_type_string,
363 'wintitle': global_type_string,
364 'channelList': global_type_list,
365 'showprofile': global_type_boolean,
366 'xmin': global_type_float,
367 'xmax': global_type_float,
368 'ymin': global_type_float,
369 'ymax': global_type_float,
370 'timerange': global_type_float,
371 'save': global_type_boolean,
372 'figpath': global_type_string,
373 'figfile': global_type_string,
374 'show': global_type_boolean,
375 'ftp': global_type_boolean,
376 'wr_period': global_type_integer,
377 'server': global_type_string,
378 'folder': global_type_string,
379 'username': global_type_string,
380 'password': global_type_string,
381 'ftp_wei': global_type_integer,
382 'exp_code': global_type_integer,
383 'sub_exp_code': global_type_integer,
384 'plot_pos': global_type_integer,
385 }
386
387
388 #NonSpecularMeteorDetection
389 parameters = {
390 'mode': global_type_string,
391 'SNRthresh': global_type_float,
392 'phaseDerThresh': global_type_float,
393 'cohThresh': global_type_float,
394 'allData': global_type_boolean,
395 }
396
397
398 Operation
399 parameters = {
400 'dataIn': global_type_string,
401 }
402
403
404 #ParamWriter
405 parameters = {
406 'path': global_type_string,
407 'blocksPerFile':global_type_integer,
408 'metadataList': global_type_list,
409 'dataList': global_type_list,
410 'mode': global_type_integer,
411 }
412
413
414 #Parameters1Plot
415 parameters = {
416 'id': global_type_string,
417 'wintitle': global_type_string,
418 'channelList': global_type_list,
419 'showprofile': global_type_boolean,
420 'xmin': global_type_float,
421 'xmax': global_type_float,
422 'ymin': global_type_float,
423 'ymax': global_type_float,
424 'zmin': global_type_float,
425 'zmax': global_type_float,
426 'timerange': global_type_float,
427 'parameterIndex': global_type_float,
428 'onlyPositive': global_type_boolean,
429 'SNRthresh': global_type_float,
430 'SNR': global_type_boolean,
431 'SNRmin': global_type_float,
432 'SNRmax': global_type_float,
433 'onlySNR': global_type_boolean,
434 'DOP': global_type_boolean,
435 'zlabel': global_type_string,
436 'parameterName': global_type_string,
437 'parameterObject': global_type_string,
438 'save': global_type_boolean,
439 'figpath': global_type_string,
440 'lastone': global_type_integer,
441 'figfile': global_type_string,
442 'ftp': global_type_boolean,
443 'wr_period': global_type_integer,
444 'show': global_type_string,
445 'server': global_type_string,
446 'folder': global_type_string,
447 'username': global_type_string,
448 'password': global_type_string,
449 'ftp_wei': global_type_integer,
450 'exp_code': global_type_integer,
451 'sub_exp_code': global_type_integer,
452 'plot_pos': global_type_integer,
453 }
454
455
456 #ParametersPlot
457 parameters = {
458 'id': global_type_string,
459 'wintitle': global_type_string,
460 'channelList': global_type_list,
461 'paramIndex': global_type_integer,
462 'colormap': global_type_colormap,
463 'xmin': global_type_float,
464 'xmax': global_type_float,
465 'ymin': global_type_float,
466 'ymax': global_type_float,
467 'zmin': global_type_float,
468 'zmax': global_type_float,
469 'timerange': global_type_float,
470 'showSNR': global_type_boolean,
471 'SNRthresh': global_type_float,
472 'SNRmin': global_type_float,
473 'SNRmax': global_type_float,
474 'save': global_type_boolean,
475 'figpath': global_type_string,
476 'lastone': global_type_integer,
477 'figfile': global_type_string,
478 'ftp': global_type_boolean,
479 'wr_period': global_type_integer,
480 'show': global_type_boolean,
481 'server': global_type_string,
482 'folder': global_type_string,
483 'username': global_type_string,
484 'password': global_type_string,
485 'ftp_wei': global_type_integer,
486 'exp_code': global_type_integer,
487 'sub_exp_code': global_type_integer,
488 'plot_pos': global_type_integer,
489 }
490
491
492 #PhasePlot
493 parameters = {
494 'id': global_type_string,
495 'wintitle': global_type_string,
496 'pairsList': global_type_pairsList,
497 'showprofile': global_type_boolean,
498 'xmin': global_type_float,
499 'xmax': global_type_float,
500 'ymin': global_type_float,
501 'ymax': global_type_float,
502 'timerange': global_type_float,
503 'save': global_type_boolean,
504 'figpath': global_type_string,
505 'figfile': global_type_string,
506 'show': global_type_boolean,
507 'ftp': global_type_boolean,
508 'wr_period': global_type_integer,
509 'server': global_type_string,
510 'folder': global_type_string,
511 'username': global_type_string,
512 'password': global_type_string,
513 'ftp_wei': global_type_integer,
514 'exp_code': global_type_integer,
515 'sub_exp_code': global_type_integer,
516 'plot_pos': global_type_integer,
517 }
518
519
520 PlotCOHData
521 parameters = {
522 : global_type_string,
523 }
524
525
526 PlotCrossSpectraData
527 parameters = {
528 : global_type_string,
529 }
530
531
532 PlotDOPData
533 parameters = {
534 : global_type_string,
535 }
536
537
538 PlotData
539 parameters = {
540 : global_type_string,
541 }
542
543
544 PlotNoiseData
545 parameters = {
546 : global_type_string,
547 }
548
549
550 PlotPHASEData
551 parameters = {
552 : global_type_string,
553 }
554
555
556 PlotRTIData
557 parameters = {
558 : global_type_string,
559 }
560
561
562 PlotSNRData
563 parameters = {
564 : global_type_string,
565 }
566
567
568 PlotSpectraData
569 parameters = {
570 : global_type_string,
571 }
572
573
574 PlotSpectraMeanData
575 parameters = {
576 : global_type_string,
577 }
578
579
580 PlotWindProfilerData
581 parameters = {
582 : global_type_string,
583 }
584
585
586 PowerProfilePlot
587 parameters = {
588 'id': global_type_string,
589 'wintitle': global_type_string,
590 'channelList': global_type_list,
591 'xmin': global_type_float,
592 'xmax': global_type_float,
593 'ymin': global_type_float,
594 'ymax': global_type_float,
595 'save': global_type_boolean,
596 'figpath': global_type_string,
597 'figfile': global_type_string,
598 'show': global_type_boolean,
599 'ftp': global_type_boolean,
600 'wr_period': global_type_integer,
601 'server': global_type_string,
602 'folder': global_type_string,
603 'username': global_type_string,
604 'password': global_type_string,
605 }
606
607
608 PrintInfo
609 parameters = {
610 : global_type_string,
611 }
612
613
614 ProfileConcat
615 parameters = {
616 'm': global_type_string,
617 }
618
619
620 ProfileSelector
621 parameters = {
622 'profileList': global_type_string,
623 'profileRangeList': global_type_string,
624 'beam': global_type_string,
625 'byblock': global_type_string,
626 'rangeList': global_type_string,
627 'nProfiles': global_type_string,
628 }
629
630
631 ProfileToChannels
632 parameters = {
633 : global_type_string,
634 }
635
636
637 PublishData
638 parameters = {
639 : global_type_string,
640 }
641
642
643 RTIPlot
644 parameters = {
645 'id': global_type_string,
646 'wintitle': global_type_string,
647 'channelList': global_type_list,
648 'showprofile': global_type_boolean,
649 'xmin': global_type_float,
650 'xmax': global_type_float,
651 'ymin': global_type_float,
652 'ymax': global_type_float,
653 'zmin': global_type_float,
654 'zmax': global_type_float,
655 'timerange': global_type_float,
656 'save': global_type_boolean,
657 'figpath': global_type_string,
658 'lastone': global_type_string,
659 'figfile': global_type_string,
660 'ftp': global_type_boolean,
661 'wr_period': global_type_integer,
662 'show': global_type_boolean,
663 'server': global_type_string,
664 'folder': global_type_string,
665 'username': global_type_string,
666 'password': global_type_string,
667 'ftp_wei': global_type_integer,
668 'exp_code': global_type_integer,
669 'sub_exp_code': global_type_integer,
670 'plot_pos': global_type_integer,
671 }
672
673
674 RTIfromSpectraHeis
675 parameters = {
676 'id': global_type_string,
677 'wintitle': global_type_string,
678 'channelList': global_type_list,
679 'showprofile': global_type_boolean,
680 'xmin': global_type_float,
681 'xmax': global_type_float,
682 'ymin': global_type_float,
683 'ymax': global_type_float,
684 'timerange': global_type_float,
685 'save': global_type_boolean,
686 'figpath': global_type_string,
687 'figfile': global_type_string,
688 'ftp': global_type_boolean,
689 'wr_period': global_type_integer,
690 'show': global_type_boolean,
691 'server': global_type_string,
692 'folder': global_type_string,
693 'username': global_type_string,
694 'password': global_type_string,
695 'ftp_wei': global_type_integer,
696 'exp_code': global_type_integer,
697 'sub_exp_code': global_type_integer,
698 'plot_pos': global_type_integer,
699 }
700
701
702 Reshaper
703 parameters = {
704 'shape': global_type_string,
705 'nTxs': global_type_string,
706 }
707
708
709 SALags
710 parameters = {
711 : global_type_string,
712 }
713
714
715 SMDetection
716 parameters = {
717 'hei_ref': global_type_string,
718 'tauindex': global_type_string,
719 'phaseOffsets': global_type_string,
720 'cohDetection': global_type_string,
721 'cohDet_timeStep': global_type_string,
722 'cohDet_thresh': global_type_string,
723 'noise_timeStep': global_type_string,
724 'noise_multiple': global_type_string,
725 'multDet_timeLimit': global_type_string,
726 'multDet_rangeLimit': global_type_string,
727 'phaseThresh': global_type_string,
728 'SNRThresh': global_type_string,
729 'hmin': global_type_string,
730 'hmax': global_type_string,
731 'azimuth': global_type_string,
732 'channelPositions': global_type_string,
733 }
734
735
736 SMPhaseCalibration
737 parameters = {
738 'hmin': global_type_string,
739 'hmax': global_type_string,
740 'channelPositions': global_type_string,
741 'nHours': global_type_string,
742 }
743
744
745 Scope
746 parameters = {
747 'id': global_type_string,
748 'wintitle': global_type_string,
749 'channelList': global_type_list,
750 'xmin': global_type_float,
751 'xmax': global_type_float,
752 'ymin': global_type_float,
753 'ymax': global_type_float,
754 'save': global_type_boolean,
755 'figpath': global_type_string,
756 'figfile': global_type_string,
757 'show': global_type_boolean,
758 'wr_period': global_type_integer,
759 'ftp': global_type_boolean,
760 'server': global_type_string,
761 'folder': global_type_string,
762 'username': global_type_string,
763 'password': global_type_string,
764 'type': global_type_string,
765 }
766
767
768 SendByFTP
769 parameters = {
770 'ext': global_type_string,
771 'localfolder': global_type_string,
772 'remotefolder': global_type_string,
773 'server': global_type_string,
774 'username': global_type_string,
775 'password': global_type_string,
776 'period': global_type_string,
777 }
778
779
780 SkyMapPlot
781 parameters = {
782 'id': global_type_string,
783 'wintitle': global_type_string,
784 'channelList': global_type_list,
785 'showprofile': global_type_boolean,
786 'tmin': global_type_string,
787 'tmax': global_type_string,
788 'timerange': global_type_float,
789 'save': global_type_boolean,
790 'figpath': global_type_string,
791 'figfile': global_type_string,
792 'show': global_type_boolean,
793 'ftp': global_type_boolean,
794 'wr_period': global_type_integer,
795 'server': global_type_string,
796 'folder': global_type_string,
797 'username': global_type_string,
798 'password': global_type_string,
799 'ftp_wei': global_type_integer,
800 'exp_code': global_type_integer,
801 'sub_exp_code': global_type_integer,
802 'plot_pos': global_type_integer,
803 'realtime': global_type_boolean,
804 }
805
806
807 SpectraCutPlot
808 parameters = {
809 'id': global_type_string,
810 'wintitle': global_type_string,
811 'channelList': global_type_list,
812 'xmin': global_type_float,
813 'xmax': global_type_float,
814 'ymin': global_type_float,
815 'ymax': global_type_float,
816 'save': global_type_boolean,
817 'figpath': global_type_string,
818 'figfile': global_type_string,
819 'show': global_type_boolean,
820 'ftp': global_type_boolean,
821 'wr_period': global_type_integer,
822 'server': global_type_string,
823 'folder': global_type_string,
824 'username': global_type_string,
825 'password': global_type_string,
826 'xaxis': global_type_string,
827 }
828
829
830 SpectraHeisScope
831 parameters = {
832 'id': global_type_string,
833 'wintitle': global_type_string,
834 'channelList': global_type_list,
835 'xmin': global_type_float,
836 'xmax': global_type_float,
837 'ymin': global_type_float,
838 'ymax': global_type_float,
839 'save': global_type_boolean,
840 'figpath': global_type_string,
841 'figfile': global_type_string,
842 'ftp': global_type_boolean,
843 'wr_period': global_type_integer,
844 'show': global_type_boolean,
845 'server': global_type_string,
846 'folder': global_type_string,
847 'username': global_type_string,
848 'password': global_type_string,
849 'ftp_wei': global_type_integer,
850 'exp_code': global_type_integer,
851 'sub_exp_code': global_type_integer,
852 'plot_pos': global_type_integer,
853 }
854
855
856 SpectraHeisWriter
857 parameters = {
858 : global_type_string,
859 }
860
861
862 SpectraPlot
863 parameters = {
864 'id': global_type_string,
865 'wintitle': global_type_string,
866 'channelList': global_type_list,
867 'showprofile': global_type_boolean,
868 'xmin': global_type_float,
869 'xmax': global_type_float,
870 'ymin': global_type_float,
871 'ymax': global_type_float,
872 'zmin': global_type_float,
873 'zmax': global_type_float,
874 'save': global_type_boolean,
875 'figpath': global_type_string,
876 'figfile': global_type_string,
877 'show': global_type_boolean,
878 'ftp': global_type_boolean,
879 'wr_period': global_type_integer,
880 'server': global_type_string,
881 'folder': global_type_string,
882 'username': global_type_string,
883 'password': global_type_string,
884 'ftp_wei': global_type_integer,
885 'exp_code': global_type_integer,
886 'sub_exp_code': global_type_integer,
887 'plot_pos': global_type_integer,
888 'realtime': global_type_boolean,
889 'xaxis': global_type_string,
890 }
891
892
893 SpectraWriter
894 parameters = {
895 'path': global_type_string,
896 'blocksPerFile': global_type_string,
897 'profilesPerBlock': global_type_string,
898 'set': global_type_string,
899 'ext': global_type_string,
900 'datatype': global_type_string,
901 }
902
903
904 SpectralFitting
905 parameters = {
906 'getSNR': global_type_string,
907 'path': global_type_string,
908 'file': global_type_string,
909 'groupList': global_type_string,
910 }
911
912
913 SpectralFittingPlot
914 parameters = {
915 'id': global_type_string,
916 'cutHeight': global_type_string,
917 'fit': global_type_string,
918 'wintitle': global_type_string,
919 'channelList': global_type_list,
920 'showprofile': global_type_boolean,
921 'xmin': global_type_float,
922 'xmax': global_type_float,
923 'ymin': global_type_float,
924 'ymax': global_type_float,
925 'save': global_type_boolean,
926 'figpath': global_type_string,
927 'figfile': global_type_string,
928 'show': global_type_boolean,
929 }
930
931
932 SpectralMoments
933 parameters = {
934 : global_type_string,
935 }
936
937
938 SplitProfiles
939 parameters = {
940 'n': global_type_string,
941 }
942
943
944 USRPWriter
945 parameters = {
946 'dataIn': global_type_string,
947 }
948
949
950 VoltageWriter
951 parameters = {
952 'path': global_type_string,
953 'blocksPerFile': global_type_string,
954 'profilesPerBlock': global_type_string,
955 'set': global_type_string,
956 'ext': global_type_string,
957 'datatype': global_type_string,
958 }
959
960
961 WindProfiler
962 parameters = {
963 'technique': global_type_string,
964 }
965
966
967 WindProfilerPlot
968 parameters = {
969 'id': global_type_string,
970 'wintitle': global_type_string,
971 'channelList': global_type_list,
972 'showprofile': global_type_boolean,
973 'xmin': global_type_float,
974 'xmax': global_type_float,
975 'ymin': global_type_float,
976 'ymax': global_type_float,
977 'zmin': global_type_float,
978 'zmax': global_type_float,
979 'zmax_ver': global_type_string,
980 'zmin_ver': global_type_string,
981 'SNRmin': global_type_float,
982 'SNRmax': global_type_float,
983 'timerange': global_type_float,
984 'SNRthresh': global_type_string,
985 'save': global_type_boolean,
986 'figpath': global_type_string,
987 'lastone': global_type_string,
988 'figfile': global_type_string,
989 'ftp': global_type_boolean,
990 'wr_period': global_type_integer,
991 'show': global_type_boolean,
992 'server': global_type_string,
993 'folder': global_type_string,
994 'username': global_type_string,
995 'password': global_type_string,
996 'ftp_wei': global_type_integer,
997 'exp_code': global_type_integer,
998 'sub_exp_code': global_type_integer,
999 'plot_pos': global_type_integer,
1000 }
1001
1002
1003 Writer
1004 parameters = {
1005 'dataIn': global_type_string,
1006 }
1007
1008
1009 AMISRProc
1010 parameters = {
1011 : global_type_string,
1012 }
1013
1014
1015 AMISRReader
1016 parameters = {
1017 : global_type_string,
1018 }
1019
1020
1021 CorrelationProc
1022 parameters = {
1023 'lags': global_type_string,
1024 'mode': global_type_string,
1025 'pairsList': 'pairsLists',
1026 'fullBuffer': global_type_string,
1027 'nAvg': global_type_string,
1028 'removeDC': global_type_string,
1029 'splitCF': global_type_string,
1030 }
1031
1032
1033 FitsReader
1034 parameters = {
1035 : global_type_string,
1036 }
1037
1038
1039 HFReader
1040 parameters = {
1041 : global_type_string,
1042 }
1043
1044
1045 ParamReader
1046 parameters = {
1047 : global_type_string,
1048 }
1049
1050
1051 ParametersProc
1052 parameters = {
1053 : global_type_string,
1054 }
1055
1056
1057 ProcessingUnit
1058 parameters = {
1059 : global_type_string,
1060 }
1061
1062
1063 ReceiverData
1064 parameters = {
1065 : global_type_string,
1066 }
1067
1068
1069 SendToServer
1070 parameters = {
1071 : global_type_string,
1072 }
1073
1074
1075 SpectraAFCProc
1076 parameters = {
1077 'nProfiles': global_type_string,
1078 'nFFTPoints': global_type_string,
1079 'pairsList': 'pairsLists',
1080 'code': global_type_string,
1081 'nCode': global_type_string,
1082 'nBaud': global_type_string,
1083 }
1084
1085
1086 SpectraHeisProc
1087 parameters = {
1088 : global_type_string,
1089 }
1090
1091
1092 SpectraLagsProc
1093 parameters = {
1094 'nProfiles': global_type_string,
1095 'nFFTPoints': global_type_string,
1096 'pairsList': 'pairsLists',
1097 'code': global_type_string,
1098 'nCode': global_type_string,
1099 'nBaud': global_type_string,
1100 'codeFromHeader': global_type_string,
1101 'pulseIndex': global_type_string,
1102 }
1103
1104
1105 SpectraProc
1106 parameters = {
1107 'nProfiles': global_type_string,
1108 'nFFTPoints': global_type_string,
1109 'pairsList': 'pairsLists',
1110 'ippFactor': global_type_string,
1111 }
1112
1113
1114 SpectraReader
1115 parameters = {
1116 'path': global_type_string,
1117 'startDate': global_type_string,
1118 'endDate': global_type_string,
1119 'startTime': global_type_string,
1120 'endTime': global_type_string,
1121 'set': global_type_string,
1122 'expLabel': global_type_string,
1123 'ext': global_type_string,
1124 'online': global_type_string,
1125 'delay': global_type_string,
1126 'walk': global_type_string,
1127 'getblock': global_type_string,
1128 'nTxs': global_type_string,
1129 'realtime': global_type_boolean,
1130 'blocksize': global_type_string,
1131 'blocktime': global_type_string,
1132 'queue': global_type_string,
1133 'skip': global_type_string,
1134 'cursor': global_type_string,
1135 'warnings': global_type_string,
1136 'verbose': global_type_string,
1137 }
1138
1139
1140 USRPReader
1141 parameters = {
1142 : global_type_string,
1143 }
1144
1145
1146 VoltageProc
1147 parameters = {
1148 : global_type_string,
1149 }
1150
1151
1152 VoltageReader
1153 parameters = {
1154 'path': global_type_string,
1155 'startDate': global_type_string,
1156 'endDate': global_type_string,
1157 'startTime': global_type_string,
1158 'endTime': global_type_string,
1159 'set': global_type_string,
1160 'expLabel': global_type_string,
1161 'ext': global_type_string,
1162 'online': global_type_string,
1163 'delay': global_type_string,
1164 'walk': global_type_string,
1165 'getblock': global_type_string,
1166 'nTxs': global_type_string,
1167 'realtime': global_type_boolean,
1168 'blocksize': global_type_string,
1169 'blocktime': global_type_string,
1170 'queue': global_type_string,
1171 'skip': global_type_string,
1172 'cursor': global_type_string,
1173 'warnings': global_type_string,
1174 'verbose': global_type_string,
1175 }
1176
1177
Show file before | Show file after | Hide comments
@@ -0,0 +1,81
1 import schainpy
2 from schainpy.model import Operation, ProcessingUnit
3 from importlib import import_module
4 from pydoc import locate
5
6 def clean_modules(module):
7 noEndsUnder = [x for x in module if not x.endswith('__')]
8 noStartUnder = [x for x in noEndsUnder if not x.startswith('__')]
9 noFullUpper = [x for x in noStartUnder if not x.isupper()]
10 return noFullUpper
11
12 def check_module(possible, instance):
13 def check(x):
14 try:
15 instancia = locate('schainpy.model.{}'.format(x))
16 return isinstance(instancia(), instance)
17 except Exception as e:
18 return False
19 clean = clean_modules(possible)
20 return [x for x in clean if check(x)]
21
22
23 def getProcs():
24 module = dir(import_module('schainpy.model'))
25 procs = check_module(module, ProcessingUnit)
26 try:
27 procs.remove('ProcessingUnit')
28 except Exception as e:
29 pass
30 return procs
31
32 def getOperations():
33 module = dir(import_module('schainpy.model'))
34 noProcs = [x for x in module if not x.endswith('Proc')]
35 operations = check_module(noProcs, Operation)
36 try:
37 operations.remove('Operation')
38 except Exception as e:
39 pass
40 return operations
41
42 def getArgs(op):
43 module = locate('schainpy.model.{}'.format(op))
44 args = module().getAllowedArgs()
45 try:
46 args.remove('self')
47 except Exception as e:
48 pass
49 try:
50 args.remove('dataOut')
51 except Exception as e:
52 pass
53 return args
54
55 def getAll():
56 allModules = dir(import_module('schainpy.model'))
57 modules = check_module(allModules, Operation)
58 modules.extend(check_module(allModules, ProcessingUnit))
59 return modules
60
61 def formatArgs(op):
62 args = getArgs(op)
63
64 argsAsKey = ["\t'{}'".format(x) for x in args]
65 argsFormatted = ": 'string',\n".join(argsAsKey)
66
67 print op
68 print "parameters = { \n" + argsFormatted + ": 'string',\n }"
69 print '\n'
70
71
72 if __name__ == "__main__":
73 getAll()
74 [formatArgs(x) for x in getAll()]
75
76 '''
77 parameters = {
78 'id': ,
79 'wintitle': ,
80 }
81 ''' No newline at end of file
Show file before | Show file after | Hide comments
@@ -0,0 +1,1
1 You should install "digital_rf_hdf5" module if you want to read USRP data
Show file before | Show file after | Hide comments
@@ -14,6 +14,7 from schainpy.utils import log
14 from importlib import import_module
14 from importlib import import_module
15 from pydoc import locate
15 from pydoc import locate
16 from fuzzywuzzy import process
16 from fuzzywuzzy import process
17 from schainpy.utils import paramsFinder
17 sys.stdout = save_stdout
18 sys.stdout = save_stdout
18
19
19
20
@@ -75,47 +76,25 def search(nextcommand):
75 if nextcommand is None:
76 if nextcommand is None:
76 log.error('There is no Operation/ProcessingUnit to search')
77 log.error('There is no Operation/ProcessingUnit to search')
77 elif nextcommand == 'procs':
78 elif nextcommand == 'procs':
78 module = dir(import_module('schainpy.model'))
79 procs = paramsFinder.getProcs()
79 procs = check_module(module, ProcessingUnit)
80 try:
81 procs.remove('ProcessingUnit')
82 except Exception as e:
83 pass
84 log.success('Current ProcessingUnits are:\n\033[1m{}\033[0m'.format('\n'.join(procs)))
80 log.success('Current ProcessingUnits are:\n\033[1m{}\033[0m'.format('\n'.join(procs)))
85
81
86 elif nextcommand == 'operations':
82 elif nextcommand == 'operations':
87 module = dir(import_module('schainpy.model'))
83 operations = paramsFinder.getOperations()
88 noProcs = [x for x in module if not x.endswith('Proc')]
89 operations = check_module(noProcs, Operation)
90 try:
91 operations.remove('Operation')
92 except Exception as e:
93 pass
94 log.success('Current Operations are:\n\033[1m{}\033[0m'.format('\n'.join(operations)))
84 log.success('Current Operations are:\n\033[1m{}\033[0m'.format('\n'.join(operations)))
95 else:
85 else:
96 try:
86 try:
97 module = locate('schainpy.model.{}'.format(nextcommand))
87 args = paramsFinder.getArgs(nextcommand)
98 args = module().getAllowedArgs()
99 log.warning('Use this feature with caution. It may not return all the allowed arguments')
88 log.warning('Use this feature with caution. It may not return all the allowed arguments')
100 try:
101 args.remove('self')
102 except Exception as e:
103 pass
104 try:
105 args.remove('dataOut')
106 except Exception as e:
107 pass
108 if len(args) == 0:
89 if len(args) == 0:
109 log.success('{} has no arguments'.format(nextcommand))
90 log.success('{} has no arguments'.format(nextcommand))
110 else:
91 else:
111 log.success('Showing arguments of {} are:\n\033[1m{}\033[0m'.format(nextcommand, '\n'.join(args)))
92 log.success('Showing arguments of {} are:\n\033[1m{}\033[0m'.format(nextcommand, '\n'.join(args)))
112 except Exception as e:
93 except Exception as e:
113 log.error('Module {} does not exists'.format(nextcommand))
94 log.error('Module {} does not exists'.format(nextcommand))
114 allModules = dir(import_module('schainpy.model'))
95 allModules = paramsFinder.getAll()
115 module = check_module(allModules, Operation)
96 similar = process.extractOne(nextcommand, allModules)[0]
116 module.extend(check_module(allModules, ProcessingUnit))
97 log.success('Showing {} instead'.format(similar))
117 similar = process.extractOne(nextcommand, module)[0]
118 log.success('Searching {} instead'.format(similar))
119 search(similar)
98 search(similar)
120
99
121
100
Show file before | Show file after | Hide comments
@@ -10,3 +10,13 from io import *
10 from proc import *
10 from proc import *
11 from graphics import *
11 from graphics import *
12 from utils import *
12 from utils import *
13
14 global_type_string = 'string'
15 global_type_integer = 'int'
16 global_type_floatList = 'floatList'
17 global_type_pairsList = 'pairsList'
18 global_type_boolean = 'bolean'
19 global_type_float = 'float'
20 global_type_colormap = 'colormap'
21 global_type_list = 'list'
22 global_type_float = 'float'
Show file before | Show file after | Hide comments
@@ -61,7 +61,7 class Figure(Operation):
61 figfile = None
61 figfile = None
62
62
63 created = False
63 created = False
64
64 parameters = {}
65 def __init__(self, **kwargs):
65 def __init__(self, **kwargs):
66
66
67 Operation.__init__(self, **kwargs)
67 Operation.__init__(self, **kwargs)
Show file before | Show file after | Hide comments
@@ -2,10 +2,37 import os
2 import datetime
2 import datetime
3 import numpy
3 import numpy
4 import copy
4 import copy
5
5 from schainpy.model import *
6 from figure import Figure, isRealtime
6 from figure import Figure, isRealtime
7
7
8 class CorrelationPlot(Figure):
8 class CorrelationPlot(Figure):
9 parameters = {
10 'id': global_type_string,
11 'wintitle': global_type_string,
12 'channelList': global_type_list,
13 'showprofile': global_type_string,
14 'xmin': global_type_float,
15 'xmax': global_type_float,
16 'ymin': global_type_float,
17 'ymax': global_type_float,
18 'zmin': global_type_float,
19 'zmax': global_type_float,
20 'save': global_type_boolean,
21 'figpath': global_type_string,
22 'figfile': global_type_string,
23 'show': global_type_boolean,
24 'ftp': global_type_boolean,
25 'wr_period': global_type_integer,
26 'server': global_type_string,
27 'folder': global_type_string,
28 'username': global_type_string,
29 'password': global_type_string,
30 'ftp_wei': global_type_integer,
31 'exp_code': global_type_integer,
32 'sub_exp_code': global_type_integer,
33 'plot_pos': global_type_integer,
34 'realtime': global_type_boolean,
35 }
9
36
10 isConfig = None
37 isConfig = None
11 __nsubplots = None
38 __nsubplots = None
Show file before | Show file after | Hide comments
@@ -15,6 +15,34 class MomentsPlot(Figure):
15 HEIGHTPROF = None
15 HEIGHTPROF = None
16 PREFIX = 'prm'
16 PREFIX = 'prm'
17
17
18 parameters = {
19 'id': global_type_string,
20 'wintitle': global_type_string,
21 'channelList': global_type_list,
22 'showprofile': global_type_boolean,
23 'xmin': global_type_float,
24 'xmax': global_type_float,
25 'ymin': global_type_float,
26 'ymax': global_type_float,
27 'zmin': global_type_float,
28 'zmax': global_type_float,
29 'save': global_type_boolean,
30 'figpath': global_type_string,
31 'figfile': global_type_string,
32 'show': global_type_boolean,
33 'ftp': global_type_boolean,
34 'wr_period': global_type_integer,
35 'server': global_type_string,
36 'folder': global_type_string,
37 'username': global_type_string,
38 'password': global_type_string,
39 'ftp_wei': global_type_string,
40 'exp_code': global_type_integer,
41 'sub_exp_code': global_type_integer,
42 'plot_pos': global_type_integer,
43 'realtime': global_type_boolean,
44 }
45
18 def __init__(self, **kwargs):
46 def __init__(self, **kwargs):
19 Figure.__init__(self, **kwargs)
47 Figure.__init__(self, **kwargs)
20 self.isConfig = False
48 self.isConfig = False
@@ -577,6 +605,40 class ParametersPlot(Figure):
577 nplots = None
605 nplots = None
578 nchan = None
606 nchan = None
579
607
608 parameters = {
609 'id': global_type_string,
610 'wintitle': global_type_string,
611 'channelList': global_type_list,
612 'paramIndex': global_type_integer,
613 'colormap': global_type_colormap,
614 'xmin': global_type_float,
615 'xmax': global_type_float,
616 'ymin': global_type_float,
617 'ymax': global_type_float,
618 'zmin': global_type_float,
619 'zmax': global_type_float,
620 'timerange': global_type_float,
621 'showSNR': global_type_boolean,
622 'SNRthresh': global_type_float,
623 'SNRmin': global_type_float,
624 'SNRmax': global_type_float,
625 'save': global_type_boolean,
626 'figpath': global_type_string,
627 'lastone': global_type_integer,
628 'figfile': global_type_string,
629 'ftp': global_type_boolean,
630 'wr_period': global_type_integer,
631 'show': global_type_boolean,
632 'server': global_type_string,
633 'folder': global_type_string,
634 'username': global_type_string,
635 'password': global_type_string,
636 'ftp_wei': global_type_integer,
637 'exp_code': global_type_integer,
638 'sub_exp_code': global_type_integer,
639 'plot_pos': global_type_integer,
640 }
641
580 def __init__(self, **kwargs):
642 def __init__(self, **kwargs):
581 Figure.__init__(self, **kwargs)
643 Figure.__init__(self, **kwargs)
582 self.timerange = None
644 self.timerange = None
@@ -784,6 +846,46 class Parameters1Plot(Figure):
784 HEIGHTPROF = None
846 HEIGHTPROF = None
785 PREFIX = 'prm'
847 PREFIX = 'prm'
786
848
849 parameters = {
850 'id': global_type_string,
851 'wintitle': global_type_string,
852 'channelList': global_type_list,
853 'showprofile': global_type_boolean,
854 'xmin': global_type_float,
855 'xmax': global_type_float,
856 'ymin': global_type_float,
857 'ymax': global_type_float,
858 'zmin': global_type_float,
859 'zmax': global_type_float,
860 'timerange': global_type_float,
861 'parameterIndex': global_type_float,
862 'onlyPositive': global_type_boolean,
863 'SNRthresh': global_type_float,
864 'SNR': global_type_boolean,
865 'SNRmin': global_type_float,
866 'SNRmax': global_type_float,
867 'onlySNR': global_type_boolean,
868 'DOP': global_type_boolean,
869 'zlabel': global_type_string,
870 'parameterName': global_type_string,
871 'parameterObject': global_type_string,
872 'save': global_type_boolean,
873 'figpath': global_type_string,
874 'lastone': global_type_integer,
875 'figfile': global_type_string,
876 'ftp': global_type_boolean,
877 'wr_period': global_type_integer,
878 'show': global_type_string,
879 'server': global_type_string,
880 'folder': global_type_string,
881 'username': global_type_string,
882 'password': global_type_string,
883 'ftp_wei': global_type_integer,
884 'exp_code': global_type_integer,
885 'sub_exp_code': global_type_integer,
886 'plot_pos': global_type_integer,
887 }
888
787 def __init__(self, **kwargs):
889 def __init__(self, **kwargs):
788 Figure.__init__(self, **kwargs)
890 Figure.__init__(self, **kwargs)
789 self.timerange = 2*60*60
891 self.timerange = 2*60*60
@@ -1213,6 +1315,42 class EWDriftsPlot(Figure):
1213 HEIGHTPROF = None
1315 HEIGHTPROF = None
1214 PREFIX = 'drift'
1316 PREFIX = 'drift'
1215
1317
1318 parameters = {
1319 'id': global_type_string,
1320 'wintitle': global_type_string,
1321 'channelList': global_type_string,
1322 'xmin': global_type_float,
1323 'xmax': global_type_float,
1324 'ymin': global_type_float,
1325 'ymax': global_type_float,
1326 'zmin': global_type_float,
1327 'zmax': global_type_float,
1328 'zmaxVertfloat': global_type_float,
1329 'zminVertfloat': global_type_float,
1330 'zmaxZonafloat': global_type_float,
1331 'zminZonafloat': global_type_float,
1332 'timerange': global_type_float,
1333 'SNRthresh': global_type_float,
1334 'SNRmin': global_type_float,
1335 'SNRmax': global_type_float,
1336 'SNR_1': global_type_boolean,
1337 'save': global_type_boolean,
1338 'figpath': global_type_string,
1339 'lastone': global_type_float,
1340 'figfile': global_type_string,
1341 'ftp': global_type_string,
1342 'wr_period': global_type_integer,
1343 'show': global_type_string,
1344 'server': global_type_string,
1345 'folder': global_type_string,
1346 'username': global_type_string,
1347 'password': global_type_string,
1348 'ftp_wei': global_type_integer,
1349 'exp_code': global_type_integer,
1350 'sub_exp_code': global_type_integer,
1351 'plot_pos': global_type_integer,
1352 }
1353
1216 def __init__(self, **kwargs):
1354 def __init__(self, **kwargs):
1217 Figure.__init__(self, **kwargs)
1355 Figure.__init__(self, **kwargs)
1218 self.timerange = 2*60*60
1356 self.timerange = 2*60*60
@@ -1417,6 +1555,32 class PhasePlot(Figure):
1417
1555
1418 PREFIX = 'mphase'
1556 PREFIX = 'mphase'
1419
1557
1558 parameters = {
1559 'id': global_type_string,
1560 'wintitle': global_type_string,
1561 'pairsList': global_type_pairsList,
1562 'showprofile': global_type_boolean,
1563 'xmin': global_type_float,
1564 'xmax': global_type_float,
1565 'ymin': global_type_float,
1566 'ymax': global_type_float,
1567 'timerange': global_type_float,
1568 'save': global_type_boolean,
1569 'figpath': global_type_string,
1570 'figfile': global_type_string,
1571 'show': global_type_boolean,
1572 'ftp': global_type_boolean,
1573 'wr_period': global_type_integer,
1574 'server': global_type_string,
1575 'folder': global_type_string,
1576 'username': global_type_string,
1577 'password': global_type_string,
1578 'ftp_wei': global_type_integer,
1579 'exp_code': global_type_integer,
1580 'sub_exp_code': global_type_integer,
1581 'plot_pos': global_type_integer,
1582 }
1583
1420 def __init__(self, **kwargs):
1584 def __init__(self, **kwargs):
1421 Figure.__init__(self, **kwargs)
1585 Figure.__init__(self, **kwargs)
1422 self.timerange = 24*60*60
1586 self.timerange = 24*60*60
@@ -1590,6 +1754,40 class NSMeteorDetection1Plot(Figure):
1590 nChannels = None
1754 nChannels = None
1591 nParam = None
1755 nParam = None
1592
1756
1757 parameters = {
1758 'id': global_type_string,
1759 'wintitle': global_type_string,
1760 'channelList': global_type_list,
1761 'showprofile': global_type_boolean,
1762 'xmin': global_type_float,
1763 'xmax': global_type_float,
1764 'ymin': global_type_float,
1765 'ymax': global_type_float,
1766 'SNRmin': global_type_float,
1767 'SNRmax': global_type_float,
1768 'vmin': global_type_float,
1769 'vmax': global_type_float,
1770 'wmin': global_type_float,
1771 'wmax': global_type_float,
1772 'mode': global_type_string,
1773 'save': global_type_boolean,
1774 'figpath': global_type_string,
1775 'figfile': global_type_string,
1776 'show': global_type_boolean,
1777 'ftp': global_type_string,
1778 'wr_period': global_type_integer,
1779 'server': global_type_string,
1780 'folder': global_type_string,
1781 'username': global_type_string,
1782 'password': global_type_string,
1783 'ftp_wei': global_type_integer,
1784 'exp_code': global_type_integer,
1785 'sub_exp_code': global_type_integer,
1786 'plot_pos': global_type_integer,
1787 'realtime': global_type_boolean,
1788 'xaxis': global_type_string,
1789 }
1790
1593 def __init__(self, **kwargs):
1791 def __init__(self, **kwargs):
1594 Figure.__init__(self, **kwargs)
1792 Figure.__init__(self, **kwargs)
1595 self.isConfig = False
1793 self.isConfig = False
@@ -1774,6 +1972,40 class NSMeteorDetection2Plot(Figure):
1774 nChannels = None
1972 nChannels = None
1775 nParam = None
1973 nParam = None
1776
1974
1975 parameters = {
1976 'id': global_type_string,
1977 'wintitle': global_type_string,
1978 'channelList': global_type_list,
1979 'showprofile': global_type_boolean,
1980 'xmin': global_type_float,
1981 'xmax': global_type_float,
1982 'ymin': global_type_float,
1983 'ymax': global_type_float,
1984 'SNRmin': global_type_float,
1985 'SNRmax': global_type_float,
1986 'vmin': global_type_float,
1987 'vmax': global_type_float,
1988 'wmin': global_type_float,
1989 'wmax': global_type_float,
1990 'mode': global_type_string,
1991 'save': global_type_boolean,
1992 'figpath': global_type_string,
1993 'figfile': global_type_string,
1994 'show': global_type_string,
1995 'ftp': global_type_boolean,
1996 'wr_period': global_type_integer,
1997 'server': global_type_string,
1998 'folder': global_type_string,
1999 'username': global_type_string,
2000 'password': global_type_string,
2001 'ftp_wei': global_type_integer,
2002 'exp_code': global_type_integer,
2003 'sub_exp_code': global_type_integer,
2004 'plot_pos': global_type_integer,
2005 'realtime': global_type_boolean,
2006 'xaxis': global_type_string,
2007 }
2008
1777 def __init__(self, **kwargs):
2009 def __init__(self, **kwargs):
1778 Figure.__init__(self, **kwargs)
2010 Figure.__init__(self, **kwargs)
1779 self.isConfig = False
2011 self.isConfig = False
Show file before | Show file after | Hide comments
@@ -10,6 +10,7 import numpy
10 from figure import Figure, isRealtime, isTimeInHourRange
10 from figure import Figure, isRealtime, isTimeInHourRange
11 from plotting_codes import *
11 from plotting_codes import *
12
12
13
13 class SpectraPlot(Figure):
14 class SpectraPlot(Figure):
14
15
15 isConfig = None
16 isConfig = None
@@ -230,6 +231,40 class CrossSpectraPlot(Figure):
230 HEIGHTPROF = None
231 HEIGHTPROF = None
231 PREFIX = 'cspc'
232 PREFIX = 'cspc'
232
233
234 parameters = {
235 'id': global_type_string,
236 'wintitle': global_type_string,
237 'pairsList': global_type_pairsList,
238 'xmin': global_type_float,
239 'xmax': global_type_float,
240 'ymin': global_type_float,
241 'ymax': global_type_float,
242 'zmin': global_type_float,
243 'zmax': global_type_float,
244 'coh_min': global_type_float,
245 'coh_max': global_type_float,
246 'phase_min': global_type_float,
247 'phase_max': global_type_float,
248 'save': global_type_boolean,
249 'figpath': global_type_string,
250 'figfile': global_type_string,
251 'ftp': global_type_boolean,
252 'wr_period': global_type_integer,
253 'power_cmap': global_type_colormap,
254 'coherence_cmap': global_type_colormap,
255 'phase_cmap': global_type_colormap,
256 'show': global_type_boolean,
257 'server': global_type_string,
258 'folder': global_type_string,
259 'username': global_type_string,
260 'password': global_type_string,
261 'ftp_wei': global_type_integer,
262 'exp_code': global_type_integer,
263 'sub_exp_code': global_type_integer,
264 'plot_pos': global_type_integer,
265 'xaxis': global_type_string,
266 }
267
233 def __init__(self, **kwargs):
268 def __init__(self, **kwargs):
234 Figure.__init__(self, **kwargs)
269 Figure.__init__(self, **kwargs)
235 self.isConfig = False
270 self.isConfig = False
@@ -652,6 +687,38 class CoherenceMap(Figure):
652 HEIGHTPROF = None
687 HEIGHTPROF = None
653 PREFIX = 'cmap'
688 PREFIX = 'cmap'
654
689
690 parameters = {
691 'id': 'string',
692 'wintitle': 'string',
693 'pairsList': 'pairsLists',
694 'showprofile': 'boolean',
695 'xmin': 'float',
696 'xmax': 'float',
697 'ymin': 'float',
698 'ymax': 'float',
699 'zmin': 'float',
700 'zmax': 'float',
701 'timerange': 'float',
702 'phase_min': 'float',
703 'phase_max': 'float',
704 'save': 'boolean',
705 'figpath': 'string',
706 'figfile': 'string',
707 'ftp': 'boolean',
708 'wr_period': 'int',
709 'coherence_cmap': 'colormap',
710 'phase_cmap': 'colormap',
711 'show': 'boolean',
712 'server': 'string',
713 'folder': 'string',
714 'username': 'string',
715 'password': 'string',
716 'ftp_wei': 'int',
717 'exp_code': 'int',
718 'sub_exp_code': 'int',
719 'plot_pos': 'int',
720 }
721
655 def __init__(self, **kwargs):
722 def __init__(self, **kwargs):
656 Figure.__init__(self, **kwargs)
723 Figure.__init__(self, **kwargs)
657 self.timerange = 2*60*60
724 self.timerange = 2*60*60
@@ -1111,6 +1178,32 class Noise(Figure):
1111
1178
1112 PREFIX = 'noise'
1179 PREFIX = 'noise'
1113
1180
1181 parameters = {
1182 'id': global_type_string,
1183 'wintitle': global_type_string,
1184 'channelList': global_type_list,
1185 'showprofile': global_type_boolean,
1186 'xmin': global_type_float,
1187 'xmax': global_type_float,
1188 'ymin': global_type_float,
1189 'ymax': global_type_float,
1190 'timerange': global_type_float,
1191 'save': global_type_boolean,
1192 'figpath': global_type_string,
1193 'figfile': global_type_string,
1194 'show': global_type_boolean,
1195 'ftp': global_type_boolean,
1196 'wr_period': global_type_integer,
1197 'server': global_type_string,
1198 'folder': global_type_string,
1199 'username': global_type_string,
1200 'password': global_type_string,
1201 'ftp_wei': global_type_integer,
1202 'exp_code': global_type_integer,
1203 'sub_exp_code': global_type_integer,
1204 'plot_pos': global_type_integer,
1205 }
1206
1114 def __init__(self, **kwargs):
1207 def __init__(self, **kwargs):
1115 Figure.__init__(self, **kwargs)
1208 Figure.__init__(self, **kwargs)
1116 self.timerange = 24*60*60
1209 self.timerange = 24*60*60
@@ -1311,6 +1404,34 class BeaconPhase(Figure):
1311
1404
1312 PREFIX = 'beacon_phase'
1405 PREFIX = 'beacon_phase'
1313
1406
1407 parameters = {
1408 'id': global_type_string,
1409 'wintitle': global_type_string,
1410 'pairsList': global_type_pairsList,
1411 'showprofile': global_type_boolean,
1412 'xmin': global_type_float,
1413 'xmax': global_type_float,
1414 'ymin': global_type_float,
1415 'ymax': global_type_float,
1416 'hmin': global_type_float,
1417 'hmax': global_type_float,
1418 'timerange': global_type_float,
1419 'save': global_type_boolean,
1420 'figpath': global_type_string,
1421 'figfile': global_type_string,
1422 'show': global_type_boolean,
1423 'ftp': global_type_boolean,
1424 'wr_period': global_type_integer,
1425 'server': global_type_string,
1426 'folder': global_type_string,
1427 'username': global_type_string,
1428 'password': global_type_string,
1429 'ftp_wei': global_type_integer,
1430 'exp_code': global_type_integer,
1431 'sub_exp_code': global_type_integer,
1432 'plot_pos': global_type_integer,
1433 }
1434
1314 def __init__(self, **kwargs):
1435 def __init__(self, **kwargs):
1315 Figure.__init__(self, **kwargs)
1436 Figure.__init__(self, **kwargs)
1316 self.timerange = 24*60*60
1437 self.timerange = 24*60*60
Show file before | Show file after | Hide comments
@@ -119,7 +119,11 class Metadata(object):
119 self.parmConfObjList.append(parmConfObj)
119 self.parmConfObjList.append(parmConfObj)
120
120
121 class FitsWriter(Operation):
121 class FitsWriter(Operation):
122
122 parameters = {
123 'path': global_type_string,
124 'dataBlocksPerFile': global_type_integer,
125 'metadatafile': global_type_string,
126 }
123 def __init__(self, **kwargs):
127 def __init__(self, **kwargs):
124 Operation.__init__(self, **kwargs)
128 Operation.__init__(self, **kwargs)
125 self.isConfig = False
129 self.isConfig = False
@@ -276,9 +280,9 class FitsWriter(Operation):
276 self.setNextFile()
280 self.setNextFile()
277 self.writeNextBlock()
281 self.writeNextBlock()
278
282
279 def run(self, dataOut, **kwargs):
283 def run(self, dataOut, path, dataBlocksPerFile=100, metadatafile=None, **kwargs):
280 if not(self.isConfig):
284 if not(self.isConfig):
281 self.setup(dataOut, **kwargs)
285 self.setup(dataOut, path, dataBlocksPerFile=dataBlocksPerFile, metadatafile=metadatafile, **kwargs)
282 self.isConfig = True
286 self.isConfig = True
283 self.putData()
287 self.putData()
284
288
Show file before | Show file after | Hide comments
@@ -602,34 +602,31 class ParamWriter(Operation):
602
602
603 lastTime = None
603 lastTime = None
604
604
605 parameters = {
606 'path': global_type_string,
607 'blocksPerFile':global_type_integer,
608 'metadataList': global_type_list,
609 'dataList': global_type_list,
610 'mode': global_type_integer,
611 }
612
605 def __init__(self, **kwargs):
613 def __init__(self, **kwargs):
606 Operation.__init__(self, **kwargs)
614 Operation.__init__(self, **kwargs)
607 self.isConfig = False
615 self.isConfig = False
608 return
616 return
609
617
610 def setup(self, dataOut, **kwargs):
618 def setup(self, dataOut, path=None, blocksPerFile=10, metadataList=None, dataList=None, mode=None, **kwargs):
611
619 self.path = path
612 self.path = kwargs['path']
620 self.blocksPerFile = blocksPerFile
613 self.setType = kwargs.get('setType', None)
621 self.metadataList = metadataList
614
622 self.dataList = dataList
615 if kwargs.has_key('blocksPerFile'):
616 self.blocksPerFile = kwargs['blocksPerFile']
617 else:
618 self.blocksPerFile = 10
619
620 self.metadataList = kwargs['metadataList']
621 self.dataList = kwargs['dataList']
622 self.dataOut = dataOut
623 self.dataOut = dataOut
624 self.mode = mode
623
625
624 if kwargs.has_key('mode'):
626 if self.mode is not None:
625 mode = kwargs['mode']
627 self.mode = numpy.zeros(len(self.dataList)) + mode
626
627 if type(mode) == int:
628 mode = numpy.zeros(len(self.dataList)) + mode
629 else:
628 else:
630 mode = numpy.ones(len(self.dataList))
629 self.mode = numpy.ones(len(self.dataList))
631
632 self.mode = mode
633
630
634 arrayDim = numpy.zeros((len(self.dataList),5))
631 arrayDim = numpy.zeros((len(self.dataList),5))
635
632
@@ -1089,10 +1086,11 class ParamWriter(Operation):
1089 self.fp.close()
1086 self.fp.close()
1090 return
1087 return
1091
1088
1092 def run(self, dataOut, **kwargs):
1089 def run(self, dataOut, path=None, blocksPerFile=10, metadataList=None, dataList=None, mode=None, **kwargs):
1093
1090
1094 if not(self.isConfig):
1091 if not(self.isConfig):
1095 flagdata = self.setup(dataOut, **kwargs)
1092 flagdata = self.setup(dataOut, path=path, blocksPerFile=blocksPerFile,
1093 metadataList=metadataList, dataList=dataList, mode=mode, **kwargs)
1096
1094
1097 if not(flagdata):
1095 if not(flagdata):
1098 return
1096 return
Show file before | Show file after | Hide comments
@@ -41,6 +41,9 class PrintInfo(Operation):
41 class BeamSelector(Operation):
41 class BeamSelector(Operation):
42 profileIndex = None
42 profileIndex = None
43 nProfiles = None
43 nProfiles = None
44 parameters = {
45 'beam': global_type_string,
46 }
44
47
45 def __init__(self):
48 def __init__(self):
46
49
Show file before | Show file after | Hide comments
@@ -162,6 +162,11 class IncohInt4SpectraHeis(Operation):
162 __dataReady = False
162 __dataReady = False
163
163
164 n = None
164 n = None
165 parameters = {
166 'n': global_type_float,
167 'timeInterval': global_type_integer,
168 'overlapping': global_type_boolean,
169 }
165
170
166
171
167 def __init__(self, **kwargs):
172 def __init__(self, **kwargs):
@@ -324,10 +329,10 class IncohInt4SpectraHeis(Operation):
324
329
325 return avgdata, avgdatatime
330 return avgdata, avgdatatime
326
331
327 def run(self, dataOut, **kwargs):
332 def run(self, dataOut, n=None, timeInterval=None, overlapping=False, **kwargs):
328
333
329 if not self.isConfig:
334 if not self.isConfig:
330 self.setup(**kwargs)
335 self.setup(n=n, timeInterval=timeInterval, overlapping=overlapping)
331 self.isConfig = True
336 self.isConfig = True
332
337
333 avgdata, avgdatatime = self.integrate(dataOut.data_spc, dataOut.utctime)
338 avgdata, avgdatatime = self.integrate(dataOut.data_spc, dataOut.utctime)
Show file before | Show file after | Hide comments
@@ -2220,6 +2220,13 class SMDetection(Operation):
2220 return arrayParameters
2220 return arrayParameters
2221
2221
2222 class CorrectSMPhases(Operation):
2222 class CorrectSMPhases(Operation):
2223 parameters = {
2224 'phaseOffsets': global_type_pairsList,
2225 'hmin': global_type_float,
2226 'hmax': global_type_float,
2227 'azimuth': global_type_float,
2228 'channelPositions': global_type_pairsList,
2229 }
2223
2230
2224 def run(self, dataOut, phaseOffsets, hmin = 50, hmax = 150, azimuth = 45, channelPositions = None):
2231 def run(self, dataOut, phaseOffsets, hmin = 50, hmax = 150, azimuth = 45, channelPositions = None):
2225
2232
Show file before | Show file after | Hide comments
@@ -742,6 +742,12 class IncohInt(Operation):
742
742
743 __timeInterval = None
743 __timeInterval = None
744
744
745 parameters = {
746 'n': global_type_float,
747 'timeInterval': global_type_integer,
748 'overlapping': global_type_boolean,
749 }
750
745 n = None
751 n = None
746
752
747
753
Show file before | Show file after | Hide comments
@@ -334,6 +334,37 class CohInt(Operation):
334
334
335 n = None
335 n = None
336
336
337 parameters = {
338 'id': global_type_string,
339 'wintitle': global_type_string,
340 'pairsList': global_type_pairsList,
341 'showprofile': global_type_boolean,
342 'xmin': global_type_float,
343 'xmax': global_type_float,
344 'ymin': global_type_float,
345 'ymax': global_type_float,
346 'zmin': global_type_float,
347 'zmax': global_type_float,
348 'timerange': global_type_float,
349 'phase_min': global_type_float,
350 'phase_max': global_type_float,
351 'save': global_type_boolean,
352 'figpath': global_type_string,
353 'figfile': global_type_string,
354 'ftp': global_type_boolean,
355 'wr_period': global_type_integer,
356 'coherence_cmap': global_type_colormap,
357 'phase_cmap': global_type_colormap,
358 'show': global_type_boolean,
359 'server': global_type_string,
360 'folder': global_type_string,
361 'username': global_type_string,
362 'password': global_type_string,
363 'ftp_wei': global_type_integer,
364 'exp_code': global_type_integer,
365 'sub_exp_code': global_type_integer,
366 'plot_pos': global_type_integer,
367 }
337
368
338 def __init__(self, **kwargs):
369 def __init__(self, **kwargs):
339
370
@@ -350,7 +381,6 class CohInt(Operation):
350 n : Number of coherent integrations
381 n : Number of coherent integrations
351 timeInterval : Time of integration. If the parameter "n" is selected this one does not work
382 timeInterval : Time of integration. If the parameter "n" is selected this one does not work
352 overlapping :
383 overlapping :
353
354 """
384 """
355
385
356 self.__initime = None
386 self.__initime = None
@@ -550,6 +580,13 class Decoder(Operation):
550 nCode = None
580 nCode = None
551 nBaud = None
581 nBaud = None
552
582
583 parameters = {
584 'code': global_type_list,
585 'nCode': global_type_integer,
586 'nBaud': global_type_integer,
587 'mode': global_type_integer,
588 'osamp': global_type_float,
589 }
553
590
554 def __init__(self, **kwargs):
591 def __init__(self, **kwargs):
555
592
@@ -1112,7 +1149,9 class SplitProfiles(Operation):
1112 dataOut.ippSeconds /= n
1149 dataOut.ippSeconds /= n
1113
1150
1114 class CombineProfiles(Operation):
1151 class CombineProfiles(Operation):
1115
1152 parameters = {
1153 'n': global_type_integer,
1154 }
1116 def __init__(self, **kwargs):
1155 def __init__(self, **kwargs):
1117
1156
1118 Operation.__init__(self, **kwargs)
1157 Operation.__init__(self, **kwargs)
General Comments 0
You need to be logged in to leave comments. Login now