##// END OF EJS Templates
schain
RSS
cleaning trunk
Juan C. Valdez -
r885:47a9233afe94
parent child
Show More
Show file before | Show file after | Hide comments
@@ -0,0 +1,76
1 #!/usr/bin/env python
2 '''
3 Created on Jul 7, 2014
4
5 @author: roj-idl71
6 '''
7 import os, sys
8 from Queue import Queue
9 from time import sleep
10
11 from schainpy.controller_api import ControllerThread
12 from schainpy.model.graphics.jroplotter import PlotManager
13
14 def main():
15 desc = "Segundo Test"
16 filename = "schain.xml"
17
18 controllerObj = ControllerThread()
19
20 controllerObj.setup(id = '191', name='test01', description=desc)
21
22 readUnitConfObj = controllerObj.addReadUnit(datatype='Spectra',
23 path='../data/pdata/',
24 startDate='2010/12/18',
25 endDate='2015/12/22',
26 startTime='00:00:00',
27 endTime='23:59:59',
28 online=0,
29 walk=0,
30 expLabel='')
31
32 procUnitConfObj1 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId())
33
34 opObj10 = procUnitConfObj1.addOperation(name='selectChannels')
35 opObj10.addParameter(name='channelList', value='0,1', format='intlist')
36
37 opObj10 = procUnitConfObj1.addOperation(name='selectHeights')
38 opObj10.addParameter(name='minHei', value='90', format='float')
39 opObj10.addParameter(name='maxHei', value='180', format='float')
40
41 opObj10 = procUnitConfObj1.addOperation(name='removeDC')
42
43 opObj12 = procUnitConfObj1.addOperation(name='IncohInt', optype='other')
44 opObj12.addParameter(name='n', value='1', format='int')
45
46 opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other')
47 opObj11.addParameter(name='id', value='1', format='int')
48 opObj11.addParameter(name='wintitle', value='SpectraPlot0', format='str')
49 opObj11.addParameter(name='showprofile', value='1', format='int')
50 opObj11.addParameter(name='save', value='0', format='int')
51 opObj11.addParameter(name='figpath', value='/Users/miguel/Data/JULIA/pdata/graphs')
52
53 opObj11 = procUnitConfObj1.addOperation(name='RTIPlot', optype='other')
54 opObj11.addParameter(name='id', value='10', format='int')
55 opObj11.addParameter(name='wintitle', value='RTI', format='str')
56 opObj11.addParameter(name='xmin', value='21', format='float')
57 opObj11.addParameter(name='xmax', value='22', format='float')
58 opObj11.addParameter(name='zmin', value='12', format='int')
59 opObj11.addParameter(name='zmax', value='32', format='int')
60 opObj11.addParameter(name='showprofile', value='1', format='int')
61 opObj11.addParameter(name='timerange', value=str(2*60*60), format='int')
62
63 ########################################
64 #Configure use of external plotter before start
65 plotterObj = controllerObj.useExternalPlotter()
66 ########################################
67
68 controllerObj.start()
69
70 plotterObj.start()
71
72 if __name__ == '__main__':
73 import time
74 start_time = time.time()
75 main()
76 print("--- %s seconds ---" % (time.time() - start_time))
Show file before | Show file after | Hide comments
@@ -0,0 +1,66
1 #!/usr/bin/env python
2 '''
3 Created on Jul 7, 2014
4
5 @author: roj-idl71
6 '''
7 import os, sys
8
9 from schainpy.controller import Project
10
11 def main():
12 desc = "Segundo Test"
13 filename = "schain.xml"
14
15 controllerObj = Project()
16
17 controllerObj.setup(id = '191', name='test01', description=desc)
18
19 readUnitConfObj = controllerObj.addReadUnit(datatype='Spectra',
20 path='../data/pdata/',
21 startDate='2010/12/18',
22 endDate='2015/12/22',
23 startTime='00:00:00',
24 endTime='23:59:59',
25 online=0,
26 walk=0,
27 expLabel='')
28
29 procUnitConfObj1 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId())
30
31 opObj10 = procUnitConfObj1.addOperation(name='selectChannels')
32 opObj10.addParameter(name='channelList', value='0,1', format='intlist')
33
34 opObj10 = procUnitConfObj1.addOperation(name='selectHeights')
35 opObj10.addParameter(name='minHei', value='90', format='float')
36 opObj10.addParameter(name='maxHei', value='180', format='float')
37
38 opObj10 = procUnitConfObj1.addOperation(name='removeDC')
39
40 opObj12 = procUnitConfObj1.addOperation(name='IncohInt', optype='other')
41 opObj12.addParameter(name='n', value='1', format='int')
42
43 opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other')
44 opObj11.addParameter(name='id', value='1', format='int')
45 opObj11.addParameter(name='wintitle', value='SpectraPlot0', format='str')
46 opObj11.addParameter(name='showprofile', value='1', format='int')
47 opObj11.addParameter(name='save', value='0', format='int')
48 opObj11.addParameter(name='figpath', value='/Users/miguel/Data/JULIA/pdata/graphs')
49
50 opObj11 = procUnitConfObj1.addOperation(name='RTIPlot', optype='other')
51 opObj11.addParameter(name='id', value='10', format='int')
52 opObj11.addParameter(name='wintitle', value='RTI', format='str')
53 # opObj11.addParameter(name='xmin', value='21', format='float')
54 # opObj11.addParameter(name='xmax', value='22', format='float')
55 opObj11.addParameter(name='zmin', value='12', format='int')
56 opObj11.addParameter(name='zmax', value='32', format='int')
57 opObj11.addParameter(name='showprofile', value='1', format='int')
58 opObj11.addParameter(name='timerange', value=str(2*60*60), format='int')
59
60 controllerObj.start()
61
62 if __name__ == '__main__':
63 import time
64 start_time = time.time()
65 main()
66 print("--- %s seconds ---" % (time.time() - start_time))
Show file before | Show file after | Hide comments
@@ -0,0 +1,118
1 #!/usr/bin/env python
2 '''
3 Created on Jul 7, 2014
4
5 @author: roj-idl71
6 '''
7 import os, sys
8
9 from schainpy.controller import Project
10
11 def main():
12
13 desc = "Testing USRP data reader"
14 filename = "schain.xml"
15 figpath = "./"
16 remotefolder = "/home/wmaster/graficos"
17
18 #this controller object save all user configuration and then execute each module
19 #with their parameters.
20 controllerObj = Project()
21
22 controllerObj.setup(id = '191', name='test01', description=desc)
23
24 #Creating a reader object with its parameters
25 #schainpy.model.io.jroIO_usrp.USRPReader.setup()
26 readUnitConfObj = controllerObj.addReadUnit(datatype='USRP',
27 path='../data/haystack/',
28 startDate='2000/07/03',
29 endDate='2015/07/03',
30 startTime='00:00:00',
31 endTime='23:59:59',
32 online=0,
33 ippKm = 60)
34
35 procUnitConfObj0 = controllerObj.addProcUnit(datatype='Voltage',
36 inputId=readUnitConfObj.getId())
37
38 # opObj10 = procUnitConfObj0.addOperation(name='selectHeights')
39 # opObj10.addParameter(name='minHei', value='0', format='float')
40 # opObj10.addParameter(name='maxHei', value='8', format='float')
41
42 # opObj10 = procUnitConfObj0.addOperation(name='setH0')
43 # opObj10.addParameter(name='h0', value='5.4', format='float')
44
45 # opObj10 = procUnitConfObj0.addOperation(name='Decoder', optype='external')
46 # opObj10.addParameter(name='code', value='1,-1', format='intlist')
47 # opObj10.addParameter(name='nCode', value='2', format='float')
48 # opObj10.addParameter(name='nBaud', value='1', format='float')
49
50 opObj10 = procUnitConfObj0.addOperation(name='CohInt', optype='external')
51 opObj10.addParameter(name='n', value='1', format='float')
52
53 # opObj11 = procUnitConfObj0.addOperation(name='Scope', optype='external')
54 # opObj11.addParameter(name='id', value='121', format='int')
55 # opObj11.addParameter(name='wintitle', value='Scope', format='str')
56
57 procUnitConfObj1 = controllerObj.addProcUnit(datatype='Spectra',
58 inputId=procUnitConfObj0.getId())
59
60 #Creating a processing object with its parameters
61 #schainpy.model.proc.jroproc_spectra.SpectraProc.run()
62 #If you need to add more parameters can use the "addParameter method"
63 procUnitConfObj1.addParameter(name='nFFTPoints', value='8', format='int')
64 procUnitConfObj1.addParameter(name='pairsList', value='(0,1)', format='pairslist')
65
66 # opObj10 = procUnitConfObj1.addOperation(name='IncohInt', optype='external')
67 # opObj10.addParameter(name='n', value='2', format='float')
68 #
69 #Using internal methods
70 #schainpy.model.proc.jroproc_spectra.SpectraProc.selectChannels()
71 # opObj10 = procUnitConfObj1.addOperation(name='selectChannels')
72 # opObj10.addParameter(name='channelList', value='0,1', format='intlist')
73
74 #Using internal methods
75 #schainpy.model.proc.jroproc_spectra.SpectraProc.selectHeights()
76 # opObj10 = procUnitConfObj1.addOperation(name='selectHeights')
77 # opObj10.addParameter(name='minHei', value='90', format='float')
78 # opObj10.addParameter(name='maxHei', value='180', format='float')
79
80 #Using external methods (new modules)
81 # #schainpy.model.proc.jroproc_spectra.IncohInt.setup()
82 # opObj12 = procUnitConfObj1.addOperation(name='IncohInt', optype='other')
83 # opObj12.addParameter(name='n', value='1', format='int')
84
85 #Using external methods (new modules)
86 #schainpy.model.graphics.jroplot_spectra.SpectraPlot.setup()
87 opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='external')
88 opObj11.addParameter(name='id', value='11', format='int')
89 opObj11.addParameter(name='wintitle', value='SpectraPlot', format='str')
90 # opObj11.addParameter(name='zmin', value='0', format='int')
91 # opObj11.addParameter(name='zmax', value='90', format='int')
92 # opObj11.addParameter(name='save', value='1', format='int')
93 # opObj11.addParameter(name='xmin', value='-20', format='float')
94 # opObj11.addParameter(name='xmax', value='20', format='float')
95
96 #Using external methods (new modules)
97 #schainpy.model.graphics.jroplot_spectra.RTIPlot.setup()
98 opObj11 = procUnitConfObj1.addOperation(name='RTIPlot', optype='other')
99 opObj11.addParameter(name='id', value='30', format='int')
100 opObj11.addParameter(name='wintitle', value='RTI', format='str')
101 # opObj11.addParameter(name='zmin', value='0', format='int')
102 # opObj11.addParameter(name='zmax', value='90', format='int')
103 opObj11.addParameter(name='showprofile', value='1', format='int')
104 opObj11.addParameter(name='timerange', value=str(2*60*60), format='int')
105 # opObj11.addParameter(name='xmin', value='19.5', format='float')
106 # opObj11.addParameter(name='xmax', value='20', format='float')
107
108 opObj11 = procUnitConfObj1.addOperation(name='CrossSpectraPlot', optype='other')
109 opObj11.addParameter(name='id', value='3', format='int')
110 opObj11.addParameter(name='wintitle', value='CrossSpectraPlot', format='str')
111 # opObj11.addParameter(name='zmin', value='30', format='int')
112 # opObj11.addParameter(name='zmax', value='120', format='int')
113 # opObj11.addParameter(name='pairsList', value='(0,1)', format='pairslist')
114
115 controllerObj.start()
116
117 if __name__ == '__main__':
118 main()
Show file before | Show file after | Hide comments
@@ -0,0 +1,133
1 #!/usr/bin/env python
2 '''
3 Created on Jul 11, 2014
4
5 @author: roj-idl71
6 '''
7 import time
8 from gevent import sleep
9
10 import os, sys
11
12 path = os.path.dirname(os.getcwd())
13 path = os.path.join(path, 'source')
14 sys.path.insert(0, path)
15
16 import zerorpc
17 from schainpy.model import *
18 from schainpy.model.serializer.data import serial2Obj, serial2Dict
19 # import schainpy.model.io.jroIO_usrp
20
21 def createObjVolt():
22 '''
23 This function creates a processing object "VoltProc" with some operations.
24 such as: "CohInt", "Scope", etc
25 These class are found inside schainpy.model.proc and schainpy.model.graphics
26 '''
27 procObj = VoltageProc()
28
29 opObj = CohInt()
30 procObj.addOperation(opObj, 1)
31
32 opObj = Scope()
33 procObj.addOperation(opObj, 2)
34
35 return procObj
36
37 def createObjSpec():
38 '''
39 This function creates a processing object "SpecProc" with some operation objects
40 such as: "IncohInt", "SpectraPlot", "RTIPlot", etc
41 These class are found inside schainpy.model.proc and schainpy.model.graphics
42 '''
43
44 procObj = SpectraProc()
45
46 opObj = IncohInt()
47 procObj.addOperation(opObj, objId = 1)
48
49 opObj = SpectraPlot()
50 procObj.addOperation(opObj, objId = 2)
51
52 opObj = RTIPlot()
53 procObj.addOperation(opObj, objId = 3)
54
55 opObj = SpectraPlot()
56 procObj.addOperation(opObj, objId = 4)
57
58 opObj = RTIPlot()
59 procObj.addOperation(opObj, objId = 5)
60
61 return procObj
62
63 def processingSpec(procObj, dataInObj):
64
65 procObj.setInput(dataInObj)
66 procObj.run(nFFTPoints = 16)
67
68 procObj.call(opType = "external",
69 opId = 1,
70 n=1)
71
72 procObj.call(opType = "external",
73 opId = 2,
74 id=191,
75 # zmin=-100,
76 # zmax=-40
77 )
78
79 procObj.call(opType = "external",
80 opId = 3,
81 id=192,
82 # zmin=-100,
83 # zmax=-40,
84 timerange=10*60)
85
86 def printSpeed(deltaTime, mySerial):
87
88 ####################
89 size = len(mySerial)/1024.
90 vel = 1.0*size / deltaTime
91
92 print "Index [", replayerObj.getProfileIndex(), "]: ",
93 print "Total time %5.2f ms, Data size %5.2f KB, Speed %5.2f MB/s" %(deltaTime, size, vel)
94 ####################
95
96 if __name__ == '__main__':
97
98 procObj = createObjSpec()
99
100 replayerObj = zerorpc.Client()
101 replayerObj.connect("tcp://127.0.0.1:4242")
102
103 serializer = replayerObj.getSerializer()
104
105 ini = time.time()
106 mySerialMetadata = replayerObj.getSerialMetaData()
107 deltaTime = (time.time() - ini)*1024
108
109 printSpeed(deltaTime, mySerialMetadata)
110
111 myMetaDict = serial2Dict(mySerialMetadata,
112 serializer = serializer)
113 # print myMetaDict
114 while True:
115 ini = time.time()
116 mySerialData = replayerObj.getSerialData()
117 deltaTime = (time.time() - ini)*1024
118
119 if not mySerialData:
120 print "No more data"
121 break
122
123 # myDataDict = SERIALIZER.loads(mySerialData)
124 # print myDataDict
125 # continue
126
127 printSpeed(deltaTime, mySerialData)
128
129 dataInObj = serial2Obj(mySerialData,
130 metadataDict=myMetaDict,
131 serializer = serializer)
132 processingSpec(procObj, dataInObj)
133 sleep(1e-1) No newline at end of file
Show file before | Show file after | Hide comments
@@ -0,0 +1,43
1 #!/usr/bin/env python
2 '''
3 Created on Jul 11, 2014
4
5 @author: roj-idl71
6 '''
7 # import sys
8 import datetime
9 import zerorpc
10
11 import os, sys
12
13 path = os.path.dirname(os.getcwd())
14 path = os.path.join(path, 'source')
15 sys.path.insert(0, path)
16
17 # from gevent import sleep
18
19 from schainpy.model.io.jroIO_usrp_api import USRPReaderAPI
20 # from schainpy.serializer.DataTranslate import serial2Obj
21
22 if __name__ == '__main__':
23
24 replayerObj = USRPReaderAPI(serializer='msgpack')
25
26 replayerObj.setup(path='../data/haystack/',
27 startDate=datetime.date(2000,1,1),
28 endDate=datetime.date(2016,1,1),
29 startTime=datetime.time(0,0,0),
30 endTime=datetime.time(23,59,59),
31 online=0,
32 nSamples=50,
33 buffer_size = 8,
34 channelList = [0])
35
36 replayerObj.start()
37
38 print "\nInitializing 'zerorpc' server"
39 s = zerorpc.Server(replayerObj)
40 s.bind("tcp://0.0.0.0:4242")
41 s.run()
42
43 print "End" No newline at end of file
Show file before | Show file after | Hide comments
1 NO CONTENT: file was removed
NO CONTENT: file was removed
General Comments 0
You need to be logged in to leave comments. Login now