| @@ -0,0 +1,94 | |||
|
|
1 | import os, sys | |
|
|
2 | ||
|
|
3 | from schainpy.controller import Project | |
|
|
4 | ||
|
|
5 | if __name__ == '__main__': | |
|
|
6 | ||
|
|
7 | desc = "Segundo Test" | |
|
|
8 | filename = "schain.xml" | |
|
|
9 | ||
|
|
10 | controllerObj = Project() | |
|
|
11 | ||
|
|
12 | controllerObj.setup(id = '191', name='test01', description=desc) | |
|
|
13 | ||
|
|
14 | readUnitConfObj = controllerObj.addReadUnit(datatype='VoltageReader', | |
|
|
15 | path='/home/jchavez/jicamarca/jro_data/rawdata/', | |
|
|
16 | startDate='2010/10/28', | |
|
|
17 | endDate='2017/10/28', | |
|
|
18 | startTime='00:00:00', | |
|
|
19 | endTime='23:59:59', | |
|
|
20 | online=0, | |
|
|
21 | walk=0) | |
|
|
22 | ||
|
|
23 | opObj00 = readUnitConfObj.addOperation(name='printNumberOfBlock') | |
|
|
24 | ||
|
|
25 | procUnitConfObj0 = controllerObj.addProcUnit(datatype='VoltageProc', | |
|
|
26 | inputId=readUnitConfObj.getId()) | |
|
|
27 | ||
|
|
28 | opObj10 = procUnitConfObj0.addOperation(name='DigitalRFWriter', optype='other') | |
|
|
29 | opObj10.addParameter(name='path', value='/home/jchavez/jicamarca/data_sink/', format='str') | |
|
|
30 | # opObj10.addParameter(name='minHei', value='0', format='float') | |
|
|
31 | # opObj10.addParameter(name='maxHei', value='8', format='float') | |
|
|
32 | ||
|
|
33 | # opObj10 = procUnitConfObj0.addOperation(name='filterByHeights') | |
|
|
34 | # opObj10.addParameter(name='window', value='2', format='float') | |
|
|
35 | ||
|
|
36 | # opObj10 = procUnitConfObj0.addOperation(name='Decoder', optype='external') | |
|
|
37 | # opObj10.addParameter(name='code', value='1,-1', format='intlist') | |
|
|
38 | # opObj10.addParameter(name='nCode', value='2', format='float') | |
|
|
39 | # opObj10.addParameter(name='nBaud', value='1', format='float') | |
|
|
40 | ||
|
|
41 | ||
|
|
42 | # opObj10 = procUnitConfObj0.addOperation(name='CohInt', optype='external') | |
|
|
43 | # opObj10.addParameter(name='n', value='1296', format='float') | |
|
|
44 | ||
|
|
45 | # procUnitConfObj1 = controllerObj.addProcUnit(datatype='SpectraProc', | |
|
|
46 | # inputId=procUnitConfObj0.getId()) | |
|
|
47 | ||
|
|
48 | #Creating a processing object with its parameters | |
|
|
49 | #schainpy.model.proc.jroproc_spectra.SpectraProc.run() | |
|
|
50 | #If you need to add more parameters can use the "addParameter method" | |
|
|
51 | # procUnitConfObj1.addParameter(name='nFFTPoints', value='128', format='int') | |
|
|
52 | ||
|
|
53 | # opObj10 = procUnitConfObj1.addOperation(name='IncohInt', optype='external') | |
|
|
54 | # opObj10.addParameter(name='n', value='2', format='float') | |
|
|
55 | ||
|
|
56 | #Using internal methods | |
|
|
57 | #schainpy.model.proc.jroproc_spectra.SpectraProc.selectChannels() | |
|
|
58 | # opObj10 = procUnitConfObj1.addOperation(name='selectChannels') | |
|
|
59 | # opObj10.addParameter(name='channelList', value='0,1', format='intlist') | |
|
|
60 | ||
|
|
61 | #Using internal methods | |
|
|
62 | #schainpy.model.proc.jroproc_spectra.SpectraProc.selectHeights() | |
|
|
63 | # opObj10 = procUnitConfObj1.addOperation(name='selectHeights') | |
|
|
64 | # opObj10.addParameter(name='minHei', value='90', format='float') | |
|
|
65 | # opObj10.addParameter(name='maxHei', value='180', format='float') | |
|
|
66 | ||
|
|
67 | #Using external methods (new modules) | |
|
|
68 | # #schainpy.model.proc.jroproc_spectra.IncohInt.setup() | |
|
|
69 | # opObj12 = procUnitConfObj1.addOperation(name='IncohInt', optype='other') | |
|
|
70 | # opObj12.addParameter(name='n', value='1', format='int') | |
|
|
71 | ||
|
|
72 | #Using external methods (new modules) | |
|
|
73 | #schainpy.model.graphics.jroplot_spectra.SpectraPlot.setup() | |
|
|
74 | # opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='external') | |
|
|
75 | # opObj11.addParameter(name='id', value='11', format='int') | |
|
|
76 | # opObj11.addParameter(name='wintitle', value='SpectraPlot', format='str') | |
|
|
77 | # opObj11.addParameter(name='zmin', value='-60', format='int') | |
|
|
78 | # opObj11.addParameter(name='zmax', value='10', format='int') | |
|
|
79 | # opObj11.addParameter(name='save', value='1', format='int') | |
|
|
80 | ||
|
|
81 | # #Using external methods (new modules) | |
|
|
82 | # #schainpy.model.graphics.jroplot_spectra.RTIPlot.setup() | |
|
|
83 | # opObj11 = procUnitConfObj1.addOperation(name='RTIPlot', optype='other') | |
|
|
84 | # opObj11.addParameter(name='id', value='30', format='int') | |
|
|
85 | # opObj11.addParameter(name='wintitle', value='RTI', format='str') | |
|
|
86 | # opObj11.addParameter(name='zmin', value='-60', format='int') | |
|
|
87 | # opObj11.addParameter(name='zmax', value='-10', format='int') | |
|
|
88 | # opObj11.addParameter(name='showprofile', value='1', format='int') | |
|
|
89 | # # opObj11.addParameter(name='timerange', value=str(5*60*60*60), format='int') | |
|
|
90 | # opObj11.addParameter(name='xmin', value='14', format='float') | |
|
|
91 | # opObj11.addParameter(name='xmax', value='23.9', format='float') | |
|
|
92 | # opObj11.addParameter(name='save', value='1', format='int') | |
|
|
93 | ||
|
|
94 | controllerObj.start() | |
| @@ -370,7 +370,6 class RadarControllerHeader(Header): | |||
|
|
370 | 370 | if fp.tell() < endFp: |
|
|
371 | 371 | sys.stderr.write("Warning %s: Size value read from Radar Controller header is greater than it has to be\n" %fp.name) |
|
|
372 | 372 | |
|
|
373 | ||
|
|
374 | 373 | return 1 |
|
|
375 | 374 | |
|
|
376 | 375 | def write(self, fp): |
| @@ -548,7 +548,7 class DigitalRFWriter(Operation): | |||
|
|
548 | 548 | Operation.__init__(self, **kwargs) |
|
|
549 | 549 | self.dataOut = None |
|
|
550 | 550 | |
|
|
551 |
def setup(self, dataIn, path, blocksPerFile, set=0, ext= |
|
|
|
551 | def setup(self, dataIn, path, blocksPerFile, set=0, ext='.h5'): | |
|
|
552 | 552 | ''' |
|
|
553 | 553 | In this method we should set all initial parameters. |
|
|
554 | 554 | |
| @@ -566,7 +566,7 class DigitalRFWriter(Operation): | |||
|
|
566 | 566 | |
|
|
567 | 567 | return |
|
|
568 | 568 | |
|
|
569 | def run(self, dataIn, **kwargs): | |
|
|
569 | def run(self, dataIn, path=None, **kwargs): | |
|
|
570 | 570 | ''' |
|
|
571 | 571 | This method will be called many times so here you should put all your code |
|
|
572 | 572 | |
| @@ -575,9 +575,15 class DigitalRFWriter(Operation): | |||
|
|
575 | 575 | dataIn : object with the data |
|
|
576 | 576 | |
|
|
577 | 577 | ''' |
|
|
578 | ||
|
|
578 | print dir(dataIn) | |
|
|
579 | print 'blocksize', dataIn.blocksize | |
|
|
580 | print 'channelIndexList', dataIn.channelIndexList | |
|
|
581 | print 'ippSeconds', dataIn.ippSeconds | |
|
|
582 | print 'frequency', dataIn.frequency | |
|
|
583 | print 'nProfiles', dataIn.nProfiles | |
|
|
584 | print 'systemHeaderObj.nSamples', dataIn.systemHeaderObj.nSamples | |
|
|
579 | 585 | if not self.isConfig: |
|
|
580 | self.setup(dataIn, **kwargs) | |
|
|
586 | self.setup(dataIn, path, **kwargs) | |
|
|
581 | 587 | |
|
|
582 | 588 | |
|
|
583 | 589 | if __name__ == '__main__': |
| @@ -1,1 +1,1 | |||
|
|
1 | <Project description="Testing USRP data reader" id="191" name="test01"><ReadUnit datatype="DigitalRF" id="1911" inputId="0" name="DigitalRFReader"><Operation id="19111" name="run" priority="1" type="self"><Parameter format="str" id="191111" name="datatype" value="DigitalRF" /><Parameter format="str" id="191112" name="path" value="/home/jchavez/jicamarca/mocked_data" /><Parameter format="date" id="191113" name="startDate" value="2000/07/03" /><Parameter format="date" id="191114" name="endDate" value="2017/07/03" /><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="ippKm" value="60" /><Parameter format="int" id="191119" name="online" value="0" /></Operation></ReadUnit><ProcUnit datatype="Voltage" id="1912" inputId="1911" name="VoltageProc"><Operation id="19121" name="run" priority="1" type="self" /><Operation id="19122" name="CohInt" priority="2" type="external"><Parameter format="float" id="191221" name="n" value="1" /></Operation><Operation id="19123" name="Scope" priority="3" type="external"><Parameter format="int" id="191231" name="id" value="121" /><Parameter format="str" id="191232" name="wintitle" value="Scope" /></Operation></ProcUnit></Project> No newline at end of file | |
|
|
1 | <Project description="Segundo Test" id="191" name="test01"><ReadUnit datatype="VoltageReader" id="1911" inputId="0" name="VoltageReader"><Operation id="19111" name="run" priority="1" type="self"><Parameter format="str" id="191111" name="datatype" value="VoltageReader" /><Parameter format="str" id="191112" name="path" value="/home/jchavez/jicamarca/jro_data/rawdata" /><Parameter format="date" id="191113" name="startDate" value="2010/10/28" /><Parameter format="date" id="191114" name="endDate" value="2017/10/28" /><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="online" value="0" /><Parameter format="int" id="191119" name="walk" value="0" /></Operation><Operation id="19112" name="printNumberOfBlock" priority="2" type="self" /></ReadUnit><ProcUnit datatype="VoltageProc" id="1912" inputId="1911" name="VoltageProc"><Operation id="19121" name="run" priority="1" type="self" /><Operation id="19122" name="DigitalRFWriter" priority="2" type="other"><Parameter format="str" id="191221" name="path" value="/home/jchavez/jicamarca/data_sink/" /></Operation></ProcUnit></Project> No newline at end of file | |
General Comments 0
You need to be logged in to leave comments.
Login now