| @@ -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