schain Commit - r1432:444e27e2e24f · Jicamarca Repository

LAST FIX PATH DATA

avaldezp -

r1432:444e27e2e24f

parent child

Context file:

r1432:444e27e2e24f

Collapse all files

schainpy/controller.py +41 -40

                 def getId(self):
                     return self.id
                 def getNewId(self):
                     return int(self.id) * 10 + len(self.operations) + 1
                     for key, value in self.parameters.items():
                         if value not in (None, '', ' '):
                             params[key] = value
                     return params
                 def update(self, **kwargs):
                 def addParameter(self, name, value, format=None):
                     '''
                     '''
+                    if os.path.isdir(value):
-                    if isinstance(value, str) and re.search(r'(\d+/\d+/\d+)', value):
+                        self.parameters[name] = value
+                    elif isinstance(value, str) and re.search(r'(\d+/\d+/\d+)', value):
                         self.parameters[name] = datetime.date(*[int(x) for x in value.split('/')])
                     elif isinstance(value, str) and re.search(r'(\d+:\d+:\d+)', value):
                         self.parameters[name] = datetime.time(*[int(x) for x in value.split(':')])
                             params[key] = str(value)
                     return params
                 def makeXml(self, element):
                     xml = SubElement(element, self.ELEMENTNAME)
                     for label in self.xml_labels:
                         xml.set(label, str(getattr(self, label)))
                     for key, value in self.getParameters().items():
                         xml_param = SubElement(xml, 'Parameter')
                         xml_param.set('name', key)
                         xml_param.set('value', value)
                     for conf in self.operations:
                         conf.makeXml(xml)
                 def __str__(self):
                     if self.ELEMENTNAME == 'Operation':
                             s += '    {}: {}\n'.format(key, value)
                         else:
                             s += '  {}: {}\n'.format(key, value)
                     for conf in self.operations:
                         s += str(conf)
                 def setup(self, project_id, id, name, datatype, inputId, err_queue):
                     '''
                     '''
                     if datatype == None and name == None:
                         raise ValueError('datatype or name should be defined')
                     i = [1 if x.id==id else 0 for x in self.operations]
                     self.operations.pop(i.index(1))
                 def getOperation(self, id):
                     for conf in self.operations:
                     self.err_queue = err_queue
                     self.operations = []
                     self.parameters = {}
                     for elm in element:
                         if elm.tag == 'Parameter':
                             self.addParameter(elm.get('name'), elm.get('value'))
                     log.success('creating process...', self.name)
                     for conf in self.operations:
                         opObj = conf.createObject()
                         log.success('adding operation: {}, type:{}'.format(
                             conf.name,
                             conf.type), self.name)
                         procUnitObj.addOperation(conf, opObj)
                     self.object = procUnitObj
                 def run(self):
                     '''
                     '''
                     return self.object.call(**self.getKwargs())
                     self.inputId = None
                     self.operations = []
                     self.parameters = {}
                 def setup(self, project_id, id, name, datatype, err_queue, path='', startDate='', endDate='',
                           startTime='', endTime='', server=None, **kwargs):
                     if datatype == None and name == None:
                         raise ValueError('datatype or name should be defined')
                     if name == None:
                     self.project_id = project_id
                     self.name = name
                     self.datatype = datatype
                     self.err_queue = err_queue
                     self.addParameter(name='path', value=path)
                     self.addParameter(name='startDate', value=startDate)
                     self.addParameter(name='endDate', value=endDate)
                 def setup(self, id=1, name='', description='', email=None, alarm=[]):
                     self.id = str(id)
                     self.description = description
                     self.email = email
                     self.alarm = alarm
                     if name:
                     conf = ReadUnitConf()
                     conf.setup(self.id, idReadUnit, name, datatype, self.err_queue, **kwargs)
                     self.configurations[conf.id] = conf
                     return conf
                 def addProcUnit(self, id=None, inputId='0', datatype=None, name=None):
                         idProcUnit = self.getNewId()
                     else:
                         idProcUnit = id
                     conf = ProcUnitConf()
                     conf.setup(self.id, idProcUnit, name, datatype, inputId, self.err_queue)
                     self.configurations[conf.id] = conf
                 def updateUnit(self, id, **kwargs):
                     conf = self.configurations[id].update(**kwargs)
                 def makeXml(self):
                     xml = Element('Project')
                             self.configurations[conf.id] = conf
                     self.filename = abs_file
                     return 1
                 def __str__(self):
                     t = Thread(target=self._monitor, args=(self.err_queue, self.ctx))
                     t.start()
                 def _monitor(self, queue, ctx):
                     import socket
                     procs = 0
                     err_msg = ''
                     while True:
                         msg = queue.get()
                         if '#_start_#' in msg:
                             procs -=1
                         else:
                             err_msg = msg
                         if procs == 0 or 'Traceback' in err_msg:
                             break
                         time.sleep(0.1)
                     if '|' in err_msg:
                         name, err = err_msg.split('|')
                         if 'SchainWarning' in err:
                             log.error(err.split('SchainError:')[-1].split('\n')[0].strip(), name)
                         else:
                             log.error(err, name)
                     else:
                         name, err = self.name, err_msg
                     time.sleep(1)
                     ctx.term()
                     message = ''.join(err)
                             subtitle += '[End time = %s]\n' % readUnitConfObj.parameters['endTime']
                         a = Alarm(
                             modes=self.alarm,
                             email=self.email,
                             message=message,
                             subject=subject,
                     err = False
                     n = len(self.configurations)
                     while not err:
                         for conf in self.getUnits():
                             ok = conf.run()
                             if ok == 'Error':
                                 n -= 1
                                 continue
                                 break
                         if n == 0:
                             err = True
                 def run(self):
                     log.success('\nStarting Project {} [id={}]'.format(self.name, self.id), tag='')
                     self.started = True
                     self.start_time = time.time()
                     self.createObjects()
                     self.runProcs()
                     log.success('{} Done (Time: {:4.2f}s)'.format(

schainpy/scripts/wr_marzo_v1_001.py +25 -16

             #path   = "/DATA_RM/DRONE01ABRIL1429"
             #path_ped = "/DATA_RM/TEST_PEDESTAL/P20220322-171722"
             #path = "/DATA_RM/DRONE01ABRIL1701"
-            path = "/DATA_RM/DATA/Torre_con_bola_1649092242/rawdata"
+            ##path = "/DATA_RM/DATA/Torre_con_bola_1649092242/rawdata"
-            path="/DATA_RM/DRONE01ABRIL1727"
+            ##path="/DATA_RM/DRONE01ABRIL1727"
+            path ="/DATA_RM/DATA/TEST@2022-04-11T17:29:56/rawdata"
+            #path="/DATA_RM/TEST172956_0411"
+            #path = "/DATA_RM/DATA/TEST@2022-04-11T17:29:56/rawdata"
             #path_ped = "/DATA_RM/DRONE01ABRIL1450"
-            path_ped="/DATA_RM/TEST_PEDESTAL/P20220401-172744"
+            #path_ped="/DATA_RM/TEST_PEDESTAL/P20220401-172744"
+            path_ped="/DATA_RM/TEST_PEDESTAL/P20220411-173017"
             #path_ped = "/DATA_RM/DATA/Torre_con_bola_1649092242/position/2022-04-04T17-00-00"
             #-------------------------------------------------------------------------------
-            figpath_pp     = "/home/soporte/Pictures/Torre_con_bola_1649092242"
+            figpath_pp     = "/home/soporte/Pictures/TEST"
             #figpath_pp     = "/home/soporte/Pictures/MARTES_22_PP_1M_1us"
             figpath_spec   = "/home/soporte/Pictures/MARTES_22_1M_1us"
-            figpath_pp_ppi = "/home/soporte/Pictures/MARTES_22_1M_1us_PPI"
+            figpath_pp_ppi = "/home/soporte/Pictures/PPILUNES11042022"
             figpath_pp_rhi  = "/DATA_RM/LUNES04ABRIL_1200_RHI"
             #--------------------------OPCIONES---------------------------------------------
-            plot_ppi    = 0
+            plot_ppi    = 1
-            plot        = 0
+            plot        = 0#0
-            plot_rhi    = 1
+            plot_rhi    = 0#1
-            integration = 1
+            integration = 1#1
             save        = 0
             plot_spec   = 0
             #---------------------------SAVE HDF5 PROCESADO/--------------------------------
             ################# RANGO DE PLOTEO######################################
             dBmin = '20'
             dBmax = '60'
-            xmin  = '12.0' #17.1,17.5
+            xmin  = '17.4' #17.1,17.5
-            xmax  = '12.4' #17.2,17.8
+            xmax  = '17.7' #17.2,17.8
             ymin  = '0'    #### PONER A 0
-            ymax  = '1.0'    #### PONER A 8
+            ymax  = '1.5'    #### PONER A 8
             ########################FECHA##########################################
             str1 = datetime.date.today()
             today = str1.strftime("%Y/%m/%d")
             #------------------------ UNIDAD DE LECTURA-------------------------------------
             readUnitConfObj = controllerObj.addReadUnit(datatype='DigitalRFReader',
                                                         path=path,
-                                                        startDate="2022/04/01",#today,
+                                                        startDate="2022/04/11",#today,
-                                                        endDate="2022/04/01",#today,
+                                                        endDate="2022/04/11",#today,
-                                                        startTime='00:10:05',#'17:39:25',
+                                                        startTime='17:36:00',#'17:39:25',
                                                         endTime='23:59:59',#23:59:59',
                                                         delay=0,
                                                         #set=0,
             opObj10.addParameter(name='save_period', value=10, format='int')
             '''
             opObj11 = procUnitConfObjA.addOperation(name='setH0')
-            opObj11.addParameter(name='h0', value='-1.2', format='float')
+            opObj11.addParameter(name='h0', value='-1.0', format='float')
             opObj11 = procUnitConfObjA.addOperation(name='selectHeights')
             opObj11.addParameter(name='minIndex', value='1', format='int')

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages