- #coding:utf8
- from redis import StrictRedis
- """定义一个处理 redis 的类"""
- class OprRedis:
- def init(self,host,port):
- self._redis = StrictRedis(host,port)
- def set(self,key,value):
- try:
- self._redis.set(key,value)
- except Exception,e:
- print e
- def get(self,key):
- try:
- return self._redis.get(key)
- except Exception,e:
- print e
- def pipeline(self):
- try:
- return self._redis.pipeline(transaction=False)
- except Exception,e:
- print e
- def main():
- oprRedis = OprRedis("localhost","6379")
- oprRedis.set("wf","wangfei")
- print oprRedis.get("xjb")
- pipline = oprRedis.pipeline()
- try:
- pipline.set("xxf","xiaoxiaofang")
- pipline.set("ldh","liudehua")
- pipline.execute()
- except Exception,e:
- print e
- main()
来源: http://www.bubuko.com/infodetail-2716231.html