redis的实践

火冰狐

def __init__(self,host,port):　　try:
　　self.pool = redis.ConnectionPool(host=host, port=port,db=0)
　　self.conn = redis.Redis(connection_pool=self.pool)
　　except redis.ConnectionError as e:
　　logger.exception('Connected failed:%s'%e)
　　def set(self,key,value):
　　self.conn.set(key, value)
　　def get(self,key):
　　pipe = self.conn.pipeline(transaction=True)
　　return self.conn.get(key)
　　pipe.execute()
　　def delete(self,key):
　　return self.conn.delete(key)
　　def isKeyExists(self,name):
　　'''判断key是否存在'''
　　return self.conn.exists(name)
　　def bitcount(self,key):
　　return self.conn.bitcount(key)
　　def get_value(self,Key):
　　'''60秒拿特定key的值'''
　　# redisValue = {}
　　seconds = 60
　　count = 0
　　while (count < seconds):
　　count += 1
　　n = seconds - count
　　logger.info('remain %s seconds' % n)
　　time.sleep(1)
　　redisValue = self.get(Key.strip())
　　if redisValue:
　　break
　　if redisValue:
　　logger.info('此规则的key为:%s,值为: %s' % (Key, redisValue))
　　else:
　　logger.exception('此规则的key为:%s,值为: %s' % (Key, redisValue))
　　return redisValue