Frasco que arroja 'trabajo fuera del contexto de solicitud' al iniciar el subproceso

Question

Estoy tratando de iniciar un nuevo subproceso en Python dentro de una aplicación Flask. Estoy haciendo un trabajo de fondo que se desencadena con la solicitud, pero no necesito esperar a que se realice el trabajo para responder a la solicitud.

¿Es posible establecer la solicitud del matraz en esta sub-amenaza a la solicitud que entró? Por lo que respecta a la razón, nuestra ACL en nuestras consultas a nuestro DB (mongoengine frente a mongoDB) depende del usuario de la solicitud (lo agarra del objeto de solicitud del matraz) para ver si tienen acceso a los objetos, y explota porque la solicitud es no disponible en el sub thread

Cualquier idea sería muy apreciada.

Aquí hay un pseudo código de cómo lo estoy manejando ahora, pero no está funcionando.

@app.route('/my_endpoint', methods=['POST']) 
def my_endpoint_handler(): 
    #do tracking in sub-thread so we don't hold up the page 
    def handle_sub_view(req): 
     from flask import request 
     request = req 
     # Do Expensive work 
    thread.start_new_thread(handle_sub_view, (request)) 
    return "Thanks" 

Answer 1

Envuelve el código de hilo en una test_request_context para que tenga acceso a context locals:

@app.route('/my_endpoint', methods=['POST']) 
def my_endpoint_handler(): 
    #do tracking in sub-thread so we don't hold up the page 
    def handle_sub_view(req): 
     with app.test_request_context(): 
      from flask import request 
      request = req 
      # Do Expensive work 
    thread.start_new_thread(handle_sub_view, (request)) 
    return "Thanks" 

Editar: vale la pena señalar que el hilo tendrá un contexto diferente al de la solicitud original. Debe extraer datos de solicitud interesantes, como la ID de usuario, antes de generar el hilo. A continuación, puede tomar un objeto de usuario (diferente) en el sub thread utilizando la ID.

Answer 2

Desde la versión 0.10 hay una manera de hacer esto apoyado: http://flask.pocoo.org/docs/api/#flask.copy_current_request_context

Si desea que los ganchos se ejecuten before_request debe llamar current_app.preprocess_request() en el interior de la función decorada.

Answer 3

puede copiar la información deseada y pasarlo

@app.route('/my_endpoint', methods=['POST']) 
def my_endpoint_handler(): 
    #do tracking in sub-thread so we don't hold up the page 
    def handle_sub_view(data): 
     # Use the data in subprocess 
    data = request.get_json() # copy the data 
    thread.start_new_thread(handle_sub_view, data) 
    return "Thanks"