def _get_connection(self):
conn = getattr(_thread_local, "_redisconn", None)
if conn:
return conn
conn = redis.StrictRedis(host=self.host, port=self.port, db=self.db)
setattr(_thread_local, "_redisconn", conn)
return conn
评论列表
文章目录