Flask werfend "außerhalb des Anfragekontexts arbeiten" beim Starten von Unter-Thread

Question

Ich versuche, einen neuen Thread in Python innerhalb einer Flask-Anwendung zu starten. Ich mache Hintergrundarbeit, die von der Anfrage ausgelöst wird, aber ich muss nicht warten, bis die Arbeit erledigt ist, um auf die Anfrage zu antworten.

Ist es möglich, die Flaschenanforderung in dieser Subbedrohung auf die eingehende Anfrage zu setzen? Der Grund dafür ist, dass unsere ACL auf unsere Anfragen an unsere DB (Mongoengine vor mongoDB) auf den Benutzer der Anfrage angewiesen ist (er nimmt es aus dem Anfrageobjekt von flask), um zu sehen, ob sie Zugriff auf die Objekte haben und dass die Anfrage explodiert nicht im Unter-Thread verfügbar.

Alle Gedanken würden sehr geschätzt werden.

Hier ist Pseudo-Code, wie ich es jetzt handle, aber es funktioniert nicht.

@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

Wickeln Sie Ihre Thread-Code in einem test_request_context so haben Sie Zugriff auf 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" 

bearbeiten: es ist erwähnenswert, dass der Thread einen anderen Kontext als die ursprüngliche Anforderung haben. Sie müssen alle interessanten Anforderungsdaten wie die Benutzer-ID extrahieren, bevor Sie den Thread erstellen. Sie können dann ein (anderes) Benutzerobjekt im Unter-Thread mit der ID erfassen.

Answer 2

Seit Version 0.10 gibt es eine unterstützte Möglichkeit, dies zu tun: http://flask.pocoo.org/docs/api/#flask.copy_current_request_context

Wenn Sie die before_request Haken ausführen möchten Sie current_app.preprocess_request() innerhalb der dekorierten Funktion aufrufen müssen.

Answer 3

können Sie die gewünschte Info kopieren und

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