Fiasco lanciare "lavorare fuori dal contesto della richiesta" all'avvio della sottofodera

Question

Sto provando ad avviare una nuova discussione in Python all'interno di un'applicazione Flask. Sto facendo il lavoro in background che viene attivato dalla richiesta, ma non ho bisogno di aspettare che il lavoro sia fatto per rispondere alla richiesta.

È possibile impostare la richiesta del pallone in questa sotto minaccia alla richiesta? Essendo la ragione, il nostro ACL sulle nostre query al nostro DB (mongoengine di fronte a mongoDB) si basa sull'utente della richiesta (lo afferra dall'oggetto di richiesta del flask) per vedere se hanno accesso agli oggetti, e la sua esplosione perché la richiesta è non disponibile nel sottoprocesso.

Ogni pensiero sarebbe molto apprezzato.

Ecco lo pseudo codice di come lo sto gestendo ora, ma non funziona.

@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

Avvolgete il vostro codice di discussione in un test_request_context in modo da avere accesso 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" 

Edit: vale la pena di sottolineare che il filo avrà un contesto diverso da quello della richiesta originale. È necessario estrarre qualsiasi dato di richiesta interessante, come l'ID utente, prima di generare il thread. È quindi possibile afferrare un oggetto utente (diverso) nel sottoprocesso utilizzando l'ID.

Answer 2

Dalla versione 0.10 non v'è un modo sostenuto di fare questo: http://flask.pocoo.org/docs/api/#flask.copy_current_request_context

Se si desidera che i before_request ganci per funzionare è necessario chiamare current_app.preprocess_request() all'interno della funzione decorato.

Answer 3

è possibile copiare le informazioni desiderato e passarlo

@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"