Lanzar procesos en background

Muchas veces nos resultará útil lanzar algún tipo de proceso en background con tal de no bloquear el navegador. Por ejemplo, procesos que impliquen actualización o creación de muchos objetos

Para ello, podemos utilizar los siguientes fragmentos de código para hacerlo

1-Por un lado, crearemos un adaptador o incluiremos este código para gestionar la llamada a procesos externos

class CommandLauncher(threading.Thread):
    def __init__(self, command,params=[]):
        threading.Thread.__init__(self)
        self.command = command
        self.result  = None
        if len(params):
            self.command = '%s %s'%(self.command,' '.join(params))       
       
    def run(self):       
        command_in, command_out = os.popen4(self.command, bufsize=0)       
        self.result = command_out.read()       
        command_in.close()       
        command_out.close()
       
    def abort(self):
        import os, sys
        if sys.platform == 'win32':
            os.abort()
        my_pid = str(os.getpid())
        command_in, command_out = os.popen4("/bin/ps -Af | /bin/grep %s | /bin/grep -v grep" % my_pid) 
        result = str(command_out.read())
        for line in result.split('\n'):
            while line.find('  ') > -1:
                line = line.replace('  ',' ')
            parts = line.split(' ')
            if len(parts)>1 and parts[2] == my_pid:
                # A child process to be killed
                os.kill(long(parts[1]), 9)
                os.waitpid(long(parts[1]), 0)
        command_in.close()
        command_out.close()


2- Dentro de nuestro código, haríamos una llamada de este tipo:

def miProcesoEnBatch(self,portal):
        try:                       
            command = '/usr/local/kmkey/zope/bin/zopectl run miscript.py'
            thread = CommandLauncher(command)
            thread.start()           
        except:  
             llamar a algun proceso que reporte el error(log propio o envío de mail)
             raise "Export error", thread.result
        return

Con esto , conseguimos hacer una llamada a un proceso externo desde nuestro navegador (en el proceso externo deberemos montar algún sistema para enviar aviso de que ha finalizado o ha dado error)

Un ejemplo de proceso externo sería este:


if __name__ == "__main__":   
    try:  
        import_products()
        #low priority   
        os.nice(5)   
       
        app = makerequest(app)
        site = app.unrestrictedTraverse('mi_sitio_kmkey')
        user = site.acl_users.getUser('manager').__of__(site.acl_users)
        newSecurityManager({}, user)
        app = makerequest(app)
        site = app.unrestrictedTraverse('mi_sitio_kmkey')              

        #todo mi proceso aquí#  (con commits parciales)
        get_transaction().commit()       
    except:  
        (exc, msg, tb) = sys.exc_info()
        out = StringIO()
        traceback.print_exception(exc,msg,tb,None,out)
        out.seek(0)
        body = str(out.read())
        #montar algún sistema para reportar errores, ya
        #sea con log propio, envió de mail o logger de zope
        escribelog(body)
        enviarMail(site,subject="Traceback Error a importació de matrícules",body=body)
        logger.error("Importar matricules Traceback:\n%s", body)



Etiquetas: