Redis是一个开源的非关系型数据库，它采用C语言编写，是一个key-value存储系统，它存储的value类型很多，包括string（字符串），list（链表），set（集合），zset（有序集合），hash（哈希）
比如，我们插入一条数据，如下：
class Database:
def __init__(self):
self.host = ‘localhost’
self.port = 6379
def write(self,website,city,year,month,day,deal_number):
try:
key = ‘_’.join([website,city,str(year),str(month),str(day)])
val = deal_number
r = redis.StrictRedis(host=self.host,port=self.port)
r.set(key,val)
except Exception, exception:
print exception
def read(self,website,city,year,month,day):
try:
key = ‘_’.join([website,city,str(year),str(month),str(day)])
r = redis.StrictRedis(host=self.host,port=self.port)
value = r.get(key)
print value
return value
except Exception, exception:
print exception
if __name__ == ‘__main__’:
db = Database()
db.write(‘meituan’,’beijing’,2013,9,1,8000)
db.read(‘meituan’,’beijing’,2013,9,1)
上面操作是先写入一条数据，然后再读取，如果写入或者读取数据太多，那么我们最好用批处理，这样效率会更高。
import datetime
class Database:
def __init__(self):
self.host = ‘localhost’
self.port = 6379
self.write_pool = {}
def add_write(self,website,city,year,month,day,deal_number):
key = ‘_’.join([website,city,str(year),str(month),str(day)])
val = deal_number
self.write_pool[key] = val
def batch_write(self):
try:
r = redis.StrictRedis(host=self.host,port=self.port)
r.mset(self.write_pool)
except Exception, exception:
print exception
def add_data():
beg = datetime.datetime.now()
db = Database()
for i in range(1,10000):
db.add_write(‘meituan’,’beijing’,2013,i,1,i)
db.batch_write()
end = datetime.datetime.now()
print end-beg
if __name__ == ‘__main__’:
add_data()
以上就是Python读写Redis数据库操作示例的详细内容，更多请关注gaodaima搞代码网其它相关文章！
转载请注明原文链接：Python读写Redis数据库操作示例
