企业🤖AI智能体构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
## 安装包 * 到[中文官网](http://redis.cn/clients.html)查找客户端代码 * 联网安装 ~~~ sudo pip install redis ~~~ * 使用源码安装 ~~~ unzip redis-py-master.zip cd redis-py-master sudo python setup.py install ~~~ ## 交互代码 * 引入模块 ~~~ import redis ~~~ * 连接 ~~~ try: r=redis.StrictRedis(host='localhost',port=6379) except Exception,e: print e.message ~~~ * 方式一:根据数据类型的不同,调用相应的方法,完成读写 * 更多方法同前面学的命令 ~~~ r.set('name','hello') r.get('name') ~~~ * 方式二:pipline * 缓冲多条命令,然后一次性执行,减少服务器-客户端之间TCP数据库包,从而提高效率 ~~~ pipe = r.pipeline() pipe.set('name', 'world') pipe.get('name') pipe.execute() ~~~ ## 封装 * 连接redis服务器部分是一致的 * 这里将string类型的读写进行封装 ~~~ import redis class RedisHelper(): def __init__(self,host='localhost',port=6379): self.__redis = redis.StrictRedis(host, port) def get(self,key): if self.__redis.exists(key): return self.__redis.get(key) else: return "" def set(self,key,value): self.__redis.set(key,value) ~~~ ## python3代码 ~~~ #!/usr/bin/env python # -*- coding: utf-8 -*- ''' @Time : 5/18/18 7:39 PM @Author : haibo @File : MyRedis.py ''' from redis import * # r = StrictRedis(host='localhost', port=6379) # write # pipe = r.pipeline() # pipe.set('py10', 'hello1') # pipe.set('py11', 'world') # pipe.execute() # read # temp = r.get('py10') # print(temp) class redisHelper(object): def __init__(self, host, port): self.__redis = StrictRedis(host, port) def set(self, key, value): self.__redis.set(key, value) def get(self, key): return self.__redis.get(key) ~~~