Flaskでバックグラウンドタイマーを実行するには

Question

Kubernetesで実行しているとき、特にgraceful shutdownのときに正しく動作するFlaskアプリを書き込もうとしています。

そのように、私は、コードを持っている必要があります：

• は、シャットダウン信号
を受け取る時間が 「UP」になるまで、「シャットダウンタイマー」
• を開始
• ノーマルとしての要求を続けます
• その後

を自分自身をシャットダウンこれまでのところ、私が持っていることはこれです：

from flask import Flask, abort 
import signal 
import time 
app = Flask(__name__) 
shuttingDown = False 

def exit_gracefully(self, signum): 
    app.logger.error('Received shutdown signal. Exiting gracefully') 
    global shuttingDown 
    shuttingDown = True 
    # TODO: wait for some time here to ensure we are not receiving any more 
    # traffic 
    time.sleep(20) 
    exit(0) 

signal.signal(signal.SIGTERM, exit_gracefully) 

@app.route("/") 
def hello(): 
     return "Hello World!" 

@app.route("/_status/liveness") 
def liveness(): 
     return "I am alive" 

@app.route("/_status/readiness") 
def readiness(): 
     if not shuttingDown: 
      return "I am ready" 
     else: 
      abort(500, 'not ready anymore') 

"シャットダウン"信号を送信した後を除いて上記の "動作"は、シャットダウン時の "猶予期間"内にあっても "/"への通常のリクエストは応答されません）。

"time.sleep（）"の呼び出しは同期しているようです。

これを「非同期」にする方法を知っている人はいますか？時間が "アップ"になるまでアプリがリクエストを処理し続けるようにするには？

Answer 1

あなたはFlask開発サーバーを内蔵していると思います。このようなFlaskとDjangoの組み込み開発サーバー、または標準ライブラリのWebサーバーまたはWSGIサーバーに基づくものは、運用システム向けではなく、通常はシグナルのシャットダウンを適切に処理しません。

このように、Apache/mod_wsgi（mod_wsgi-express）、gunicorn、またはuWSGIなどの適切なプロダクショングレードのWSGIサーバーを実際に使用する必要があります。これらはすべて適切にシグナルを処理し、コンテナのシャットダウンを遅らせる原因となるシグナルを無視する開発サーバーでは問題が発生しません。シャットダウンタイムアウトが発生したときに最終的にKubernetesによって殺されます。

Answer 2

これは内部サーバーで動作します。警告には、サーバーをシャットダウンする/ _shutdown URLがあり、これは悪意のあるシャットダウンに開放されています。これが欲しいものでない場合は、requests.post()を削除し、os._exit()のコメントを外してください。もちろん、@app.route("/_shutdown")とその機能も削除してください。

from flask import Flask, abort, request 
import signal 
import threading 
import time 
import os 
import requests 
app = Flask(__name__) 
shuttingDown = False 


def exit_call(): 
    time.sleep(20) 
    requests.post("http://localhost:5420/_shutdown") 
    # os._exit(0) 


def exit_gracefully(self, signum): 
    app.logger.error('Received shutdown signal. Exiting gracefully') 
    global shuttingDown 
    shuttingDown = True 
    # TODO: wait for some time here to ensure we are not receiving any more 
    # traffic 
    _et = threading.Thread(target=exit_call) 
    _et.daemon = True 
    _et.start() 


signal.signal(signal.SIGTERM, exit_gracefully) 


@app.route("/") 
def hello(): 
     return "Hello World!" 


@app.route("/_status/liveness") 
def liveness(): 
     return "I am alive" 


@app.route("/_shutdown", methods=["POST"]) 
def shutdown(): 
    func = request.environ.get('werkzeug.server.shutdown') 
    if func is None: 
     return "Not a werkzeug server" 
    func() 
    return "shutdown" 


@app.route("/_status/readiness") 
def readiness(): 
     if not shuttingDown: 
      return "I am ready" 
     else: 
      abort(500, 'not ready anymore') 


app.run(port=5420)