安裝和使用

安裝

安裝redis模組

pip3 install redis

普通連線

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

import redis
conn = redis.Redis(host='127.0.0.1',port=6379)
# 可以使用url方式連線到資料庫
# conn = Redis.from_url('redis://@localhost:6379/1')
conn.set('name','LinWOW')
print(conn.get('name'))
 

連線池

redis-py使用connection pool來管理對一個redis server的所有連線，避免每次建立、釋放連線的開銷。預設，每個Redis例項都會維護一個自己的連線池。可以直接建立一個連線池，然後作為引數Redis，這樣就可以實現多個Redis例項共享一個連線池

連線池：redis_pool.py

from redis import ConnectionPool
POOL=ConnectionPool(host='127.0.0.1',port=6379,max_connections=100)

使用連線池：test_redis.py

import redis
from redis_pool import POOl
conn = redis.Redis(connection_pool=POOl)
conn.set('name','LinWOW')
print(conn.get('name'))
 

構造url方式連線到資料庫，有以下三種模式：

redis://[:password]@host:port/db    # TCP連線
rediss://[:password]@host:port/db   # Redis TCP+SSL 連線
unix://[:password]@/path/to/socket.sock?db=db    # Redis Unix Socket 連線

Python操作Redis

String操作

Key操作

List操作

應用場景：

blpop實現簡單分散式爬蟲：

多個url放到列表裡，往裡不停放URL，程式迴圈取值，但是隻能一臺機器執行取值，可以把url放到redis中，多臺機器從redis中取值，爬取資料，實現簡單分散式

將多個列表排列，按照從左到右去pop對應列表的元素
引數：
    keys，redis的name的集合
    timeout，超時時間，當元素所有列表的元素獲取完之後，阻塞等待列表內有資料的時間（秒）,0 表示永遠阻塞
更多：
    r.brpop(keys,timeout)，從右向左獲取資料
 

自定義增量迭代：

由於redis類庫中沒有提供對列表元素的增量迭代，如果想要迴圈name對應的列表的所有元素，那麼就需要：
    1、獲取name對應的所有列表
    2、迴圈列表
但是，如果列表非常大，那麼就有可能在第一步時就將程式的內容撐爆，所有有必要自定義一個增量迭代的功能：

import redis
conn=redis.Redis(host='127.0.0.1',port=6379)
# conn.lpush('test',*[1,3,4,45,5,7,8,43,768,89,9,65,23,54,6757,68])
# conn.flushall()
def scan_list(name,count=2):
    index=0
    while True:
        data_list=conn.lrange(name,count+index-1)
        if not data_list:
            return
        index+=count
        for item in data_list:
            yield item
print(conn.lrange('test',100))
for item in scan_list('test',5):
    print('---')
    print(item)

Set操作

Sorted Set操作

Hash操作

注意點：

hscan(name,cursor=0,match=None,count=None)：增量式迭代獲取，對於資料大的資料非常有用，hscan可以實現分片的獲取資料，並非一次性將資料全部獲取完，從而放置記憶體被撐爆

引數：
    name，redis的name
    cursor，遊標（基於遊標分批取獲取資料）
    match，匹配指定key，預設None 表示所有的key
    count，每次分片最少獲取個數，預設None表示採用Redis的預設分片個數
如：
    第一次：cursor1,data1 = r.hscan('xx',count=None)
    第二次：cursor2,cursor=cursor1,count=None)
    ...
    直到返回值cursor的值為0時，表示資料已經通過分片獲取完畢
 

hscan_iter(name,count=None)： 利用yield封裝hscan建立生成器，實現分批去redis中獲取資料

引數：
    match，匹配指定key，預設None 表示所有的key
    count，每次分片最少獲取個數，預設None表示採用Redis的預設分片個數
如：
    for item in r.hscan_iter('xx'):
        print item
 

管道

redis-py預設在執行每次請求都會建立（連線池申請連線）和斷開（歸還連線池）一次連線操作，如果想要在一次請求中指定多個命令，則可以使用pipline實現一次請求指定多個命令，並且預設情況下一次pipline 是原子性操作。

import redis
pool = redis.ConnectionPool(host='10.211.55.4',port=6379)
r = redis.Redis(connection_pool=pool)
# pipe = r.pipeline(transaction=False)
pipe = r.pipeline(transaction=True)
pipe.multi()
pipe.set('name','linwow')
pipe.set('age','18')
pipe.execute()

Django中使用redis

方式一：

utils資料夾下，建立redis_pool.py

import redis
POOL = redis.ConnectionPool(host='127.0.0.1',password='1234',max_connections=1000)

檢視函式中使用：

import redis
from django.shortcuts import render,HttpResponse
from redis_pool import POOL

def index(request):
    conn = redis.Redis(connection_pool=POOL)
    conn.hset('liwow','age',18)
    return HttpResponse('設定成功')
    
def order(request):
    conn = redis.Redis(connection_pool=POOL)
    conn.hget('kkk','age')
    return HttpResponse('獲取成功')

方式二：

安裝django-redis模組

pip3 install django-redis

setting裡配置：

# redis配置
CACHES = {
    "default": {
        "BACKEND": "django_redis.cache.RedisCache","LOCATION": "redis://127.0.0.1:6379","OPTIONS": {
            "CLIENT_CLASS": "django_redis.client.DefaultClient","CONNECTION_POOL_KWARGS": {"max_connections": 100}
            # "PASSWORD": "123",}
    }
}

檢視函式：

from django_redis import get_redis_connection
conn = get_redis_connection('default')
print(conn.hgetall('xxx'))