セロリのタスク内で私のredis接続をどのように処理する必要がありますか？

Question

私はそれはすべてが素晴らしい作品私のアプリケーション

class IncrementStatsCounterTask(Task): 
    def run(self, count, shortcode, stat_type, operator_id, date, **kwargs): 
     r_server = redis.Redis(settings.REDIS_HOST) 
     key = key_mask % { 
      'shortcode': shortcode, 
      'stat_type': stat_type, 
      'operator_id': operator_id, 
      'date': date.strftime('%Y%m%d') 
     } 

     return key, r_server.incr(key, count) 

ためのいくつかのカウンタを扱うセロリサーバーを持っているが、しかし、これが開き、Redisの接続をクローズするたびに、私の仕事、実行されます。接続を処理するより良い方法はありますか？おそらく何らかの永続的な接続があるでしょうか？

私はあなたの接続プールを使用することができますpython redis libraryでは、最新のジャンゴ - セロリ

Answer 1

を実行していますよ。あなたのモジュールの1つにグローバルにプールを作成し、新しい接続ごとにプールを使用するだけです。