セロリタスクが実行されている間にセカリタスクを停止し、しばらくしてから実行を続行する方法はありますか？

Question

Twitter APIとやり取りする以下のセロリタスク（簡略化）があります。

@app.task 
def get_followers(screen_name, **kwargs): 
    cursor = kwargs.get('cursor', -1) 
    followers = kwargs.get('followers', []) 
    while True: 
     response = twitter_api.call('followers', 'ids', screen_name=screen_name, cursor=cursor) 
     if response.status_code == '429': # RATE LIMIT EXCEEDED 
      # do something here 

     cursor = response.json()['next_cursor'] 
     if cursor == 0: # we're done 
      break 
    return followers 

私はレート制限がヒットしたいくつかの時間のためのタスクを一時停止し、それが停止した時点から実行を再開できるようにしたいです。 （あるいは、エラーを投げてタスクを再試行し、追加のkwargを渡してください）。これはどのように達成できますか？

Answer 1

あなたは429エラーコードキャッチするときには、自分のタスクを再試行することができます：私はself.retryを行うことができるようにあなたのタスクの定義にパラメータとしてタスクデコレータとselfでbind=Trueを追加

@app.task(bind=True) 
def get_followers(self, screen_name, **kwargs): 
    cursor = kwargs.get('cursor', -1) 
    followers = kwargs.get('followers', []) 
    while True: 
     response = twitter_api.call('followers', 'ids', screen_name=screen_name, cursor=cursor) 
     if response.status_code == '429': 
      # RATE LIMIT EXCEEDED 
      self.retry(countdown=15*60) 

     cursor = response.json()['next_cursor'] 
     if cursor == 0: # we're done 
      break 
    return followers 

注意を countdownを使用して、タスクを再試行する時間を秒単位で指定します。ここで私はあなたがセロリのドキュメントで再試行についての詳細に関する情報を見つけることができ

15分（ツイッターAPIのレート制限）を選択しました：

http://docs.celeryproject.org/en/latest/userguide/tasks.html#retrying