| @@ -0,0 +1,77 | |||||
|
|
1 | #!/usr/bin/env python | |||
|
|
2 | ''' | |||
|
|
3 | Created on Jul 7, 2014 | |||
|
|
4 | ||||
|
|
5 | @author: roj-idl71 | |||
|
|
6 | ''' | |||
|
|
7 | import os, sys | |||
|
|
8 | from datetime import datetime, timedelta | |||
|
|
9 | import multiprocessing | |||
|
|
10 | from schainpy.controller import Project | |||
|
|
11 | ||||
|
|
12 | def main(date): | |||
|
|
13 | ||||
|
|
14 | controllerObj = Project() | |||
|
|
15 | ||||
|
|
16 | controllerObj.setup(id = '191', name='test01', description='') | |||
|
|
17 | ||||
|
|
18 | readUnitConfObj = controllerObj.addReadUnit(datatype='Spectra', | |||
|
|
19 | path='/data/workspace/data/zeus/', | |||
|
|
20 | startDate=date, | |||
|
|
21 | endDate=date, | |||
|
|
22 | startTime='00:00:00', | |||
|
|
23 | endTime='23:59:59', | |||
|
|
24 | online=0, | |||
|
|
25 | walk=1, | |||
|
|
26 | expLabel='') | |||
|
|
27 | ||||
|
|
28 | procUnitConfObj1 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId()) | |||
|
|
29 | #opObj11 = procUnitConfObj1.addOperation(name='removeDC') | |||
|
|
30 | #opObj11.addParameter(name='mode', value='1', format='int') | |||
|
|
31 | ||||
|
|
32 | #opObj11 = procUnitConfObj1.addOperation(name='removeInterference') | |||
|
|
33 | ||||
|
|
34 | ||||
|
|
35 | # opObj11 = procUnitConfObj1.addOperation(name='RTIPlot', optype='other') | |||
|
|
36 | # opObj11.addParameter(name='id', value='10', format='int') | |||
|
|
37 | # opObj11.addParameter(name='wintitle', value='150Km', format='str') | |||
|
|
38 | # opObj11.addParameter(name='colormap', value='jro', format='str') | |||
|
|
39 | # opObj11.addParameter(name='xaxis', value='time', format='str') | |||
|
|
40 | # opObj11.addParameter(name='xmin', value='0', format='int') | |||
|
|
41 | # opObj11.addParameter(name='xmax', value='23', format='int') | |||
|
|
42 | # #opObj11.addParameter(name='ymin', value='100', format='int') | |||
|
|
43 | # #opObj11.addParameter(name='ymax', value='150', format='int') | |||
|
|
44 | # opObj11.addParameter(name='zmin', value='10', format='int') | |||
|
|
45 | # opObj11.addParameter(name='zmax', value='35', format='int') | |||
|
|
46 | ||||
|
|
47 | ||||
|
|
48 | ||||
|
|
49 | ||||
|
|
50 | opObj11 = procUnitConfObj1.addOperation(name='PlotRTIData', optype='other') | |||
|
|
51 | opObj11.addParameter(name='id', value='12', format='int') | |||
|
|
52 | opObj11.addParameter(name='wintitle', value='150Km', format='str') | |||
|
|
53 | opObj11.addParameter(name='colormap', value='jro', format='str') | |||
|
|
54 | opObj11.addParameter(name='xaxis', value='time', format='str') | |||
|
|
55 | opObj11.addParameter(name='xmin', value='0', format='int') | |||
|
|
56 | opObj11.addParameter(name='xmax', value='23', format='int') | |||
|
|
57 | #opObj11.addParameter(name='ymin', value='100', format='int') | |||
|
|
58 | #opObj11.addParameter(name='ymax', value='150', format='int') | |||
|
|
59 | opObj11.addParameter(name='zmin', value='10', format='int') | |||
|
|
60 | opObj11.addParameter(name='zmax', value='35', format='int') | |||
|
|
61 | #opObj11.addParameter(name='pause', value='1', format='bool') | |||
|
|
62 | opObj11.addParameter(name='show', value='0', format='bool') | |||
|
|
63 | opObj11.addParameter(name='save', value='/tmp', format='str') | |||
|
|
64 | ||||
|
|
65 | ||||
|
|
66 | controllerObj.start() | |||
|
|
67 | ||||
|
|
68 | if __name__=='__main__': | |||
|
|
69 | ||||
|
|
70 | dt = datetime(2017, 1, 12) | |||
|
|
71 | ||||
|
|
72 | dates = [(dt+timedelta(x)).strftime('%Y/%m/%d') for x in range(20)] | |||
|
|
73 | ||||
|
|
74 | p = multiprocessing.Pool(4) | |||
|
|
75 | p.map(main, dates) | |||
|
|
76 | ||||
|
|
77 | No newline at end of file | |||
General Comments 0
You need to be logged in to leave comments.
Login now