python操作redis

gjfer

python、redis

1. #!/usr/bin/python
   
2. #coding=utf-8
   
3. 
   
4. import redis
   
5. 
   
6. class CRedis:
   
7. 
   
8.     def __init__(self):
   
9.         self.host = 'localhost'
   
10.         self.port = 6379
    
11.         self.db = 0
    
12.         self.r = redis.Redis(host = self.host, port = self.port, db = self.db)
    
13. 
    
14.     #1. strings 类型及操作
    
15.     #设置 key 对应的值为 string 类型的 value
    
16.     def set(self, key, value):
    
17.         return self.r.set(key, value)
    
18. 
    
19.     #设置 key 对应的值为 string 类型的 value。如果 key 已经存在,返回 0,nx 是 not exist 的意思
    
20.     def setnx(self, key, value):
    
21.         return self.r.setnx(key, value)
    
22. 
    
23.     #设置 key 对应的值为 string 类型的 value,并指定此键值对应的有效期
    
24.     def setex(self, key, time, value):
    
25.         return self.r.setex(key, time, value)
    
26. 
    
27.     #设置指定 key 的 value 值的子字符串
    
28.     #setrange name 8 gmail.com
    
29.     #其中的 8 是指从下标为 8(包含 8)的字符开始替换
    
30.     def setrange(self, key, num, value):
    
31.         return self.r.setrange(key, num, value)
    
32. 
    
33.     #获取指定 key 的 value 值的子字符串
    
34.     def getrange(self, key, start ,end):
    
35.         return self.r.getrange(key, start, end)
    
36. 
    
37.     #mget(list)
    
38.     def get(self, key):
    
39.         if isinstance(key, list):
    
40.             return self.r.mget(key)
    
41.         else:
    
42.             return self.r.get(key)
    
43. 
    
44.     #删除
    
45.     def remove(self, key):
    
46.         return self.r.delete(key)
    
47. 
    
48.     #自增
    
49.     def incr(self, key, default = 1):
    
50.         if (1 == default):
    
51.             return self.r.incr(key)
    
52.         else:
    
53.             return self.r.incr(key, default)
    
54. 
    
55.     #自减
    
56.     def decr(self, key, default = 1):
    
57.         if (1 == default):
    
58.             return self.r.decr(key)
    
59.         else:
    
60.             return self.r.decr(key, default)
    
61. 
    
62.     #2. hashes 类型及操作
    
63.     #根据email获取session信息
    
64.     def hget(self, email):
    
65.         return self.r.hget('session', email)
    
66. 
    
67.     #以email作为唯一标识，增加用户session
    
68.     def hset(self, email, content):
    
69.         return self.r.hset('session', email, content)
    
70. 
    
71.     #获取session哈希表中的所有数据
    
72.     def hgetall(self):
    
73.         return self.r.hgetall('session')
    
74. 
    
75.     #删除hashes
    
76.     def hdel(self, name, key = None):
    
77.         if(key):
    
78.             return self.r.hdel(name, key)
    
79.         return self.r.hdel(name)
    
80. 
    
81.     #清空当前db
    
82.     def clear(self):
    
83.         return self.r.flushdb()
    
84. 
    
85.     #3、lists 类型及操作
    
86.     #适合做邮件队列
    
87.     #在 key 对应 list 的头部添加字符串元素
    
88.     def lpush(self, key ,value):
    
89.         return self.r.lpush(key, value)
    
90. 
    
91.     #从 list 的尾部删除元素,并返回删除元素
    
92.     def lpop(self, key):
    
93.         return self.r.plush(key)
    
94. 
    
95. if __name__ == '__main__':
    
96. 
    
97.     r = CRedis()
    

复制代码