Python中怎么對(duì)redis進(jìn)行操作

Python中怎么對(duì)redis進(jìn)行操作，相信很多沒有經(jīng)驗(yàn)的人對(duì)此束手無策，為此本文總結(jié)了問題出現(xiàn)的原因和解決方法，通過這篇文章希望你能解決這個(gè)問題。

一、redis

redis是一個(gè)key-value存儲(chǔ)系統(tǒng)。和Memcached類似，它支持存儲(chǔ)的value類型相對(duì)更多，包括string(字符串)、list(鏈表)、set(集合)、zset(sorted set --有序集合)和hash（哈希類型）。這些數(shù)據(jù)類型都支持push/pop、add/remove及取交集并集和差集及更豐富的操作，而且這些操作都是原子性的。在此基礎(chǔ)上，redis支持各種不同方式的排序。與memcached一樣，為了保證效率，數(shù)據(jù)都是緩存在內(nèi)存中。區(qū)別的是redis會(huì)周期性的把更新的數(shù)據(jù)寫入磁盤或者把修改操作寫入追加的記錄文件，并且在此基礎(chǔ)上實(shí)現(xiàn)了master-slave(主從)同步。

Redis 是一個(gè)高性能的key-value數(shù)據(jù)庫(kù)。 redis的出現(xiàn)，很大程度補(bǔ)償了memcached這類key/value存儲(chǔ)的不足，在部 分場(chǎng)合可以對(duì)關(guān)系數(shù)據(jù)庫(kù)起到很好的補(bǔ)充作用。它提供了Python，Ruby，Erlang，PHP客戶端，使用很方便,Redis支持主從同步。數(shù)據(jù)可以從主服務(wù)器向任意數(shù)量的從服務(wù)器上同步，從服務(wù)器可以是關(guān)聯(lián)其他從服務(wù)器的主服務(wù)器。這使得Redis可執(zhí)行單層樹復(fù)制。從盤可以有意無意的對(duì)數(shù)據(jù)進(jìn)行寫操作。由于完全實(shí)現(xiàn)了發(fā)布/訂閱機(jī)制，使得從數(shù)據(jù)庫(kù)在任何地方同步樹時(shí)，可訂閱一個(gè)頻道并接收主服務(wù)器完整的消息發(fā)布記錄。

二、python操作redis

1、連接方式

redis-py提供兩個(gè)類Redis和StrictRedis用于實(shí)現(xiàn)Redis的命令，StrictRedis用于實(shí)現(xiàn)大部分官方的命令，并使用官方的語(yǔ)法和命令，Redis是StrictRedis的子類

#!/usr/bin/env python
# -*- coding:utf-8 -*-
import redis
r = redis.Redis(host='192.168.0.110', port=6379,db=0)
r.set('name', 'zhangsan')  #添加
print (r.get('name'))  #獲取

2、連接池

redis-py使用connection pool來管理對(duì)一個(gè)redis server的所有連接，避免每次建立、釋放連接的開銷。默認(rèn)，每個(gè)Redis實(shí)例都會(huì)維護(hù)一個(gè)自己的連接池?？梢灾苯咏⒁粋€(gè)連接池，然后作為參數(shù)Redis，這樣就可以實(shí)現(xiàn)多個(gè)Redis實(shí)例共享一個(gè)連接池。

#!/usr/bin/env python
# -*- coding:utf-8 -*-
import redis
pool = redis.ConnectionPool(host='192.168.0.110', port=6379)
r = redis.Redis(connection_pool=pool)
r.set('name', 'zhangsan')  #添加
print (r.get('name'))  #獲取

3、操作

redis詳細(xì)操作命令

4、管道

redis-py默認(rèn)在執(zhí)行每次請(qǐng)求都會(huì)創(chuàng)建（連接池申請(qǐng)連接）和斷開（歸還連接池）一次連接操作，如果想要在一次請(qǐng)求中指定多個(gè)命令，則可以使用pipline實(shí)現(xiàn)一次請(qǐng)求指定多個(gè)命令，并且默認(rèn)情況下一次pipline 是原子性操作。

#!/usr/bin/env python
# -*- coding:utf-8 -*-
import redis
pool = redis.ConnectionPool(host='192.168.0.110', port=6379)
r = redis.Redis(connection_pool=pool)
pipe = r.pipeline(transaction=True)
r.set('name', 'zhangsan')
r.set('name', 'lisi')
pipe.execute()

5、發(fā)布和訂閱

首先定義一個(gè)RedisHelper類，連接Redis，定義頻道為monitor，定義發(fā)布(publish)及訂閱(subscribe)方法。

#!/usr/bin/env python
#-*- coding:utf-8 -*-
import redis
class RedisHelper(object):
  def __init__(self):
    self.__conn = redis.Redis(host='192.168.0.110',port=6379)#連接Redis
    self.channel = 'monitor' #定義名稱
  def publish(self,msg):#定義發(fā)布方法
    self.__conn.publish(self.channel,msg)
    return True
  def subscribe(self):#定義訂閱方法
    pub = self.__conn.pubsub()
    pub.subscribe(self.channel)
    pub.parse_response()
    return pub

發(fā)布者

#!/usr/bin/env python
# -*- coding:utf-8 -*-
#發(fā)布
from RedisHelper import RedisHelper
obj = RedisHelper()
obj.publish('hello')#發(fā)布

訂閱者

#!/usr/bin/env python
# -*- coding:utf-8 -*-
#訂閱
from RedisHelper import RedisHelper
obj = RedisHelper()
redis_sub = obj.subscribe()#調(diào)用訂閱方法
while True:
  msg= redis_sub.parse_response()
  print (msg)

看完上述內(nèi)容，你們掌握Python中怎么對(duì)redis進(jìn)行操作的方法了嗎？如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容，歡迎關(guān)注億速云行業(yè)資訊頻道，感謝各位的閱讀！