すべての再試行が失敗した場合にタスクカウンタを減らす方法はありますか？

Question

I use現在実行中のタスクの数を保持するカウンタ。タスクが正常に完了したら、私はそれを減らす：

 for argument in files_arguments: 
       taskqueue.add(url='/tasks/upload', params={'photo_key': str(photo_file.key()), 
                  'counter_key': counter_key}) 
       # count number of active tasks     
       db.run_in_transaction(increase_counter, counter_key) 

# task handler 
class UploadWorker(webapp.RequestHandler): 
    def post(self): 
      try: 
       result = urlfetch.fetch(...)    
      except DownloadError: 
       logging.error('(TASK) ... DownloadError during file upload') 
       pass 
      except DeadlineExceededError: 
       logging.error('(TASK) ... DeadlineExceededError during file upload') 
       pass 
      if result.status_code == 200: 
       # decrease counter of active tasks 
       db.run_in_transaction(decrease_counter, counter_key) 
      else: 
       self.response.set_status(500) 

をしかし、どのように、私は最後の試みは、タスクカウンタを減少させるために失敗したことを知ることができますか？

Answer 1

このトランザクションが失敗した場合、別の例外がスローされます。

このタスクハンドラの応答には500のステータスコードがあり、GAEはこれを数回試します。

ところで、ハンドラを複数回呼び出すことができるので、urlfetch.fetch()は数回実行できます。あなたのために働いていますか？

Answer 2

障害が多すぎるためにタスクがキャンセルされた場合、コードを実行する方法はありません。代わりに、何かがうまくいかないときは自分の再試行カウンタをチェックし、最後の再試行では失敗する前にタスクカウンタを減らすようにタスクを構築する必要があります。

あなたが元の質問で言ったように、Pipeline APIのようなものを使用しているはずです。タスク用の単一のグローバルデータストアカウンタを維持すると、スループットが大幅に制限されます。