1. 程式人生 > >(廿三)Python:Redis儲存

(廿三)Python:Redis儲存

      Redis是一個基於記憶體的高效的(讀的速度是110000次/s,寫的速度是81000次/s)鍵值型非關係型資料庫,存取效率極高,支援多種儲存資料結構。Redis支援資料的備份,即master-slave模式的資料備份。

準備

      Python操作Redis請安裝redis-py庫,直接使用命令pip3 install redis 安裝即可。
       如果我們還需要多資料進行匯入/匯出工作我們還需要安裝RedisDump庫。由於它是基於Ruby實現的,所有我們需要先安裝Ruby:

  1. 下載 rubyinstaller 之後,解壓到新建立的目錄下:
  2. 雙擊 rubyinstaller-2.2.3.exe 檔案,啟動 Ruby 安裝嚮導。
  3. 點選 Next,繼續嚮導,記得勾選 Add Ruby executables to your PATH,直到 Ruby 安裝程式完成Ruby 安裝為止。
           安裝好Ruby後我們使用gem install redis-dump 安裝RedisDump。但是安裝RedisDump時可能會出現如下圖所示問題:
    這裡寫圖片描述
    發生這個錯誤的原因是沒有安裝DevKit,所以我們需要安裝它。下載地址:http://rubyinstaller.org/downloads
    這裡寫圖片描述
    1、執行,解壓到一個目錄,例如:D:\DevKit
    2、開啟命令列,切換到這個目錄;
    3、執行命令:ruby dk.rb init
    4、執行命令:ruby dk.rb install

    這裡寫圖片描述
    執行以上4步後重新執行gem install redis-dump 安裝RedisDump即可。

連線Redis

       redis-py提供兩個類Redis和StrictRedis用於實現Redis的命令,StrictRedis用於實現大部分官方的命令,並使用官方的語法和命令。Redis類是 StrictRedis的子類,它主要是用於向後相容舊版本。官方推薦使用StrictRedis類

from redis import StrictRedis

redis = StrictRedis(host='localhost',db=3,port=6379)#選擇db3,redis沒有密碼預設為None
redis.set('age',20)
print(redis.get('age'))#往db3中設定age=3,列印驗證

這裡寫圖片描述
觀察StrictRedis的__init__方法我們可以發現StrictRedis類使用host和port等引數構造一個ConnectionPool,所以我們可以直接將ConnetcionPool作為引數傳入。
原始碼如下:

    def __init__(self, host='localhost', port=6379,db=0, password=None,connection_pool=None):
        if not connection_pool:#判斷是否傳入connection_pool作為引數
            #其他程式碼
            connection_pool = ConnectionPool(**kwargs)#構建ConnectionPool
        self.connection_pool = connection_pool

示例程式碼:

from redis import StrictRedis,ConnectionPool

pool = ConnectionPool(host='localhost',port=6379,db=3,password=None)
redis = StrictRedis(connection_pool=pool)
redis.set('name','Jake')
print(redis.get('name'))

ConnectionPool支援通過URL構建,格式有以下3種:

redis://[:password]@host:port/db	#redis tcp連線
rediss://[:password]@host:port/db	#redis tcp+ssl連線
unix://[:password]@path/to/socket.sock?db=db	#redis unix socket連線

示例程式碼:

from redis import StrictRedis,ConnectionPool

url = 'redis://@localhost:6379/3'
pool = ConnectionPool.from_url(url)#通過url構建ConnectionPool
redis = StrictRedis(connection_pool=pool)
redis.set('addr','beijing')
print(redis.get('addr'))

鍵操作

下表總結了鍵的一些判斷和操作方法。

方法

作用

引數說明

示例

示例說明

示例結果

exists(name)

判斷一個鍵是否存在

name:鍵名

redis.exists('name')

是否存在name這個鍵

True

delete(name)

刪除一個鍵

name:鍵名

redis.delete('name')

刪除name這個鍵

1

type(name)

判斷鍵型別

name:鍵名

redis.type('name')

判斷name這個鍵型別

b'string'

keys(pattern)

獲取所有符合規則的鍵

pattern:匹配規則

redis.keys('n*')

獲取所有以n開頭的鍵

[b'name']

randomkey()

獲取隨機的一個鍵

randomkey()

獲取隨機的一個鍵

b'name'

rename(src, dst)

重新命名鍵

src:原鍵名;dst:新鍵名

redis.rename('name', 'nickname')

name重新命名為nickname

True

dbsize()

獲取當前資料庫中鍵的數目

dbsize()

獲取當前資料庫中鍵的數目

100

expire(name, time)

設定鍵的過期時間,單位為秒

name:鍵名;time:秒數

redis.expire('name', 2)

name鍵的過期時間設定為2秒

True

ttl(name)

獲取鍵的過期時間,單位為秒,-1表示永久不過期

name:鍵名

redis.ttl('name')

獲取name這個鍵的過期時間

-1

move(name, db)

將鍵移動到其他資料庫

name:鍵名;db:資料庫代號

move('name', 2)

name移動到2號資料庫

True

flushdb()

刪除當前選擇資料庫中的所有鍵

flushdb()

刪除當前選擇資料庫中的所有鍵

True

flushall()

刪除所有資料庫中的所有鍵

flushall()

刪除所有資料庫中的所有鍵

True

## 字串操作 ##

Redis支援最基本的鍵值對形式儲存,用法總結如下表所示。

方法

作用

引數說明

示例

示例說明

示例結果

set(name, value)

給資料庫中鍵為namestring賦予值value

name: 鍵名;value: 值

redis.set('name', 'Bob')

name這個鍵的value賦值為Bob

True

get(name)

返回資料庫中鍵為namestringvalue

name:鍵名

redis.get('name')

返回name這個鍵的value

b'Bob'

getset(name, value)

給資料庫中鍵為namestring賦予值value並返回上次的value

name:鍵名;value:新值

redis.getset('name', 'Mike')

賦值nameMike並得到上次的value

b'Bob'

mget(keys, *args)

返回多個鍵對應的value

keys:鍵的列表

redis.mget(['name', 'nickname'])

返回namenicknamevalue

[b'Mike', b'Miker']

setnx(name, value)

如果不存在這個鍵值對,則更新value,否則不變

name:鍵名

redis.setnx('newname', 'James')

如果newname這個鍵不存在,則設定值為James

第一次執行結果是True,第二次執行結果是False

setex(name, time, value)

設定可以對應的值為string型別的value,並指定此鍵值對應的有效期

name: 鍵名;time: 有效期; value:值

redis.setex('name', 1, 'James')

name這個鍵的值設為James,有效期為1秒

True

setrange(name, offset, value)

設定指定鍵的value值的子字串

name:鍵名;offset:偏移量;value:值

redis.set('name', 'Hello') redis.setrange('name', 6, 'World')

設定nameHello字串,並在index為6的位置補World

11,修改後的字串長度

mset(mapping)

批量賦值

mapping:字典

redis.mset({'name1': 'Durant', 'name2': 'James'})

name1設為Durantname2設為James

True

msetnx(mapping)

鍵均不存在時才批量賦值

mapping:字典

redis.msetnx({'name3': 'Smith', 'name4': 'Curry'})

name3name4均不存在的情況下才設定二者值

True

incr(name, amount=1)

鍵為namevalue增值操作,預設為1,鍵不存在則被建立並設為amount

name:鍵名;amount:增長的值

redis.incr('age', 1)

age對應的值增1,若不存在,則會建立並設定為1

1,即修改後的值

decr(name, amount=1)

鍵為namevalue減值操作,預設為1,鍵不存在則被建立並將value設定為-amount

name:鍵名; amount:減少的值

redis.decr('age', 1)

age對應的值減1,若不存在,則會建立並設定為-1

-1,即修改後的值

append(key, value)

鍵為namestring的值附加value

key:鍵名

redis.append('nickname', 'OK')

向鍵為nickname的值後追加OK

13,即修改後的字串長度

substr(name, start, end=-1)

返回鍵為namestring的子串

name:鍵名;start:起始索引;end:終止索引,預設為-1,表示擷取到末尾

redis.substr('name', 1, 4)

返回鍵為name的值的字串,擷取索引為1~4的字元

b'ello'

getrange(key, start, end)

獲取鍵的value值從startend的子字串

key:鍵名;start:起始索引;end:終止索引

redis.getrange('name', 1, 4)

返回鍵為name的值的字串,擷取索引為1~4的字元

b'ello'

## 列表操作 ##

Redis還提供了列表儲存,列表內的元素可以重複,而且可以從兩端儲存,用法如下表所示。

方法

作用

引數說明

示例

示例說明

示例結果

rpush(name, *values)

在鍵為name的列表末尾新增值為value的元素,可以傳多個

name:鍵名;values:值

redis.rpush('list', 1, 2, 3)

向鍵為list的列表尾新增1、2、3

3,列表大小

lpush(name, *values)

在鍵為name的列表頭新增值為value的元素,可以傳多個

name:鍵名;values:值

redis.lpush('list', 0)

向鍵為list的列表頭部新增0

4,列表大小

llen(name)

返回鍵為name的列表的長度

name:鍵名

redis.llen('list')

返回鍵為list的列表的長度

4

lrange(name, start, end)

返回鍵為name的列表中startend之間的元素

name:鍵名;start:起始索引;end:終止索引

redis.lrange('list', 1, 3)

返回起始索引為1終止索引為3的索引範圍對應的列表

[b'3', b'2', b'1']

ltrim(name, start, end)

擷取鍵為name的列表,保留索引為startend的內容

name:鍵名;start:起始索引;end:終止索引

ltrim('list', 1, 3)

保留鍵為list的索引為1到3的元素

True

lindex(name, index)

返回鍵為name的列表中index位置的元素

name:鍵名;index:索引

redis.lindex('list', 1)

返回鍵為list的列表索引為1的元素

b’2′

lset(name, index, value)

給鍵為name的列表中index位置的元素賦值,越界則報錯

name:鍵名;index:索引位置;value:值

redis.lset('list', 1, 5)

將鍵為list的列表中索引為1的位置賦值為5

True

lrem(name, count, value)

刪除count個鍵的列表中值為value的元素

name:鍵名;count:刪除個數;value:值

redis.lrem('list', 2, 3)

將鍵為list的列表刪除兩個3

1,即刪除的個數

lpop(name)

返回並刪除鍵為name的列表中的首元素

name:鍵名

redis.lpop('list')

返回並刪除名為list的列表中的第一個元素

b'5'

rpop(name)

返回並刪除鍵為name的列表中的尾元素

name:鍵名

redis.rpop('list')

返回並刪除名為list的列表中的最後一個元素

b'2'

blpop(keys, timeout=0)

返回並刪除名稱在keys中的list中的首個元素,如果列表為空,則會一直阻塞等待

keys:鍵列表;timeout: 超時等待時間,0為一直等待

redis.blpop('list')

返回並刪除鍵為list的列表中的第一個元素

[b'5']

brpop(keys, timeout=0)

返回並刪除鍵為name的列表中的尾元素,如果list為空,則會一直阻塞等待

keys:鍵列表;timeout:超時等待時間,0為一直等待

redis.brpop('list')

返回並刪除名為list的列表中的最後一個元素

[b'2']

rpoplpush(src, dst)

返回並刪除名稱為src的列表的尾元素,並將該元素新增到名稱為dst的列表頭部

src:源列表的鍵;dst:目標列表的key

redis.rpoplpush('list', 'list2')

將鍵為list的列表尾元素刪除並將其新增到鍵為list2的列表頭部,然後返回

b'2'

## 集合操作 ##

Redis還提供了集合儲存,集合中的元素都是不重複的,用法如下表所示。

方法

作用

引數說明

示例

示例說明

示例結果

sadd(name, *values)

向鍵為name的集合中新增元素

name:鍵名;values:值,可為多個

redis.sadd('tags', 'Book', 'Tea', 'Coffee')

向鍵為tags的集合中新增BookTeaCoffee這3個內容

3,即插入的資料個數

srem(name, *values)

從鍵為name的集合中刪除元素

name:鍵名;values:值,可為多個

redis.srem('tags', 'Book')

從鍵為tags的集合中刪除Book

1,即刪除的資料個數

spop(name)

隨機返回並刪除鍵為name的集合中的一個元素

name:鍵名

redis.spop('tags')

從鍵為tags的集合中隨機刪除並返回該元素

b'Tea'

smove(src, dst, value)

src對應的集合中移除元素並將其新增到dst對應的集合中

src:源集合;dst:目標集合;value:元素值

redis.smove('tags', 'tags2', 'Coffee')

從鍵為tags的集合中刪除元素Coffee並將其新增到鍵為tags2的集合

True

scard(name)

返回鍵為name的集合的元素個數

name:鍵名

redis.scard('tags')

獲取鍵為tags的集合中的元素個數

3

sismember(name, value)

測試member是否是鍵為name的集合的元素

name:鍵值

redis.sismember('tags', 'Book')

判斷Book是否是鍵為tags的集合元素

True

sinter(keys, *args)

返回所有給定鍵的集合的交集

keys:鍵列表

redis.sinter(['tags', 'tags2'])

返回鍵為tags的集合和鍵為tags2的集合的交集

{b'Coffee'}

sinterstore(dest, keys, *args)

求交集並將交集儲存到dest的集合

dest:結果集合;keys:鍵列表

redis.sinterstore('inttag', ['tags', 'tags2'])

求鍵為tags的集合和鍵為tags2的集合的交集並將其儲存為inttag

1

sunion(keys, *args)

返回所有給定鍵的集合的並集

keys:鍵列表

redis.sunion(['tags', 'tags2'])

返回鍵為tags的集合和鍵為tags2的集合的並集

{b'Coffee', b'Book', b'Pen'}

sunionstore(dest, keys, *args)

求並集並將並集儲存到dest的集合

dest:結果集合;keys:鍵列表

redis.sunionstore('inttag', ['tags', 'tags2'])

求鍵為tags的集合和鍵為tags2的集合的並集並將其儲存為inttag

3

sdiff(keys, *args)

返回所有給定鍵的集合的差集

keys:鍵列表

redis.sdiff(['tags', 'tags2'])

返回鍵為tags的集合和鍵為tags2的集合的差集

{b'Book', b'Pen'}

sdiffstore(dest, keys, *args)

求差集並將差集儲存到dest集合

dest:結果集合;keys:鍵列表

redis.sdiffstore('inttag', ['tags', 'tags2'])

求鍵為tags的集合和鍵為tags2的集合的差集並將其儲存為inttag`

3

smembers(name)

返回鍵為name的集合的所有元素

name:鍵名

redis.smembers('tags')

返回鍵為tags的集合的所有元素

{b'Pen', b'Book', b'Coffee'}

srandmember(name)

隨機返回鍵為name的集合中的一個元素,但不刪除元素

name:鍵值

redis.srandmember('tags')

隨機返回鍵為tags的集合中的一個元素

## 有序集合操作 ##

有序集合比集合多了一個分數字段,利用它可以對集合中的資料進行排序,其用法總結如下表所示。

方法

作用

引數說明

示例

示例說明

示例結果

zadd(name, *args, **kwargs)

向鍵為name的zset中新增元素member,score用於排序。如果該元素存在,則更新其順序

name: 鍵名;args:可變引數

redis.zadd('grade', 100, 'Bob', 98, 'Mike')

向鍵為grade的zset中新增Bob(其score為100),並新增Mike(其score為98)

2,即新增的元素個數

zrem(name, *values)

刪除鍵為name的zset中的元素

name:鍵名;values:元素

redis.zrem('grade', 'Mike')

從鍵為grade的zset中刪除Mike

1,即刪除的元素個數

zincrby(name, value, amount=1)

如果在鍵為name的zset中已經存在元素value,則將該元素的score增加amount;否則向該集合中新增該元素,其score的值為amount

name:key名;value:元素;amount:增長的score

redis.zincrby('grade', 'Bob', -2)

鍵為grade的zset中Bobscore減2

98.0,即修改後的值

zrank(name, value)

返回鍵為name的zset中元素的排名,按score從小到大排序,即名次

name:鍵名;value:元素值

redis.zrank('grade', 'Amy')

得到鍵為grade的zset中Amy的排名

1

zrevrank(name, value)

返回鍵為name的zset中元素的倒數排名(按score從大到小排序),即名次

name:鍵名;value:元素值

redis.zrevrank('grade', 'Amy')

得到鍵為grade的zset中Amy的倒數排名

2

zrevrange(name, start, end, withscores=False)

返回鍵為name的zset(按score從大到小排序)中indexstartend的所有元素

name:鍵值;start:開始索引;end:結束索引;withscores:是否帶score

redis.zrevrange('grade', 0, 3)

返回鍵為grade的zset中前四名元素

[b'Bob', b'Mike', b'Amy', b'James']

zrangebyscore(name, min, max, start=None, num=None, withscores=False)

返回鍵為name的zset中score在給定區間的元素

name:鍵名;min:最低scoremax:最高scorestart:起始索引;num:個數;withscores:是否帶score

redis.zrangebyscore('grade', 80, 95)

返回鍵為grade的zset中score在80和95之間的元素

[b'Bob', b'Mike', b'Amy', b'James']

zcount(name, min, max)

返回鍵為name的zset中score在給定區間的數量

name:鍵名;min:最低score;max:最高score

redis.zcount('grade', 80, 95)

返回鍵為grade的zset中score在80到95的元素個數

2

zcard(name)

返回鍵為name的zset的元素個數

name:鍵名

redis.zcard('grade')

獲取鍵為grade的zset中元素的個數

3

zremrangebyrank(name, min, max)

刪除鍵為name的zset中排名在給定區間的元素

name:鍵名;min:最低位次;max:最高位次

redis.zremrangebyrank('grade', 0, 0)

刪除鍵為grade的zset中排名第一的元素

1,即刪除的元素個數

zremrangebyscore(name, min, max)

刪除鍵為name的zset中score在給定區間的元素

name:鍵名;min:最低scoremax:最高score

redis.zremrangebyscore('grade', 80, 90)

刪除score在80到90之間的元素

1,即刪除的元素個數

## 雜湊操作 ##

Redis還提供了散列表的資料結構,我們可以用name指定一個散列表的名稱,表記憶體儲了各個鍵值對,用法總結如下表所示。

表5-10 雜湊操作

方法

作用

引數說明

示例

示例說明

示例結果

hset(name, key, value)

向鍵為name的散列表中新增對映

name:鍵名;key:對映鍵名;value:對映鍵值

hset('price', 'cake', 5)

向鍵為price的散列表中新增對映關係,cake的值為5

1,即新增的對映個數

hsetnx(name, key, value)

如果對映鍵名不存在,則向鍵為name的散列表中新增對映

name:鍵名;key:對映鍵名;value:對映鍵值

hsetnx('price', 'book', 6)

向鍵為price的散列表中新增對映關係,book的值為6

1,即新增的對映個數

hget(name, key)

返回鍵為name的散列表中key對應的值

name:鍵名;key:對映鍵名

redis.hget('price', 'cake')

獲取鍵為price的散列表中鍵名為cake的值

5

hmget(name, keys, *args)

返回鍵為name的散列表中各個鍵對應的值

name:鍵名;keys:對映鍵名列表

redis.hmget('price', ['apple', 'orange'])

獲取鍵為price的散列表中appleorange的值

[b'3', b'7']

hmset(name, mapping)

向鍵為name的散列表中批量新增對映

name:鍵名;mapping:對映字典

redis.hmset('price', {'banana': 2, 'pear': 6})

向鍵為price的散列表中批量新增對映

True

hincrby(name, key, amount=1)

將鍵為name的散列表中對映的值增加amount

name:鍵名;key:對映鍵名;amount:增長量

redis.hincrby('price', 'apple', 3)

keyprice的散列表中apple的值增加3

6,修改後的值

hexists(name, key)

鍵為name的散列表中是否存在鍵名為鍵的對映

name:鍵名;key:對映鍵名

redis.hexists('price', 'banana')

鍵為price的散列表中banana的值是否存在

True

hdel(name, *keys)

在鍵為name的散列表中,刪除鍵名為鍵的對映

name:鍵名;keys:對映鍵名

redis.hdel('price', 'banana')

從鍵為price的散列表中刪除鍵名為banana的對映

True

hlen(name)

從鍵為name的散列表中獲取對映個數

name: 鍵名

redis.hlen('price')

從鍵為price的散列表中獲取對映個數

6

hkeys(name)

從鍵為name的散列表中獲取所有對映鍵名

name:鍵名

redis.hkeys('price')

從鍵為price的散列表中獲取所有對映鍵名

[b'cake', b'book', b'banana', b'pear']

hvals(name)

從鍵為name的散列表中獲取所有對映鍵值

name:鍵名

redis.hvals('price')

從鍵為price的散列表中獲取所有對映鍵值

[b'5', b'6', b'2', b'6']

hgetall(name)

從鍵為name的散列表中獲取所有對映鍵值對

name:鍵名

redis.hgetall('price')

從鍵為price的散列表中獲取所有對映鍵值對

{b'cake': b'5', b'book': b'6', b'orange': b'7', b'pear': b'6'}

[表格來源:https://cuiqingcai.com/5587.html ]