jroprocessing.py
637 lines
| 18.9 KiB
| text/x-python
|
PythonLexer
Miguel Valdez
|
r174 | ''' | |
| $Author: dsuarez $ | |||
| $Id: Processor.py 1 2012-11-12 18:56:07Z dsuarez $ | |||
| ''' | |||
| import os | |||
| import numpy | |||
| import datetime | |||
| import time | |||
|
Miguel Valdez
|
r178 | from jrodata import * | |
| from jrodataIO import * | |||
| from jroplot import * | |||
|
Miguel Valdez
|
r174 | ||
| class ProcessingUnit: | |||
| """ | |||
| 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 | |||
| # objeto de datos de entrada (Voltage, Spectra o Correlation) | |||
| dataOut = None | |||
| objectDict = None | |||
| def __init__(self): | |||
| self.objectDict = {} | |||
|
Miguel Valdez
|
r197 | def init(self): | |
| raise ValueError, "Not implemented" | |||
|
Miguel Valdez
|
r174 | def addOperation(self, object, objId): | |
| """ | |||
| Agrega el objeto "object" 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 | |||
| """ | |||
Daniel Valdez
|
r179 | self.objectDict[objId] = object | |
|
Miguel Valdez
|
r174 | ||
| return objId | |||
| 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
|
r197 | if name != 'run': | |
| if name == 'init' and self.dataIn.isEmpty(): | |||
|
Miguel Valdez
|
r199 | self.dataOut.flagNoData = True | |
| return False | |||
|
Miguel Valdez
|
r197 | ||
| if name != 'init' and self.dataOut.isEmpty(): | |||
|
Miguel Valdez
|
r199 | return False | |
|
Miguel Valdez
|
r174 | ||
| methodToCall = getattr(self, name) | |||
| methodToCall(**kwargs) | |||
|
Miguel Valdez
|
r199 | if name != 'run': | |
| return True | |||
| if self.dataOut.isEmpty(): | |||
| return False | |||
| return True | |||
|
Miguel Valdez
|
r174 | 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 | |||
| """ | |||
|
Miguel Valdez
|
r197 | if self.dataOut.isEmpty(): | |
|
Miguel Valdez
|
r199 | return False | |
|
Miguel Valdez
|
r197 | ||
|
Daniel Valdez
|
r189 | object = self.objectDict[objId] | |
|
Miguel Valdez
|
r174 | ||
| object.run(self.dataOut, **kwargs) | |||
|
Miguel Valdez
|
r199 | ||
| return True | |||
|
Miguel Valdez
|
r174 | ||
|
Miguel Valdez
|
r188 | def call(self, operationConf, **kwargs): | |
|
Miguel Valdez
|
r174 | ||
| """ | |||
|
Miguel Valdez
|
r199 | Return True si ejecuta la operacion "operationConf.name" con los | |
| argumentos "**kwargs". False si la operacion no se ha ejecutado. | |||
| La operacion puede ser de dos tipos: | |||
|
Miguel Valdez
|
r174 | ||
| 1. Un metodo propio de esta clase: | |||
| operation.type = "self" | |||
| 2. El metodo "run" de un objeto del tipo Operation o de un derivado de ella: | |||
| operation.type = "other". | |||
| Este objeto de tipo Operation debe de haber sido agregado antes con el metodo: | |||
| "addOperation" e identificado con el operation.id | |||
| con el id de la operacion. | |||
|
Miguel Valdez
|
r188 | ||
| Input: | |||
| Operation : Objeto del tipo operacion con los atributos: name, type y id. | |||
|
Miguel Valdez
|
r174 | """ | |
|
Miguel Valdez
|
r188 | if operationConf.type == 'self': | |
|
Miguel Valdez
|
r199 | sts = self.callMethod(operationConf.name, **kwargs) | |
|
Miguel Valdez
|
r174 | ||
|
Miguel Valdez
|
r188 | if operationConf.type == 'other': | |
|
Miguel Valdez
|
r199 | sts = self.callObject(operationConf.id, **kwargs) | |
| return sts | |||
|
Miguel Valdez
|
r191 | ||
| def setInput(self, dataIn): | |||
| self.dataIn = dataIn | |||
| def getOutput(self): | |||
| return self.dataOut | |||
|
Miguel Valdez
|
r174 | ||
| class Operation(): | |||
| """ | |||
| Clase base para definir las operaciones adicionales que se pueden agregar a la clase ProcessingUnit | |||
|
Daniel Valdez
|
r179 | y necesiten acumular informacion previa de los datos a procesar. De preferencia usar un buffer de | |
|
Miguel Valdez
|
r174 | acumulacion dentro de esta clase | |
|
Daniel Valdez
|
r179 | Ejemplo: Integraciones coherentes, necesita la informacion previa de los n perfiles anteriores (bufffer) | |
|
Miguel Valdez
|
r174 | ||
| """ | |||
| __buffer = None | |||
|
Miguel Valdez
|
r175 | __isConfig = False | |
|
Miguel Valdez
|
r174 | ||
| def __init__(self): | |||
| pass | |||
| def run(self, dataIn, **kwargs): | |||
| """ | |||
| 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. | |||
| """ | |||
| raise ValueError, "ImplementedError" | |||
| class VoltageProc(ProcessingUnit): | |||
| def __init__(self): | |||
|
Miguel Valdez
|
r188 | ||
|
Daniel Valdez
|
r179 | self.objectDict = {} | |
|
Miguel Valdez
|
r188 | self.dataOut = Voltage() | |
|
Miguel Valdez
|
r174 | ||
| def init(self): | |||
|
Daniel Valdez
|
r179 | self.dataOut.copy(self.dataIn) | |
| # No necesita copiar en cada init() los atributos de dataIn | |||
|
Miguel Valdez
|
r174 | # la copia deberia hacerse por cada nuevo bloque de datos | |
| def selectChannels(self, channelList): | |||
| self.selectChannelsByIndex(channelList) | |||
| def selectChannelsByIndex(self, channelIndexList): | |||
| """ | |||
| Selecciona un bloque de datos en base a canales segun el channelIndexList | |||
| Input: | |||
| channelIndexList : lista sencilla de canales a seleccionar por ej. [2,3,7] | |||
| Affected: | |||
|
Daniel Valdez
|
r179 | self.dataOut.data | |
| self.dataOut.channelIndexList | |||
| self.dataOut.nChannels | |||
| self.dataOut.m_ProcessingHeader.totalSpectra | |||
| self.dataOut.systemHeaderObj.numChannels | |||
| self.dataOut.m_ProcessingHeader.blockSize | |||
|
Miguel Valdez
|
r174 | ||
| Return: | |||
| None | |||
| """ | |||
| for channel in channelIndexList: | |||
|
Daniel Valdez
|
r179 | if channel not in self.dataOut.channelIndexList: | |
|
Miguel Valdez
|
r197 | print channelIndexList | |
|
Miguel Valdez
|
r174 | raise ValueError, "The value %d in channelIndexList is not valid" %channel | |
| nChannels = len(channelIndexList) | |||
|
Daniel Valdez
|
r179 | data = self.dataOut.data[channelIndexList,:] | |
|
Miguel Valdez
|
r174 | ||
|
Daniel Valdez
|
r179 | self.dataOut.data = data | |
| self.dataOut.channelIndexList = channelIndexList | |||
| self.dataOut.channelList = [self.dataOut.channelList[i] for i in channelIndexList] | |||
| self.dataOut.nChannels = nChannels | |||
|
Miguel Valdez
|
r174 | ||
| return 1 | |||
| class CohInt(Operation): | |||
| __profIndex = 0 | |||
| __withOverapping = False | |||
| __byTime = False | |||
| __initime = None | |||
|
Miguel Valdez
|
r175 | __lastdatatime = None | |
|
Miguel Valdez
|
r174 | __integrationtime = None | |
| __buffer = None | |||
| __dataReady = False | |||
| nCohInt = None | |||
| def __init__(self): | |||
|
Miguel Valdez
|
r175 | self.__isConfig = False | |
|
Miguel Valdez
|
r174 | ||
| def setup(self, nCohInt=None, timeInterval=None, overlapping=False): | |||
| """ | |||
| Set the parameters of the integration class. | |||
| Inputs: | |||
| nCohInt : Number of coherent integrations | |||
| timeInterval : Time of integration. If the parameter "nCohInt" is selected this one does not work | |||
| overlapping : | |||
| """ | |||
| self.__initime = None | |||
|
Miguel Valdez
|
r175 | self.__lastdatatime = 0 | |
|
Miguel Valdez
|
r174 | self.__buffer = None | |
| self.__dataReady = False | |||
| if nCohInt == None and timeInterval == None: | |||
| raise ValueError, "nCohInt or timeInterval should be specified ..." | |||
| if nCohInt != None: | |||
| self.nCohInt = nCohInt | |||
| self.__byTime = False | |||
| else: | |||
| self.__integrationtime = timeInterval * 60. #if (type(timeInterval)!=integer) -> change this line | |||
| self.nCohInt = 9999 | |||
| self.__byTime = True | |||
| if overlapping: | |||
| self.__withOverapping = True | |||
| self.__buffer = None | |||
| else: | |||
| self.__withOverapping = False | |||
| self.__buffer = 0 | |||
| self.__profIndex = 0 | |||
| def putData(self, data): | |||
| """ | |||
| Add a profile to the __buffer and increase in one the __profileIndex | |||
| """ | |||
| if not self.__withOverapping: | |||
| self.__buffer += data | |||
| self.__profIndex += 1 | |||
| return | |||
| #Overlapping data | |||
| nChannels, nHeis = data.shape | |||
| data = numpy.reshape(data, (1, nChannels, nHeis)) | |||
| #If the buffer is empty then it takes the data value | |||
| if self.__buffer == None: | |||
| self.__buffer = data | |||
| self.__profIndex += 1 | |||
| return | |||
| #If the buffer length is lower than nCohInt then stakcing the data value | |||
| if self.__profIndex < self.nCohInt: | |||
| self.__buffer = numpy.vstack((self.__buffer, data)) | |||
| self.__profIndex += 1 | |||
| return | |||
| #If the buffer length is equal to nCohInt then replacing the last buffer value with the data value | |||
| self.__buffer = numpy.roll(self.__buffer, -1, axis=0) | |||
| self.__buffer[self.nCohInt-1] = data | |||
| self.__profIndex = self.nCohInt | |||
| return | |||
| def pushData(self): | |||
| """ | |||
| Return the sum of the last profiles and the profiles used in the sum. | |||
| Affected: | |||
| self.__profileIndex | |||
| """ | |||
| if not self.__withOverapping: | |||
| data = self.__buffer | |||
| nCohInt = self.__profIndex | |||
| self.__buffer = 0 | |||
| self.__profIndex = 0 | |||
| return data, nCohInt | |||
| #Integration with Overlapping | |||
| data = numpy.sum(self.__buffer, axis=0) | |||
| nCohInt = self.__profIndex | |||
| return data, nCohInt | |||
| def byProfiles(self, data): | |||
| self.__dataReady = False | |||
|
Daniel Valdez
|
r189 | avgdata = None | |
|
Miguel Valdez
|
r175 | nCohInt = None | |
|
Miguel Valdez
|
r174 | ||
| self.putData(data) | |||
| if self.__profIndex == self.nCohInt: | |||
| avgdata, nCohInt = self.pushData() | |||
| self.__dataReady = True | |||
|
Daniel Valdez
|
r189 | return avgdata | |
|
Miguel Valdez
|
r174 | ||
| def byTime(self, data, datatime): | |||
| self.__dataReady = False | |||
|
Daniel Valdez
|
r189 | avgdata = None | |
|
Miguel Valdez
|
r175 | nCohInt = None | |
|
Miguel Valdez
|
r174 | self.putData(data) | |
| if (datatime - self.__initime) >= self.__integrationtime: | |||
| avgdata, nCohInt = self.pushData() | |||
| self.nCohInt = nCohInt | |||
| self.__dataReady = True | |||
|
Daniel Valdez
|
r189 | return avgdata | |
|
Miguel Valdez
|
r174 | ||
| def integrate(self, data, datatime=None): | |||
|
Miguel Valdez
|
r175 | if self.__initime == None: | |
| self.__initime = datatime | |||
| if self.__byTime: | |||
| avgdata = self.byTime(data, datatime) | |||
|
Miguel Valdez
|
r174 | else: | |
|
Miguel Valdez
|
r175 | avgdata = self.byProfiles(data) | |
|
Miguel Valdez
|
r174 | ||
|
Miguel Valdez
|
r175 | self.__lastdatatime = datatime | |
| if avgdata == None: | |||
|
Daniel Valdez
|
r189 | return None, None | |
|
Miguel Valdez
|
r175 | ||
| avgdatatime = self.__initime | |||
| deltatime = datatime -self.__lastdatatime | |||
| if not self.__withOverapping: | |||
| self.__initime = datatime | |||
| else: | |||
| self.__initime += deltatime | |||
|
Daniel Valdez
|
r179 | return avgdata, avgdatatime | |
|
Miguel Valdez
|
r174 | ||
| def run(self, dataOut, nCohInt=None, timeInterval=None, overlapping=False): | |||
|
Miguel Valdez
|
r175 | if not self.__isConfig: | |
| self.setup(nCohInt, timeInterval, overlapping) | |||
| self.__isConfig = True | |||
| avgdata, avgdatatime = self.integrate(dataOut.data, dataOut.utctime) | |||
|
Miguel Valdez
|
r174 | ||
|
Daniel Valdez
|
r189 | # dataOut.timeInterval *= nCohInt | |
| dataOut.flagNoData = True | |||
|
Miguel Valdez
|
r174 | ||
|
Miguel Valdez
|
r175 | if self.__dataReady: | |
|
Daniel Valdez
|
r179 | dataOut.data = avgdata | |
| dataOut.timeInterval *= self.nCohInt | |||
| dataOut.nCohInt *= self.nCohInt | |||
| dataOut.utctime = avgdatatime | |||
|
Daniel Valdez
|
r192 | dataOut.flagNoData = False | |
| class SpectraProc(ProcessingUnit): | |||
| def __init__(self): | |||
|
Miguel Valdez
|
r199 | ||
|
Daniel Valdez
|
r192 | self.objectDict = {} | |
| self.buffer = None | |||
| self.firstdatatime = None | |||
| self.profIndex = 0 | |||
| self.dataOut = Spectra() | |||
| def __updateObjFromInput(self): | |||
| self.dataOut.radarControllerHeaderObj = self.dataIn.radarControllerHeaderObj.copy() | |||
| self.dataOut.systemHeaderObj = self.dataIn.systemHeaderObj.copy() | |||
| self.dataOut.channelList = self.dataIn.channelList | |||
| self.dataOut.heightList = self.dataIn.heightList | |||
| self.dataOut.dtype = self.dataIn.dtype | |||
| self.dataOut.nHeights = self.dataIn.nHeights | |||
| self.dataOut.nChannels = self.dataIn.nChannels | |||
| self.dataOut.nBaud = self.dataIn.nBaud | |||
| self.dataOut.nCode = self.dataIn.nCode | |||
| self.dataOut.code = self.dataIn.code | |||
| self.dataOut.nProfiles = self.dataOut.nFFTPoints | |||
| self.dataOut.channelIndexList = self.dataIn.channelIndexList | |||
| self.dataOut.flagTimeBlock = self.dataIn.flagTimeBlock | |||
| self.dataOut.utctime = self.firstdatatime | |||
| self.dataOut.flagDecodeData = self.dataIn.flagDecodeData #asumo q la data esta decodificada | |||
| self.dataOut.flagDeflipData = self.dataIn.flagDeflipData #asumo q la data esta sin flip | |||
| self.dataOut.flagShiftFFT = self.dataIn.flagShiftFFT | |||
| self.dataOut.nCohInt = self.dataIn.nCohInt | |||
| self.dataOut.nIncohInt = 1 | |||
| self.dataOut.ippSeconds = self.dataIn.ippSeconds | |||
| self.dataOut.timeInterval = self.dataIn.timeInterval*self.dataOut.nFFTPoints | |||
|
Miguel Valdez
|
r199 | ||
|
Daniel Valdez
|
r192 | def __getFft(self): | |
| """ | |||
| Convierte valores de Voltaje a Spectra | |||
| Affected: | |||
| self.dataOut.data_spc | |||
| self.dataOut.data_cspc | |||
| self.dataOut.data_dc | |||
| self.dataOut.heightList | |||
| self.dataOut.m_BasicHeader | |||
| self.dataOut.m_ProcessingHeader | |||
| self.dataOut.radarControllerHeaderObj | |||
| self.dataOut.systemHeaderObj | |||
| self.profIndex | |||
| self.buffer | |||
| self.dataOut.flagNoData | |||
| self.dataOut.dtype | |||
| self.dataOut.nPairs | |||
| self.dataOut.nChannels | |||
| self.dataOut.nProfiles | |||
| self.dataOut.systemHeaderObj.numChannels | |||
| self.dataOut.m_ProcessingHeader.totalSpectra | |||
| self.dataOut.m_ProcessingHeader.profilesPerBlock | |||
| self.dataOut.m_ProcessingHeader.numHeights | |||
| self.dataOut.m_ProcessingHeader.spectraComb | |||
| self.dataOut.m_ProcessingHeader.shif_fft | |||
| """ | |||
| fft_volt = numpy.fft.fft(self.buffer,axis=1) | |||
| dc = fft_volt[:,0,:] | |||
| #calculo de self-spectra | |||
| fft_volt = numpy.fft.fftshift(fft_volt,axes=(1,)) | |||
| spc = fft_volt * numpy.conjugate(fft_volt) | |||
| spc = spc.real | |||
| blocksize = 0 | |||
| blocksize += dc.size | |||
| blocksize += spc.size | |||
| cspc = None | |||
| pairIndex = 0 | |||
| if self.dataOut.pairsList != None: | |||
| #calculo de cross-spectra | |||
| cspc = numpy.zeros((self.dataOut.nPairs, self.dataOut.nFFTPoints, self.dataOut.nHeights), dtype='complex') | |||
| for pair in self.dataOut.pairsList: | |||
| cspc[pairIndex,:,:] = numpy.abs(fft_volt[pair[0],:,:] * numpy.conjugate(fft_volt[pair[1],:,:])) | |||
| pairIndex += 1 | |||
| blocksize += cspc.size | |||
| self.dataOut.data_spc = spc | |||
| self.dataOut.data_cspc = cspc | |||
| self.dataOut.data_dc = dc | |||
| self.dataOut.blockSize = blocksize | |||
|
Miguel Valdez
|
r199 | ||
| def init(self, nFFTPoints=None, pairsList=None): | |||
| if self.dataIn.type == "Spectra": | |||
| self.dataOut.copy(self.dataIn) | |||
| return | |||
| if self.dataIn.type == "Voltage": | |||
| if nFFTPoints == None: | |||
| raise ValueError, "This SpectraProc.setup() need nFFTPoints input variable" | |||
| if pairsList == None: | |||
| nPairs = 0 | |||
| else: | |||
| nPairs = len(pairsList) | |||
| self.dataOut.nFFTPoints = nFFTPoints | |||
| self.dataOut.pairsList = pairsList | |||
| self.dataOut.nPairs = nPairs | |||
| if self.buffer == None: | |||
| self.buffer = numpy.zeros((self.dataIn.nChannels, | |||
| self.dataOut.nFFTPoints, | |||
| self.dataIn.nHeights), | |||
| dtype='complex') | |||
| self.buffer[:,self.profIndex,:] = self.dataIn.data | |||
| self.profIndex += 1 | |||
| if self.firstdatatime == None: | |||
| self.firstdatatime = self.dataIn.utctime | |||
| if self.profIndex == self.dataOut.nFFTPoints: | |||
| self.__updateObjFromInput() | |||
| self.__getFft() | |||
| self.dataOut.flagNoData = False | |||
| self.buffer = None | |||
| self.firstdatatime = None | |||
| self.profIndex = 0 | |||
| return | |||
| raise ValuError, "The type object %s is not valid"%(self.dataIn.type) | |||
| def selectChannels(self, channelList): | |||
| self.selectChannelsByIndex(channelList) | |||
| def selectChannelsByIndex(self, channelIndexList): | |||
| """ | |||
| Selecciona un bloque de datos en base a canales segun el channelIndexList | |||
| Input: | |||
| channelIndexList : lista sencilla de canales a seleccionar por ej. [2,3,7] | |||
| Affected: | |||
| self.dataOut.data | |||
| self.dataOut.channelIndexList | |||
| self.dataOut.nChannels | |||
| self.dataOut.m_ProcessingHeader.totalSpectra | |||
| self.dataOut.systemHeaderObj.numChannels | |||
| self.dataOut.m_ProcessingHeader.blockSize | |||
| Return: | |||
| None | |||
| """ | |||
| for channel in channelIndexList: | |||
| if channel not in self.dataOut.channelIndexList: | |||
| print channelIndexList | |||
| raise ValueError, "The value %d in channelIndexList is not valid" %channel | |||
| nChannels = len(channelIndexList) | |||
| data = self.dataOut.data_spc[channelIndexList,:] | |||
| self.dataOut.data_spc = data | |||
| self.dataOut.channelIndexList = channelIndexList | |||
| self.dataOut.channelList = [self.dataOut.channelList[i] for i in channelIndexList] | |||
| self.dataOut.nChannels = nChannels | |||
| return 1 | |||
|
Daniel Valdez
|
r192 | ||
| class IncohInt(Operation): | |||
| def __init__(self): | |||
| pass |