jroproc_base.py
285 lines
| 7.8 KiB
| text/x-python
|
PythonLexer
Daniel Valdez
|
r487 | ''' | |
Miguel Valdez
|
r568 | ||
| $Author: murco $ | |||
| $Id: jroproc_base.py 1 2012-11-12 18:56:07Z murco $ | |||
|
Daniel Valdez
|
r487 | ''' | |
|
Miguel Valdez
|
r568 | class ProcessingUnit(object): | |
|
Daniel Valdez
|
r487 | ||
| """ | |||
| Esta es la clase base para el procesamiento de datos. | |||
| Contiene el metodo "call" para llamar operaciones. Las operaciones pueden ser: | |||
| - Metodos internos (callMethod) | |||
| - Objetos del tipo Operation (callObject). Antes de ser llamados, estos objetos | |||
| tienen que ser agreagados con el metodo "add". | |||
| """ | |||
| # objeto de datos de entrada (Voltage, Spectra o Correlation) | |||
| dataIn = None | |||
| dataInList = [] | |||
| # objeto de datos de entrada (Voltage, Spectra o Correlation) | |||
| dataOut = None | |||
| operations2RunDict = None | |||
| isConfig = False | |||
| def __init__(self): | |||
| self.dataIn = None | |||
| self.dataInList = [] | |||
|
Miguel Valdez
|
r573 | self.dataOut = None | |
|
Daniel Valdez
|
r487 | ||
| self.operations2RunDict = {} | |||
| self.isConfig = False | |||
| def addOperation(self, opObj, objId): | |||
| """ | |||
| Agrega un objeto del tipo "Operation" (opObj) a la lista de objetos "self.objectList" y retorna el | |||
| identificador asociado a este objeto. | |||
| Input: | |||
| object : objeto de la clase "Operation" | |||
| Return: | |||
| objId : identificador del objeto, necesario para ejecutar la operacion | |||
| """ | |||
| self.operations2RunDict[objId] = opObj | |||
| return objId | |||
|
Miguel Valdez
|
r577 | def getOperationObj(self, objId): | |
| if objId not in self.operations2RunDict.keys(): | |||
| return None | |||
| return self.operations2RunDict[objId] | |||
|
Daniel Valdez
|
r487 | def operation(self, **kwargs): | |
| """ | |||
| Operacion directa sobre la data (dataOut.data). Es necesario actualizar los valores de los | |||
| atributos del objeto dataOut | |||
| Input: | |||
| **kwargs : Diccionario de argumentos de la funcion a ejecutar | |||
| """ | |||
| raise ValueError, "ImplementedError" | |||
| def callMethod(self, name, **kwargs): | |||
| """ | |||
| Ejecuta el metodo con el nombre "name" y con argumentos **kwargs de la propia clase. | |||
| Input: | |||
| name : nombre del metodo a ejecutar | |||
| **kwargs : diccionario con los nombres y valores de la funcion a ejecutar. | |||
| """ | |||
|
Miguel Valdez
|
r568 | ||
| #Checking the inputs | |||
|
Daniel Valdez
|
r487 | if name == 'run': | |
| if not self.checkInputs(): | |||
| self.dataOut.flagNoData = True | |||
| return False | |||
| else: | |||
| #Si no es un metodo RUN la entrada es la misma dataOut (interna) | |||
| if self.dataOut.isEmpty(): | |||
| return False | |||
| #Getting the pointer to method | |||
| methodToCall = getattr(self, name) | |||
| #Executing the self method | |||
| methodToCall(**kwargs) | |||
| #Checkin the outputs | |||
| # if name == 'run': | |||
| # pass | |||
| # else: | |||
| # pass | |||
| # | |||
| # if name != 'run': | |||
| # return True | |||
|
Miguel Valdez
|
r573 | ||
|
Miguel Valdez
|
r611 | if self.dataOut is None: | |
|
Miguel Valdez
|
r573 | return False | |
|
Daniel Valdez
|
r487 | if self.dataOut.isEmpty(): | |
| return False | |||
| return True | |||
| def callObject(self, objId, **kwargs): | |||
| """ | |||
| Ejecuta la operacion asociada al identificador del objeto "objId" | |||
| Input: | |||
| objId : identificador del objeto a ejecutar | |||
| **kwargs : diccionario con los nombres y valores de la funcion a ejecutar. | |||
| Return: | |||
| None | |||
| """ | |||
| if self.dataOut.isEmpty(): | |||
| return False | |||
| externalProcObj = self.operations2RunDict[objId] | |||
| externalProcObj.run(self.dataOut, **kwargs) | |||
| return True | |||
| def call(self, opType, opName=None, opId=None, **kwargs): | |||
| """ | |||
|
Miguel Valdez
|
r568 | Return True si ejecuta la operacion interna nombrada "opName" o la operacion externa | |
| identificada con el id "opId"; con los argumentos "**kwargs". | |||
|
Daniel Valdez
|
r487 | ||
|
Miguel Valdez
|
r568 | False si la operacion no se ha ejecutado. | |
| Input: | |||
| opType : Puede ser "self" o "external" | |||
| La operacion puede ser de dos tipos (callMethod or callObject): | |||
|
Daniel Valdez
|
r487 | ||
|
Miguel Valdez
|
r568 | 1. Un metodo propio de esta clase: | |
| opType = "self" | |||
|
Daniel Valdez
|
r487 | ||
|
Miguel Valdez
|
r568 | 2. El metodo "run" de un objeto del tipo Operation o de un derivado de ella: | |
| opType = "other" or "external". | |||
|
Daniel Valdez
|
r487 | ||
|
Miguel Valdez
|
r568 | opName : Si la operacion es interna (opType = 'self'), entonces el "opName" sera | |
| usada para llamar a un metodo interno de la clase Processing | |||
| opId : Si la operacion es externa (opType = 'other'), entonces el "opId" sera | |||
| usada para llamar al metodo "run" de la clase Operation registrada con ese Id | |||
|
Daniel Valdez
|
r487 | ||
|
Miguel Valdez
|
r568 | Exception: | |
| Este objeto de tipo Operation debe de haber sido agregado antes con el metodo: | |||
| "addOperation" e identificado con el valor "opId" = el id de la operacion. | |||
| De lo contrario retornara un error del tipo IOError | |||
|
Daniel Valdez
|
r487 | ||
| """ | |||
| if opType == 'self': | |||
| if not opName: | |||
| raise IOError, "opName parameter should be defined" | |||
| sts = self.callMethod(opName, **kwargs) | |||
| if opType == 'other' or opType == 'external': | |||
| if not opId: | |||
| raise IOError, "opId parameter should be defined" | |||
| if opId not in self.operations2RunDict.keys(): | |||
| raise IOError, "This id operation have not been registered" | |||
| sts = self.callObject(opId, **kwargs) | |||
| return sts | |||
| def setInput(self, dataIn): | |||
| self.dataIn = dataIn | |||
| self.dataInList.append(dataIn) | |||
| def getOutputObj(self): | |||
| return self.dataOut | |||
| def checkInputs(self): | |||
| for thisDataIn in self.dataInList: | |||
| if thisDataIn.isEmpty(): | |||
| return False | |||
| return True | |||
| def setup(self): | |||
| raise ValueError, "Not implemented" | |||
| def run(self): | |||
| raise ValueError, "Not implemented" | |||
|
Miguel Valdez
|
r573 | ||
| def close(self): | |||
| #Close every thread, queue or any other object here is it is neccesary. | |||
| return | |||
|
Miguel Valdez
|
r568 | class Operation(object): | |
|
Daniel Valdez
|
r487 | ||
| """ | |||
| Clase base para definir las operaciones adicionales que se pueden agregar a la clase ProcessingUnit | |||
| y necesiten acumular informacion previa de los datos a procesar. De preferencia usar un buffer de | |||
| acumulacion dentro de esta clase | |||
| Ejemplo: Integraciones coherentes, necesita la informacion previa de los n perfiles anteriores (bufffer) | |||
| """ | |||
| __buffer = None | |||
| isConfig = False | |||
| def __init__(self): | |||
| self.__buffer = None | |||
| self.isConfig = False | |||
| def setup(self): | |||
| self.isConfig = True | |||
| raise ValueError, "Not implemented" | |||
| def run(self, dataIn, **kwargs): | |||
| """ | |||
|
Miguel Valdez
|
r568 | Realiza las operaciones necesarias sobre la dataIn.data y actualiza los | |
| atributos del objeto dataIn. | |||
|
Daniel Valdez
|
r487 | ||
| Input: | |||
| dataIn : objeto del tipo JROData | |||
| Return: | |||
| None | |||
| Affected: | |||
| __buffer : buffer de recepcion de datos. | |||
| """ | |||
| if not self.isConfig: | |||
| self.setup(**kwargs) | |||
|
Miguel Valdez
|
r577 | raise ValueError, "ImplementedError" | |
| def close(self): | |||
| pass |