| @@ -0,0 +1,1 | |||
|
|
1 | You should install "digital_rf_hdf5" module if you want to read USRP data | |
| @@ -1,88 +1,88 | |||
|
|
1 | 1 | import argparse |
|
|
2 | 2 | |
|
|
3 | 3 | from schainpy.controller import Project, multiSchain |
|
|
4 | 4 | |
|
|
5 | 5 | desc = "HF_EXAMPLE" |
|
|
6 | 6 | |
|
|
7 | 7 | controllerObj = Project() |
|
|
8 | 8 | |
|
|
9 | 9 | controllerObj.setup(id='191', name='test01', description=desc) |
|
|
10 | 10 | |
|
|
11 | 11 | readUnitConfObj = controllerObj.addReadUnit(datatype='SpectraReader', |
|
|
12 | 12 | path='/home/nanosat/data/sp1_f0', |
|
|
13 | 13 | startDate="2017/01/26", |
|
|
14 | 14 | endDate="2017/01/26", |
|
|
15 | 15 | startTime="00:00:00", |
|
|
16 | 16 | endTime="23:59:59", |
|
|
17 | 17 | online=0, |
|
|
18 | 18 | #set=1426485881, |
|
|
19 | 19 | walk=1, |
|
|
20 | 20 | verbose=1 |
|
|
21 | 21 | #timezone=-5*3600 |
|
|
22 | 22 | ) |
|
|
23 | 23 | |
|
|
24 | 24 | # #opObj11 = readUnitConfObj.addOperation(name='printNumberOfBlock') |
|
|
25 | 25 | # |
|
|
26 | procUnitConfObj2 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId()) | |
|
|
26 | # procUnitConfObj2 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId()) | |
|
|
27 | 27 | # procUnitConfObj2.addParameter(name='nipp', value='5', format='int') |
|
|
28 | 28 | |
|
|
29 | 29 | procUnitConfObj3 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=readUnitConfObj.getId()) |
|
|
30 | 30 | opObj11 = procUnitConfObj3.addOperation(name='SpectralMoments', optype='other') |
|
|
31 | 31 | |
|
|
32 | 32 | # |
|
|
33 | 33 | # opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other') |
|
|
34 | 34 | # opObj11.addParameter(name='id', value='1000', format='int') |
|
|
35 | 35 | # opObj11.addParameter(name='wintitle', value='HF_Jicamarca_Spc', format='str') |
|
|
36 | 36 | # opObj11.addParameter(name='channelList', value='0', format='intlist') |
|
|
37 | 37 | # opObj11.addParameter(name='zmin', value='-120', format='float') |
|
|
38 | 38 | # opObj11.addParameter(name='zmax', value='-70', format='float') |
|
|
39 | 39 | # opObj11.addParameter(name='save', value='1', format='int') |
|
|
40 | 40 | # opObj11.addParameter(name='figpath', value=figpath, format='str') |
|
|
41 | 41 | |
|
|
42 | 42 | opObj11 = procUnitConfObj3.addOperation(name='Parameters1Plot', optype='other') |
|
|
43 | 43 | # opObj11.addParameter(name='channelList', value='0', format='intList') |
|
|
44 | 44 | |
|
|
45 | 45 | opObj11.addParameter(name='id', value='2000', format='int') |
|
|
46 | 46 | # # opObj11.addParameter(name='colormap', value='0', format='bool') |
|
|
47 | 47 | opObj11.addParameter(name='onlySNR', value='1', format='bool') |
|
|
48 | 48 | opObj11.addParameter(name='DOP', value='0', format='bool') |
|
|
49 | 49 | opObj11.addParameter(name='SNR', value='1', format='bool') |
|
|
50 | 50 | opObj11.addParameter(name='SNRthresh', value='0', format='int') |
|
|
51 | 51 | opObj11.addParameter(name='SNRmin', value='-10', format='int') |
|
|
52 | 52 | opObj11.addParameter(name='SNRmax', value='30', format='int') |
|
|
53 | 53 | opObj11.addParameter(name='xmin', value='0', format='int') |
|
|
54 | 54 | opObj11.addParameter(name='xmax', value='24', format='int') |
|
|
55 | 55 | |
|
|
56 | 56 | # opObj12 = procUnitConfObj3.addOperation(name='ParametersPlot', optype='other') |
|
|
57 | 57 | # #opObj11.addParameter(name='channelList', value='0', format='intlist') |
|
|
58 | 58 | # opObj12.addParameter(name='id', value='301', format='int') |
|
|
59 | 59 | # opObj12.addParameter(name='xmin', value='0', format='float') |
|
|
60 | 60 | # opObj12.addParameter(name='xmax', value='24', format='float') |
|
|
61 | 61 | |
|
|
62 | 62 | # opObj11.addParameter(name='zmin', value='-110', format='float') |
|
|
63 | 63 | # opObj11.addParameter(name='zmax', value='-70', format='float') |
|
|
64 | 64 | # opObj11.addParameter(name='save', value='0', format='int') |
|
|
65 | 65 | # # opObj11.addParameter(name='figpath', value='/tmp/', format='str') |
|
|
66 | 66 | # |
|
|
67 | 67 | # opObj12 = procUnitConfObj3.addOperation(name='PublishData', optype='other') |
|
|
68 | 68 | # opObj12.addParameter(name='zeromq', value=1, format='int') |
|
|
69 | 69 | # opObj12.addParameter(name='verbose', value=0, format='bool') |
|
|
70 | 70 | |
|
|
71 | 71 | |
|
|
72 | 72 | # opObj13 = procUnitConfObj3.addOperation(name='PublishData', optype='other') |
|
|
73 | 73 | # opObj13.addParameter(name='zeromq', value=1, format='int') |
|
|
74 | 74 | # opObj13.addParameter(name='server', value="juanca", format='str') |
|
|
75 | 75 | |
|
|
76 | 76 | # opObj12.addParameter(name='delay', value=0, format='int') |
|
|
77 | 77 | |
|
|
78 | 78 | |
|
|
79 | 79 | # print "Escribiendo el archivo XML" |
|
|
80 | 80 | # controllerObj.writeXml(filename) |
|
|
81 | 81 | # print "Leyendo el archivo XML" |
|
|
82 | 82 | # controllerObj.readXml(filename) |
|
|
83 | 83 | |
|
|
84 | 84 | |
|
|
85 | 85 | # timeit.timeit('controllerObj.run()', number=2) |
|
|
86 | 86 | |
|
|
87 | 87 | controllerObj.start() |
|
|
88 | 88 | |
| @@ -1,97 +1,94 | |||
|
|
1 | 1 | import argparse |
|
|
2 | 2 | |
|
|
3 | 3 | from schainpy.controller import Project, multiSchain |
|
|
4 | 4 | |
|
|
5 | 5 | desc = "HF_EXAMPLE" |
|
|
6 | 6 | |
|
|
7 | 7 | def fiber(cursor, skip, q, dt): |
|
|
8 | 8 | |
|
|
9 | 9 | controllerObj = Project() |
|
|
10 | 10 | |
|
|
11 | 11 | controllerObj.setup(id='191', name='test01', description=desc) |
|
|
12 | 12 | |
|
|
13 | 13 | readUnitConfObj = controllerObj.addReadUnit(datatype='SpectraReader', |
|
|
14 | 14 | path='/home/nanosat/data/julia', |
|
|
15 | 15 | startDate=dt, |
|
|
16 | 16 | endDate=dt, |
|
|
17 | 17 | startTime="00:00:00", |
|
|
18 | 18 | endTime="23:59:59", |
|
|
19 | 19 | online=0, |
|
|
20 | 20 | #set=1426485881, |
|
|
21 | 21 | delay=10, |
|
|
22 | 22 | walk=1, |
|
|
23 | 23 | queue=q, |
|
|
24 | 24 | cursor=cursor, |
|
|
25 | 25 | skip=skip, |
|
|
26 | 26 | #timezone=-5*3600 |
|
|
27 | 27 | ) |
|
|
28 | 28 | |
|
|
29 | 29 | # #opObj11 = readUnitConfObj.addOperation(name='printNumberOfBlock') |
|
|
30 | 30 | # |
|
|
31 | 31 | procUnitConfObj2 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId()) |
|
|
32 | 32 | # procUnitConfObj2.addParameter(name='nipp', value='5', format='int') |
|
|
33 | 33 | |
|
|
34 | 34 | # procUnitConfObj3 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=readUnitConfObj.getId()) |
|
|
35 | 35 | # opObj11 = procUnitConfObj3.addOperation(name='SpectralMoments', optype='other') |
|
|
36 | 36 | |
|
|
37 | 37 | # |
|
|
38 |
|
|
|
|
39 |
|
|
|
|
40 |
|
|
|
|
41 |
|
|
|
|
42 |
|
|
|
|
43 | # opObj11.addParameter(name='zmax', value='-70', format='float') | |
|
|
44 | # opObj11.addParameter(name='save', value='1', format='int') | |
|
|
45 | # opObj11.addParameter(name='figpath', value=figpath, format='str') | |
|
|
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') | |
|
|
46 | 43 | |
|
|
47 | 44 | # opObj11 = procUnitConfObj3.addOperation(name='Parameters1Plot', optype='other') |
|
|
48 | 45 | # opObj11.addParameter(name='channelList', value='0', format='intList') |
|
|
49 | 46 | # |
|
|
50 | 47 | # opObj11.addParameter(name='id', value='2000', format='int') |
|
|
51 | 48 | # # opObj11.addParameter(name='colormap', value='0', format='bool') |
|
|
52 | 49 | # opObj11.addParameter(name='onlySNR', value='1', format='bool') |
|
|
53 | 50 | # opObj11.addParameter(name='DOP', value='0', format='bool') |
|
|
54 | 51 | # opObj11.addParameter(name='showSNR', value='1', format='bool') |
|
|
55 | 52 | # opObj11.addParameter(name='SNRthresh', value='0', format='int') |
|
|
56 | 53 | # opObj11.addParameter(name='SNRmin', value='-10', format='int') |
|
|
57 | 54 | # opObj11.addParameter(name='SNRmax', value='30', format='int') |
|
|
58 | 55 | |
|
|
59 | 56 | # opObj11.addParameter(name='showSNR', value='1', format='int') |
|
|
60 | 57 | # # opObj11.addParameter(name='channelList', value='0', format='intlist') |
|
|
61 | 58 | # # opObj11.addParameter(name='xmin', value='0', format='float') |
|
|
62 | 59 | # opObj11.addParameter(name='xmin', value='0', format='float') |
|
|
63 | 60 | # opObj11.addParameter(name='xmax', value='24', format='float') |
|
|
64 | 61 | |
|
|
65 | 62 | # opObj11.addParameter(name='zmin', value='-110', format='float') |
|
|
66 | 63 | # opObj11.addParameter(name='zmax', value='-70', format='float') |
|
|
67 | 64 | # opObj11.addParameter(name='save', value='0', format='int') |
|
|
68 | 65 | # # opObj11.addParameter(name='figpath', value='/tmp/', format='str') |
|
|
69 | 66 | # |
|
|
70 | opObj12 = procUnitConfObj2.addOperation(name='PublishData', optype='other') | |
|
|
71 | opObj12.addParameter(name='zeromq', value=1, format='int') | |
|
|
67 | # opObj12 = procUnitConfObj2.addOperation(name='PublishData', optype='other') | |
|
|
68 | # opObj12.addParameter(name='zeromq', value=1, format='int') | |
|
|
72 | 69 | # opObj12.addParameter(name='server', value='tcp://10.10.10.82:7000', format='str') |
|
|
73 | 70 | |
|
|
74 | 71 | |
|
|
75 | 72 | # opObj13 = procUnitConfObj3.addOperation(name='PublishData', optype='other') |
|
|
76 | 73 | # opObj13.addParameter(name='zeromq', value=1, format='int') |
|
|
77 | 74 | # opObj13.addParameter(name='server', value="juanca", format='str') |
|
|
78 | 75 | |
|
|
79 | 76 | # opObj12.addParameter(name='delay', value=1, format='int') |
|
|
80 | 77 | |
|
|
81 | 78 | |
|
|
82 | 79 | # print "Escribiendo el archivo XML" |
|
|
83 | 80 | # controllerObj.writeXml(filename) |
|
|
84 | 81 | # print "Leyendo el archivo XML" |
|
|
85 | 82 | # controllerObj.readXml(filename) |
|
|
86 | 83 | |
|
|
87 | 84 | |
|
|
88 | 85 | # timeit.timeit('controllerObj.run()', number=2) |
|
|
89 | 86 | |
|
|
90 | 87 | controllerObj.start() |
|
|
91 | 88 | |
|
|
92 | 89 | |
|
|
93 | 90 | if __name__ == '__main__': |
|
|
94 | 91 | parser = argparse.ArgumentParser(description='Set number of parallel processes') |
|
|
95 | 92 | parser.add_argument('--nProcess', default=1, type=int) |
|
|
96 | 93 | args = parser.parse_args() |
|
|
97 | 94 | multiSchain(fiber, nProcess=args.nProcess, startDate='2016/08/19', endDate='2016/08/19') |
| @@ -1,61 +1,61 | |||
|
|
1 | 1 | #!/usr/bin/env python |
|
|
2 | 2 | ''' |
|
|
3 | 3 | Created on Jul 7, 2014 |
|
|
4 | 4 | |
|
|
5 | 5 | @author: roj-idl71 |
|
|
6 | 6 | ''' |
|
|
7 | 7 | import os, sys |
|
|
8 | 8 | |
|
|
9 | 9 | from schainpy.controller import Project |
|
|
10 | 10 | |
|
|
11 | 11 | if __name__ == '__main__': |
|
|
12 | 12 | desc = "Segundo Test" |
|
|
13 | 13 | |
|
|
14 | 14 | controllerObj = Project() |
|
|
15 | 15 | controllerObj.setup(id='191', name='test01', description=desc) |
|
|
16 | 16 | |
|
|
17 | 17 | proc1 = controllerObj.addProcUnit(name='ReceiverData') |
|
|
18 | 18 | proc1.addParameter(name='realtime', value='0', format='bool') |
|
|
19 |
proc1.addParameter(name='plottypes', value=' |
|
|
|
20 |
proc1.addParameter(name='throttle', value=' |
|
|
|
19 | proc1.addParameter(name='plottypes', value='snr', format='str') | |
|
|
20 | proc1.addParameter(name='throttle', value='5', format='int') | |
|
|
21 | 21 | proc1.addParameter(name='interactive', value='0', format='bool') |
|
|
22 | 22 | # proc1.addParameter(name='server', value='tcp://10.10.10.82:7000', format='str') |
|
|
23 | 23 | ## TODO Agregar direccion de server de publicacion a graficos como variable |
|
|
24 | 24 | op3 = proc1.addOperation(name='PlotSNRData', optype='other') |
|
|
25 | 25 | op3.addParameter(name='wintitle', value='Julia 150Km', format='str') |
|
|
26 | 26 | op3.addParameter(name='zmax', value='30', format='int') |
|
|
27 | 27 | op3.addParameter(name='zmin', value='-10', format='int') |
|
|
28 | 28 | op3.addParameter(name='save', value='/home/nanosat/Pictures', format='str') |
|
|
29 | 29 | op3.addParameter(name='show', value='0', format='bool') |
|
|
30 | 30 | # # |
|
|
31 | op4 = proc1.addOperation(name='PlotDOPData', optype='other') | |
|
|
32 | op4.addParameter(name='wintitle', value='Julia 150Km', format='str') | |
|
|
33 | op4.addParameter(name='save', value='/home/nanosat/Pictures', format='str') | |
|
|
34 | op4.addParameter(name='show', value='0', format='bool') | |
|
|
35 | op4.addParameter(name='colormap', value='jet', format='str') | |
|
|
36 | ||
|
|
37 | op1 = proc1.addOperation(name='PlotRTIData', optype='other') | |
|
|
38 | op1.addParameter(name='wintitle', value='Julia 150Km', format='str') | |
|
|
39 | op1.addParameter(name='save', value='/home/nanosat/Pictures', format='str') | |
|
|
40 | op1.addParameter(name='show', value='0', format='bool') | |
|
|
41 | op1.addParameter(name='colormap', value='jet', format='str') | |
|
|
42 | # | |
|
|
43 | op2 = proc1.addOperation(name='PlotCOHData', optype='other') | |
|
|
44 | op2.addParameter(name='wintitle', value='Julia 150Km', format='str') | |
|
|
45 | op2.addParameter(name='save', value='/home/nanosat/Pictures', format='str') | |
|
|
46 | op2.addParameter(name='colormap', value='jet', format='str') | |
|
|
47 | op2.addParameter(name='show', value='0', format='bool') | |
|
|
48 | # # # | |
|
|
49 | op6 = proc1.addOperation(name='PlotPHASEData', optype='other') | |
|
|
50 | op6.addParameter(name='wintitle', value='Julia 150Km', format='str') | |
|
|
51 | op6.addParameter(name='save', value='/home/nanosat/Pictures', format='str') | |
|
|
52 | op6.addParameter(name='show', value='1', format='bool') | |
|
|
31 | # op4 = proc1.addOperation(name='PlotDOPData', optype='other') | |
|
|
32 | # op4.addParameter(name='wintitle', value='Julia 150Km', format='str') | |
|
|
33 | # op4.addParameter(name='save', value='/home/nanosat/Pictures', format='str') | |
|
|
34 | # op4.addParameter(name='show', value='0', format='bool') | |
|
|
35 | # op4.addParameter(name='colormap', value='jet', format='str') | |
|
|
36 | ||
|
|
37 | # op1 = proc1.addOperation(name='PlotRTIData', optype='other') | |
|
|
38 | # op1.addParameter(name='wintitle', value='Julia 150Km', format='str') | |
|
|
39 | # op1.addParameter(name='save', value='/home/nanosat/Pictures', format='str') | |
|
|
40 | # op1.addParameter(name='show', value='0', format='bool') | |
|
|
41 | # op1.addParameter(name='colormap', value='jet', format='str') | |
|
|
42 | # # | |
|
|
43 | # op2 = proc1.addOperation(name='PlotCOHData', optype='other') | |
|
|
44 | # op2.addParameter(name='wintitle', value='Julia 150Km', format='str') | |
|
|
45 | # op2.addParameter(name='save', value='/home/nanosat/Pictures', format='str') | |
|
|
46 | # op2.addParameter(name='colormap', value='jet', format='str') | |
|
|
47 | # op2.addParameter(name='show', value='0', format='bool') | |
|
|
48 | # # # # | |
|
|
49 | # op6 = proc1.addOperation(name='PlotPHASEData', optype='other') | |
|
|
50 | # op6.addParameter(name='wintitle', value='Julia 150Km', format='str') | |
|
|
51 | # op6.addParameter(name='save', value='/home/nanosat/Pictures', format='str') | |
|
|
52 | # op6.addParameter(name='show', value='1', format='bool') | |
|
|
53 | 53 | # # |
|
|
54 | 54 | # # proc2 = controllerObj.addProcUnit(name='ReceiverData') |
|
|
55 | 55 | # # proc2.addParameter(name='server', value='juanca', format='str') |
|
|
56 | 56 | # # proc2.addParameter(name='plottypes', value='snr,dop', format='str') |
|
|
57 | 57 | # # |
|
|
58 | 58 | |
|
|
59 | 59 | |
|
|
60 | 60 | |
|
|
61 | 61 | controllerObj.start() |
| @@ -1,1 +1,1 | |||
|
|
1 |
<Project description="HF_EXAMPLE" id="191" name="test01"><ReadUnit datatype="SpectraReader" id="1911" inputId="0" name="SpectraReader"><Operation id="19111" name="run" priority="1" type="self"><Parameter format="str" id="191111" name="datatype" value="SpectraReader" /><Parameter format="str" id="191112" name="path" value="/home/nanosat/data/sp1_f0" /><Parameter format="date" id="191113" name="startDate" value="2017/01/26" /><Parameter format="date" id="191114" name="endDate" value="2017/01/26" /><Parameter format="time" id="191115" name="startTime" value="00:00:00" /><Parameter format="time" id="191116" name="endTime" value="23:59:59" /><Parameter format="int" id="191118" name="cursor" value=" |
|
|
|
1 | <Project description="HF_EXAMPLE" id="191" name="test01"><ReadUnit datatype="SpectraReader" id="1911" inputId="0" name="SpectraReader"><Operation id="19111" name="run" priority="1" type="self"><Parameter format="str" id="191111" name="datatype" value="SpectraReader" /><Parameter format="str" id="191112" name="path" value="/home/nanosat/data/sp1_f0" /><Parameter format="date" id="191113" name="startDate" value="2017/01/26" /><Parameter format="date" id="191114" name="endDate" value="2017/01/26" /><Parameter format="time" id="191115" name="startTime" value="00:00:00" /><Parameter format="time" id="191116" name="endTime" value="23:59:59" /><Parameter format="int" id="191118" name="cursor" value="32" /><Parameter format="int" id="191119" name="skip" value="22" /><Parameter format="int" id="191120" name="walk" value="1" /><Parameter format="int" id="191121" name="verbose" value="1" /><Parameter format="int" id="191122" name="online" value="0" /></Operation></ReadUnit><ProcUnit datatype="ParametersProc" id="1913" inputId="1911" name="ParametersProc"><Operation id="19131" name="run" priority="1" type="self" /><Operation id="19132" name="SpectralMoments" priority="2" type="other" /><Operation id="19133" name="PublishData" priority="3" type="other"><Parameter format="int" id="191331" name="zeromq" value="1" /><Parameter format="bool" id="191332" name="verbose" value="0" /><Parameter format="int" id="191333" name="delay" value="0" /></Operation></ProcUnit><ProcUnit datatype="Spectra" id="1912" inputId="1911" name="SpectraProc"><Operation id="19121" name="run" priority="1" type="self" /></ProcUnit></Project> No newline at end of file | |
|
|
1 | NO CONTENT: modified file |
General Comments 0
You need to be logged in to leave comments.
Login now