在返回HTTP 200後執行函數在燒瓶中OK OK

Question

我正在使用Flask應用程序，它需要在2秒內返回HTTP 200 OK。但是我的應用程序在發送HTTP 200 OK之後必須啓動一些工作。

@app.route('/events-slack', methods=['GET', 'POST']) 
def events(): 
    if(rq.is_json): 
     data = rq.get_json() 
     if(data['token']==token): 
      respond(data) #this function take more than 2 seconds 
      r_data = { 
      'OK' : True 
      } 
     else: 
      r_data = { 
      "error" : 'Token mismatch' 
      } 
    else: 
     r_data = { 
     "error" : 'Request was not JSON' 
     } 
    response = app.response_class(
     status=200, 
     mimetype='application/json', 
     response=json.dumps(r_data) 
) 
    return response 

問題是響應函數採用2秒以上來處理它接收到的數據。我需要它先發送HTTP 200請求，然後開始工作。

編輯

下面是響應函數的代碼。

import requests 
def respond(data): 
    if data['type'] == "event_callback": 
     event = data['event'] 
     if event['type'] == 'message': 
      r_data = requests.post('URL', data = {'key' : 'data') 
    else: 
     r_data = { 
       "error" : 'Type not recognized' 
     } 
    return r_data 

Answer 1

您需要將沉重的負擔轉移到背景上，這樣您纔不必忍受響應。這通常使用像Celery這樣的任務隊列完成。

http://www.celeryproject.org

你也可以考慮像休伊一些輕量級的替代品。

https://github.com/coleifer/huey/blob/master/README.rst