djangoで30分のAPIコールを実行する方法

Question

私のdjangoアプリケーションでは、再発行エンドポイントにヒットした後、その機能がトリガーされてそのステータスを確認するアクション（再発行アクション）によってトリガーされる関数があります。別のAPI呼び出しで30分。その機能は次のとおりです。

timeout = time.time() + 60 * 30 
     published_flag = False 
    while time.time() < timeout: 
       data = requests.get(apiUrl + dist_id).json() 
       try: 
        published_flag = data['flags'] 
        if published_flag: 
         break 
        else: 
         time.sleep(5) 
         continue 
       except KeyError: 
        break 

このタイムアウトは30分であり、非常に長くなります。しかし、フラグ状態が変わる最悪のシナリオは30分です。このアクションは、複数回トリガーすることができます（複数の再発行ボタンを押すことができます）。エンドポイントが実質的にタイムアウトするのは、エンドポイントが動作するには長すぎるためです。だから私はフロントエンドにWebソケットを介してデータをプッシュします。

これを行うにはスマートな方法がありますか？

Answer 1

エニックスが書いたように、セロリを使うべきです。しかし、あなたは多くの労働者を必要としません。実際にはセロリの仕事の中でsleepを呼ぶことはありません。後で再試行できます。だから、すべての仕事は本当に短くて、あなたはちょうど1〜2人の労働者が必要です。

@app.task(bind=True, max_retries=60*30/5) 
def do_whatever(self, dist_id): 
    data = requests.get(apiUrl + dist_id).json() 
    if 'flags' not in data: 
     self.retry(countdown=5)