Xc@s6dZdefdYZdefdYZdS(sG $Author: murco $ $Id: jroproc_base.py 1 2012-11-12 18:56:07Z murco $ tProcessingUnitcBseZdZdZgZdZdZeZ dZ dZ dZ dZ dZdZdddZdZd Zd Zd Zd Zd ZRS(sU 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". cCs1d|_g|_d|_i|_t|_dS(N(tNonetdataInt dataInListtdataOuttoperations2RunDicttFalsetisConfig(tself((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pyt__init__s     cCs||j|<|S(s} 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 (R(RtopObjtobjId((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pyt addOperation)s cCs$||jjkrdS|j|S(N(RtkeysR(RR ((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pytgetOperationObj<scKs tdS(s 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 N(tNotImplementedError(Rtkwargs((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pyt operationCs cKs|dkr+|js>t|j_tSn|jjr>tSt||}|||jdkrjtS|jjr}tStS(s, 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. trunN(t checkInputstTrueRt flagNoDataRtisEmptytgetattrR(RtnameRt methodToCall((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pyt callMethodPs    cKs7|jjrtS|j|}|j|j|tS(s_ 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 (RRRRRR(RR RtexternalProcObj((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pyt callObjects  cKs|dkr3|stdn|j||}n|dksW|dksW|dkr|sitdn||jjkrtdt|n|j||}n td||S( s Return True si ejecuta la operacion interna nombrada "opName" o la operacion externa identificada con el id "opId"; con los argumentos "**kwargs". False si la operacion no se ha ejecutado. Input: opType : Puede ser "self" o "external" Depende del tipo de operacion para llamar a:callMethod or callObject: 1. If opType = "self": Llama a un metodo propio de esta clase: name_method = getattr(self, name) name_method(**kwargs) 2. If opType = "other" o"external": Llama al metodo "run()" de una instancia de la clase "Operation" o de un derivado de ella: instanceName = self.operationList[opId] instanceName.run(**kwargs) 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' o 'external), entonces el "opId" sera usada para llamar al metodo "run" de la clase Operation registrada anteriormente con ese Id 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 ValueError Rs"opName parameter should be definedtothertexternaltplotters opId parameter should be defineds'Any operation with id=%s has been addeds>opType should be 'self', 'external' or 'plotter'; and not '%s'(t ValueErrorRRR tstrR(RtopTypetopNametopIdRtsts((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pytcalls(  $  cCs||_|jj|dS(N(RRtappend(RR((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pytsetInputs cCs|jS(N(R(R((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pyt getOutputObjscCs(x!|jD]}|jr tSq WtS(N(RRRR(Rt thisDataIn((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pyRs cCs tdS(N(R(R((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pytsetupscCs tdS(N(R(R((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pyRscCsdS(N((R((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pytclosesN(t__name__t __module__t__doc__RRRRRRRR R RRRRR&R(R)RR+RR,(((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pyRs&    / >    t OperationcBs>eZdZdZeZdZdZdZ dZ RS(so 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) cCsd|_t|_dS(N(Rt_Operation__bufferRR(R((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pyR s cCst|_tdS(N(RRR(R((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pyR+s cKs#|js|j|ntdS(sl Realiza las operaciones necesarias sobre la dataIn.data y actualiza los atributos del objeto dataIn. Input: dataIn : objeto del tipo JROData Return: None Affected: __buffer : buffer de recepcion de datos. N(RR+R(RRR((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pyR s cCsdS(N((R((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pyR,$sN( R-R.R/RR1RRR R+RR,(((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pyR0s    N(R/tobjectRR0(((sK/home/erick/workspace/schain_ebocanegra/schainpy/model/proc/jroproc_base.pyts