処理を中止する要求が中止された場合はフラスコのルート

Question

CPUの集中処理を行うフラスコのRESTエンドポイントがあり、戻すには数秒かかります。多くの場合、このエンドポイントが呼び出され、クライアントによってアボートされます。このような状況では、処理をキャンセルしたいと思います。どのように私はフラスコでこれを行うことができますか？ Node.jsので

、私のようなものだろう：私は中に特定の時点で確認することができると似たような、または同期メソッド（request.isClosedを（））を持つようにフラスコを期待していた

req.on('close', function(){ 
    //some handler 
}); 

を私の処理とそれが閉じている場合は戻ってきますが、見つけられません。

私は、接続がまだ開いていることをテストするために何かを送信し、失敗した場合に例外をキャッチすることを考えましたが、処理が完了して結果を返すまで例外がスローされないように：

An established connection was aborted by the software in your host machine

クライアントがリクエストを中止した場合、どのように処理を中止できますか？

Answer 1

あなたの問題に対する潜在的な...ハックな解決策がありますFlask has the ability to stream content back to the user via a generator。ハッキーな部分は、接続がまだ開いているかどうかを確認するためにブランクデータをストリーミングしています。ジェネレーターは処理が完了したかどうかをチェックして、Noneまたは""またはそれが終了していない場合は何でも返すことができます。

from flask import Response 

@app.route('/image') 
def generate_large_image(): 
    def generate(): 
     while True: 
      if not processing_finished(): 
       yield "" 
      else: 
       yield get_image() 
    return Response(generate(), mimetype='image/jpeg') 

私は、クライアントが接続を閉じた場合、あなたが買ってあげる何例外知らないが、私はちょうどプロジェクトでこれと同じことを行うしようとしたそのerror: [Errno 32] Broken pipe

Answer 2

私が知る限り、実行中に接続が開いている場合、サーバーはテストしていないため、実行中にクライアントによって接続が閉じられたかどうかはわかりません。私はあなたのカスタムrequest_handlerをFlaskアプリケーションに作成して、要求が処理された後に接続が「破棄」されたかどうかを検出できることを知っています。

from flask import Flask 
from time import sleep 
from werkzeug.serving import WSGIRequestHandler 


app = Flask(__name__) 


class CustomRequestHandler(WSGIRequestHandler): 

    def connection_dropped(self, error, environ=None): 
     print 'dropped, but it is called at the end of the execution :(' 


@app.route("/") 
def hello(): 
    for i in xrange(3): 
     print i 
     sleep(1) 
    return "Hello World!" 

if __name__ == "__main__": 
    app.run(debug=True, request_handler=CustomRequestHandler) 

はたぶん、あなたはリクエストがあなたが接続毎秒の状態をチェック__init__にスレッドを作成することができます来るときより、カスタムrequest_handlerとして作成されたビットを調査したい：例えば

接続が閉じていることを検出すると（check this thread）、画像処理を停止します。しかし、私はこれがちょっと複雑だと思っています：。

Answer 3

を賭けて喜んだと私は私のuWSGIのスタックとnginxのでストリーミング応答は以下のエラーが

SIGPIPE: writing to a closed pipe/socket/fd (probably the client disconnected) on request 
uwsgi_response_write_body_do(): Broken pipe [core/writer.c line 404] during GET 
IOError: write error 

を発生し、そのクライアントの最後に中断されたときということを発見し、私は以下のような正規の古いtryとexceptを使用することができます

try: 
     for chunk in iter(process.stdout.readline, ''): 
      yield chunk 
     process.wait() 
    except: 
     app.logger.debug('client disconnected, killing process') 
     process.terminate() 
     process.wait() 

これは私を与えなかっ：

1. フラスコの発電機能
2. を使用して、データのインスタントストリーミングにキャンセル接続