| @@ -0,0 +1,11 | |||
|
|
1 | ## ROADMAP | |
|
|
2 | ## SCHAIN BRANCHES | |
|
|
3 | ||
|
|
4 | ### BRANCH - SCHAIN_MP | |
|
|
5 | ||
|
|
6 | * Revisar si funciona con varios publishers. | |
|
|
7 | * Revisar xRange y reinicialización de gráfico. | |
|
|
8 | * Grabar cada spectra independientemente. | |
|
|
9 | * Agregar kwargs al init | |
|
|
10 | * Agregar gráficos restantes | |
|
|
11 | * Presentación | |
| @@ -125,8 +125,8 class PlotData(Operation, Process): | |||
|
|
125 | 125 | self.__plot() |
|
|
126 | 126 | |
|
|
127 | 127 | if 'ENDED' in self.data: |
|
|
128 | #self.setup() | |
|
|
129 | #self.__plot() | |
|
|
128 | # self.setup() | |
|
|
129 | # self.__plot() | |
|
|
130 | 130 | pass |
|
|
131 | 131 | |
|
|
132 | 132 | except zmq.Again as e: |
| @@ -39,6 +39,8 class ProcessingUnit(object): | |||
|
|
39 | 39 | self.isConfig = False |
|
|
40 | 40 | |
|
|
41 | 41 | self.args = args |
|
|
42 | # if (kwargs): | |
|
|
43 | # self.kwargs = kwargs | |
|
|
42 | 44 | self.kwargs = kwargs |
|
|
43 | 45 | |
|
|
44 | 46 | def addOperation(self, opObj, objId): |
| @@ -363,7 +363,7 class ReceiverData(ProcessingUnit, Process): | |||
|
|
363 | 363 | if self.dataOut.finished is True: |
|
|
364 | 364 | self.send(self.data) |
|
|
365 | 365 | self.connections -= 1 |
|
|
366 | if self.connections==0 and self.started: | |
|
|
366 | if self.connections == 0 and self.started: | |
|
|
367 | 367 | self.ended = True |
|
|
368 | 368 | self.data['ENDED'] = True |
|
|
369 | 369 | self.send(self.data) |
| @@ -13,10 +13,10 def main(date): | |||
|
|
13 | 13 | |
|
|
14 | 14 | controllerObj = Project() |
|
|
15 | 15 | |
|
|
16 |
controllerObj.setup(id |
|
|
|
16 | controllerObj.setup(id='191', name='test01', description='') | |
|
|
17 | 17 | |
|
|
18 | 18 | readUnitConfObj = controllerObj.addReadUnit(datatype='Spectra', |
|
|
19 |
path='/ |
|
|
|
19 | path='/home/nanosat/data/zeus', | |
|
|
20 | 20 | startDate=date, |
|
|
21 | 21 | endDate=date, |
|
|
22 | 22 | startTime='00:00:00', |
| @@ -44,7 +44,7 def main(date): | |||
|
|
44 | 44 | # opObj11.addParameter(name='zmin', value='10', format='int') |
|
|
45 | 45 | # opObj11.addParameter(name='zmax', value='35', format='int') |
|
|
46 | 46 | |
|
|
47 | ||
|
|
47 | ||
|
|
48 | 48 | |
|
|
49 | 49 | |
|
|
50 | 50 | opObj11 = procUnitConfObj1.addOperation(name='PlotRTIData', optype='other') |
| @@ -66,12 +66,10 def main(date): | |||
|
|
66 | 66 | controllerObj.start() |
|
|
67 | 67 | |
|
|
68 | 68 | if __name__=='__main__': |
|
|
69 | ||
|
|
69 | ||
|
|
70 | 70 | dt = datetime(2017, 1, 12) |
|
|
71 | ||
|
|
72 |
dates = [(dt+timedelta(x)).strftime('%Y/%m/%d') |
|
|
|
73 | ||
|
|
71 | ||
|
|
72 | dates = [(dt+timedelta(x)).strftime('%Y/%m/%d') for x in range(20)] | |
|
|
73 | ||
|
|
74 | 74 | p = multiprocessing.Pool(4) |
|
|
75 | 75 | p.map(main, dates) |
|
|
76 | ||
|
|
77 | No newline at end of file | |
| @@ -12,7 +12,7 if __name__ == '__main__': | |||
|
|
12 | 12 | desc = "Segundo Test" |
|
|
13 | 13 | |
|
|
14 | 14 | controllerObj = Project() |
|
|
15 |
controllerObj.setup(id |
|
|
|
15 | controllerObj.setup(id='191', name='test01', description=desc) | |
|
|
16 | 16 | |
|
|
17 | 17 | proc1 = controllerObj.addProcUnit(name='ReceiverData') |
|
|
18 | 18 | # proc1.addParameter(name='server', value='tcp://10.10.10.87:3000', format='str') |
General Comments 0
You need to be logged in to leave comments.
Login now