Redis
1 redis连接
import redis # 01 基本连接方式 # r=redis.Redis(host="127.0.0.1",port=6379) # # # r.set("age",99) # # print(r.get("age")) # b'99' # 02 基于连接池连接 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) r = redis.Redis(connection_pool=pool)
2 .字符串操作
import redis pool = redis.ConnectionPool(host='127.0.0.1', port=6379) r = redis.Redis(connection_pool=pool) # r.set("name","alex",5) # print(r.get("name")) # r.set("name","alex",nx=True) # r.set("name","alex") # 批量设置 # r.mset({'k1': 'v1', 'k2': 'v2'}) # 取值操作 # print(r.get("k2")) # b'v2' # 批量取值 # print(r.mget(["k1","k2"])) # [b'v1', b'v2'] # print(r.getrange("name",0,2)) # r.setrange("name",3,"!!!") # print(r.strlen("name")) # r.incr("age",2) # r.append("name","egon")
3. hash操作
import redis pool = redis.ConnectionPool(host='127.0.0.1', port=6379) r = redis.Redis(connection_pool=pool) # 为字典增加单个键值对 # r.hset("infos","name2","alex2") # {'infos':{'name':'alex'}} # print(r.hget("infos","name")) # 增加多个键值对 # 推荐 r.hset('infos',mapping={"age":1000,"gender":"male"}) print(r.hgetall('infos')) """ # 不推荐，即将被弃用 # r.hmset("infos",{"age":1000,"gender":"male"}) # r.hmset("infos",{"age2":1000}) { # 'infos':{'name':'alex','age':1000,'gender':'male'} # } """ # 查 # print(r.hmget("infos",["name","age"])) # [b'alex', b'1000'] # print(r.hgetall("infos")) # {b'name': b'alex', b'age': b'1000', b'gender': b'male'} # print(r.hlen("infos")) # print(r.hkeys("infos")) # [b'name', b'age', b'gender'] # print(r.hvals("infos")) # [b'alex', b'1000', b'male'] # # print(r.hexists("infos","names")) # 删除元素 # r.hdel("infos","gender") # print(r.hgetall("infos")) # {b'name': b'alex', b'age': b'1000'} # 键所对的值自增（+2） # r.hincrby("infos","age",2) #{b'name': b'alex', b'age': b'1004', b'name2': b'alex2', b'age2': b'1002'} # # print(r.hgetall("infos")) # print(r.hscan_iter("infos")) # # # for i in r.hscan_iter("infos"): # # print(i) # #返回元组 # 正则匹配 # r.hmset("abc",{"a1":"b1","a2":"b2","a3":"b3","x1":"y1"}) # 弃用 r.hset('abc',mapping={"a1":"b1","a2":"b2","a3":"b3","x1":"y2"}) print(r.hgetall('abc')) for i in r.hscan_iter("abc",match="a*"): print(i)
4 .list
import redis pool = redis.ConnectionPool(host='127.0.0.1', port=6379) r = redis.Redis(connection_pool=pool) # r.lpush("scores",56,78,99,65,34) #r.rpush("new_scores",23,56,77) # print(r.lrange("scores",0,-1)) # [b'34', b'65', b'99', b'78', b'56'] # print(r.lrange("new_scores",0,-1)) # [b'23', b'56', b'77'] # r.lpushx("scores",100) # print(r.llen("scores")) # r.linsert("scores","AFTER","34","44") # r.lset("scores",1,98) # r.lrem("scores",count=0,value=98) # print(r.lrange("scores",0,-1)) # print(r.lpop("scores")) # print(r.lrange("scores",0,-1)) # print(r.lindex("scores",3)) # print(r.lrange("scores",0,-1)) # print(r.lrange("scores",1,3)) # r.ltrim("scores",1,3) # print(r.lrange("scores",0,-1))
5. set
import redis pool = redis.ConnectionPool(host='127.0.0.1', port=6379) r = redis.Redis(connection_pool=pool) # r.sadd("score_set01",1,2,3,4,5,6,6) # r.sadd("score_set02",4,5,6,7,8) # print(r.smembers("score_set01")) # print(r.smembers("score_set02")) # # print(r.scard("score_set01")) # print(r.scard("score_set02")) # # print(r.sinter("score_set01","score_set02")) # 交集 # print(r.sunion("score_set01","score_set02")) # 并集 # print(r.sdiff("score_set01","score_set02")) # 差集 # # # # print(r.sismember("score_set01",6)) # print(r.sismember("score_set01",7)) # print(r.spop("score_set01")) # print(r.smembers("score_set01")) # print(r.srandmember("score_set01",3)) # r.srem("score_set01",5) # print(r.smembers("score_set01")) # print(r.sscan_iter("score_set01")) # for i in r.sscan_iter("score_set01"): # print(i)
6. sortset操作
import redis pool = redis.ConnectionPool(host='127.0.0.1', port=6379) r = redis.Redis(connection_pool=pool) # r.zadd("z",{"n1":1,"n2":2,"n3":5,"n4":3}) # print(r.zscan("z")) # # print(r.zcard("z")) # print(r.zcount("z",1,3)) # print(r.zcount("z",1,4)) # print(r.zcount("z",1,5)) # r.zincrby("z",2,"n3") # print(r.zscan("z")) # print(r.zrange("z",0,2)) # print(r.zrange("z",0,3)) # print(r.zscore("z","n4")) # print(r.zrank("z","n4")) # r.zrem("z","n2") # r.zremrangebyrank("z",0,1) # r.zremrangebyscore("z",1,7) # print(r.zscan("z")) # r.zadd("z1",{"n1":1,"n2":2,"n3":3,"x":100}) # r.zadd("z2",{"n3":4,"n5":5,"n6":6,"x":100}) # r.zunionstore("z3",("z1","z2")) # print(r.zscan("z3")) r.zinterstore("z4",("z1","z2")) print(r.zscan("z4"))
7 其他操作
import redis pool = redis.ConnectionPool(host='127.0.0.1', port=6379) r = redis.Redis(connection_pool=pool) # print(r.keys(pattern="k*")) # print(r.delete("naem")) # print(r.keys()) # print(r.exists("name")) # print(r.exists("naem")) # r.expire("name",10) # print(r.keys()) # # print(r.randomkey()) # # print(r.type("infos")) for i in r.scan_iter(match="k*"): print(i)
7 redis连接池
# by gaoxin import redis pool = redis.ConnectionPool(host="127.0.0.1", port=6379, decode_responses=True, max_connections=10) conn = redis.Redis(connection_pool=pool) ret = conn.get("n1") print(ret)
8 管道操作（事务操作）
# redis的事务操作 import redis pool = redis.ConnectionPool(host='10.211.55.4', port=6379) conn = redis.Redis(connection_pool=pool) pipe = conn.pipeline(transaction=True) pipe.multi() # 开始事务 pipe.set('name', 'bendere') pipe.set('role', 'sb') pipe.execute() #提交 # 注意：咨询是否当前分布式 redis 是否支持事务 print(conn.keys())
9 发布-订阅
pub.py
# by gaoxin import redis conn = redis.Redis(host="127.0.0.1", port=6379, decode_responses=True) conn.publish("gaoxin333", "18")
sub.py
# by gaoxin import redis conn = redis.Redis(host="127.0.0.1", port=6379, decode_responses=True) # 第一步 生成一个订阅者对象 pubsub = conn.pubsub() # 第二步 订阅一个消息 pubsub.subscribe("gaoxin333") # 创建一个接收 while True: print("working~~~") msg = pubsub.parse_response() print(msg)
其他
# redis的事务操作（python连接） import redis pool = redis.ConnectionPool(host='10.211.55.4', port=6379) conn = redis.Redis(connection_pool=pool) pipe = conn.pipeline(transaction=True) pipe.multi() # 开始事务 pipe.set('name', 'bendere') pipe.set('role', 'sb') pipe.execute() #提交 1 redis 事务操作 （数据库直接操作） set age 100 multi # 开启事务 set age 10 set a 20 exec # 结束 discard 取消所有事务，也就是事务回滚 2 redis 设置有效时间 ex设置有效时间 conn.set(key, json.dumps(context), ex=60 * 30) # 30分钟 3常用命令： 1） 查看keys个数 keys * // 查看所有keys keys prefix_* // 查看前缀为"prefix_"的所有keys 2） 清空数据库 flushdb // 清除当前数据库的所有keys flushall // 清除所有数据库的所有keys 3） del 'a' 删除单个