Redis 操做

Python操做Redis

安裝

pip install redis

連接方式

簡單鏈接

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

import redis

r = redis.Redis()  # 默認連本地
# r = redis.Redis(host='11.12.13.14', port=6379)  # 可配置要鏈接的IP和端口
r.set('name', 'q1mi')
print(r.get('name'))

鏈接池

推薦用鏈接池的方式；若是每次操做都用同一個連接，能夠用鏈接池連接

redis使用connection pool來管理對一個redis服務的全部鏈接，避免每次創建，釋放鏈接的開銷。

默認 ，每一個redis實例都會維護一個本身的連接池。

能夠直接創建一個鏈接池，而後做爲參數redis，這樣就能夠實現多個redis實例共享一個鏈接池。

#鏈接池
import redis
pool = redis.ConnectionPool(host='10.0.0.200',port=6379)
conn = redis.Redis(connection_pool=pool)

conn.set('a','lalla')
print(conn.get('a'))

Django-redis組件

安裝

pip install django-redis

配置

CACHES = {
    "default": {
        "BACKEND": "django_redis.cache.RedisCache",
        "LOCATION": "redis://10.0.0.200:6379",
        "OPTIONS": {
            "CLIENT_CLASS": "django_redis.client.DefaultClient",
            #"PASSWORD": "asdfasdf",
　　　　　　  "CONNECTION_POOL_KWARGS": {"max_connections": 100}， # 連接池最大連接數量

        }
    }
}

使用

#利用django-redis組件進行鏈接
from django.core.cache import caches
import os
import django_redis
os.environ['DJANGO_SETTINGS_MODULE'] = 'redis之集合練習.settings'

conn = django_redis.get_redis_connection()
conn.set('b','666') # 加入值
conn.set("key", "value", timeout=None) # 設置超時時間，0 當即過時，None 永不過時
conn.flushall() # 清除全部數據

更加詳細的使用詳見 官方說明

字符串操做

String操做，redis中的String在在內存中按照一個name對應一個value來存儲。

設置值

在Redis中設置值，默認，不存在則建立，存在則修改

set(name, value, ex=None, px=None, nx=False, xx=False)  #設置值

     ex，過時時間（秒）
     px，過時時間（毫秒）
     nx，若是設置爲True，則只有name不存在時，當前set操做才執行
     xx，若是設置爲True，則只有name存在時，崗前set操做才執行

批量設置值

mset(*args, **kwargs)

 mset(k1='v1', k2='v2')
 mset({'k1': 'v1', 'k2': 'v2'})

獲取值

get(name)  # 獲取值

批量獲取值

mget(keys, *args)

mget('ylr', 'zzz')
r.mget(['ylr', 'zzz'])

獲取原值重設新值

getset(name, value) 

切片

getrange(key, start, end)

# 獲取子序列（根據字節獲取，非字符）
# 參數：
    # name，Redis 的 name
    # start，起始位置（字節）
    # end，結束位置（字節）
# 如： "拉銷量" ，0-3表示 "拉"

HASH 操做

 Hash操做，也叫作散列表操做。redis中Hash在內存中的存儲格式以下圖：

 

設置值

hset(name, key, value)

# name對應的hash中設置一個鍵值對（不存在，則建立；不然，修改）
 
# 參數：
    # name，redis的name
    # key，name對應的hash中的key
    # value，name對應的hash中的value
 
# 注：
    # hsetnx(name, key, value),當name對應的hash中不存在當前key時則建立（至關於添加）

批量設置值

hmset(name, mapping)

# 在name對應的hash中批量設置鍵值對
 
# 參數：
    # name，redis的name
    # mapping，字典，如：{'k1':'v1', 'k2': 'v2'}
 
# 如：
    # r.hmset('xx', {'k1':'v1', 'k2': 'v2'})

 獲取指定值

在name對應的hash中獲取根據key獲取value

hget(name,key)

 批量獲取指定值

hmget(name, keys, *args)

# 在name對應的hash中獲取多個key的值
 
# 參數：
    # name，reids對應的name
    # keys，要獲取key集合，如：['k1', 'k2', 'k3']
    # *args，要獲取的key，如：k1,k2,k3
 
# 如：
    # r.mget('xx', ['k1', 'k2'])
    # 或
    # print r.hmget('xx', 'k1', 'k2')

 獲取全部鍵值

獲取name對應的hash中的全部鍵值

hgetall(name)

 獲取長度

獲取name對應的hash中鍵值對的個數

hlen(name) 

 獲取指定key 值

獲取name對應的hash中全部的key的值

hkeys(name)

獲取指定key 對應值

 獲取name對應的hash中全部的value的值

hvals(name)

 檢查是否存在指定key

檢查name對應的hash是否存在當前傳入的key

hexists(name, key) 

 刪除指定鍵值對

 將name對應的hash中指定key的鍵值對刪除

hdel(name,*keys)

 指定值簡單運算操做

 指定值+1

 原來的值自加1

hincrby(name, key, amount=1) 

  指定值-1

 原來的值自減1

hincrby ('xxx','slex',amount=-1) 

# 自增name對應的hash中的指定key的值，不存在則建立key=amount
# 參數：
    # name，redis中的name
    # key， hash對應的key
    # amount，自增數（整數）

 支持浮點型運算操做

hincrbyfloat(name, key, amount=1.0)

增量式迭代獲取

方式1

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', cursor=0, match=None, count=None)
    # 第二次：cursor2, data1 = r.hscan('xx', cursor=cursor1, match=None, count=None)
    # ...
    # 直到返回值cursor的值爲0時，表示數據已經經過分片獲取完畢

 方式2

hscan_iter(name, match=None, count=None)

# 利用yield封裝hscan建立生成器，實現分批去redis中獲取數據
 
# 參數：
    # match，匹配指定key，默認None 表示全部的key
    # count，每次分片最少獲取個數，默認None表示採用Redis的默認分片個數
 
# 如：
    # for item in r.hscan_iter('xx'):
    #     print item

　　# for item in r.hscan_iter('xx',match='*lx'):  #匹配以lx結尾的
   #     print item

List操做

redis中的List在在內存中按照一個name對應一個List來存儲。如圖：

 左右添加

lpush(name,values)

# 在name對應的list中添加元素，每一個新的元素都添加到列表的最左邊
 
# 如：
    # r.lpush('oo', 11,22,33)
    # 保存順序爲: 33,22,11
 
# 擴展：
    # rpush(name, values) 表示從右向左操做

指定位置添加

linsert(name, where, refvalue, value))

# 在name對應的列表的某一個值前或後插入一個新值
 
# 參數：
    # name，redis的name
    # where，BEFORE或AFTER
    # refvalue，標杆值，即：在它先後插入數據
    # value，要插入的數據

指定位置從新賦值

r.lset(name, index, value)

# 對name對應的list中的某一個索引位置從新賦值
 
# 參數：
    # name，redis的name
    # index，list的索引位置
    # value，要設置的值

刪除指定長度值

r.lrem(name, value, num)

# 在name對應的list中刪除指定的值
 
# 參數：
    # name，redis的name
    # value，要刪除的值
    # num，  num=0，刪除列表中全部的指定值；
           # num=2,從前到後，刪除2個；
           # num=-2,從後向前，刪除2個

切片獲取

lrange(name, start, end)

# 在name對應的列表分片獲取數據
# 參數：
    # name，redis的name
    # start，索引的起始位置
    # end，索引結束位置

刪除指定長度外的值

ltrim(name, start, end)

# 在name對應的列表中移除沒有在start-end索引之間的值
# 參數：
    # name，redis的name
    # start，索引的起始位置
    # end，索引結束位置

左右彈出值

lpop(name)

# 在name對應的列表的左側獲取第一個元素並在列表中移除，返回值則是第一個元素
 
# 更多：
    # rpop(name) 表示從右向左操做

根據索引查看值

lindex(name, index)

查看個數

name對應的list元素的個數

llen(name)

 自定義增量迭代

# 因爲redis類庫中沒有提供對列表元素的增量迭代，若是想要循環name對應的列表的全部元素，那麼就須要：
    # 一、獲取name對應的全部列表
    # 二、循環列表
# 可是，若是列表很是大，那麼就有可能在第一步時就將程序的內容撐爆，全部有必要自定義一個增量迭代的功能：
 
def list_iter(name):
    """
    自定義redis列表增量迭代
    :param name: redis中的name，即：迭代name對應的列表
    :return: yield 返回 列表元素
    """
    list_count = r.llen(name)
    for index in xrange(list_count):
        yield r.lindex(name, index)
 
# 使用
for item in list_iter('pp'):
    print item

集合操做

Set集合就是不容許重複的列表

添加元素

 name對應的集合中添加元素

sadd(name,values)

獲取集合長度

獲取name對應的集合中元素個數

scard(name)

交併補集操做

在第一個name對應的集合中且不在其餘name對應的集合的元素集合

sdiff(keys, *args)

獲取第一個name對應的集合中且不在其餘name對應的集合，再將其新加入到dest對應的集合中

sdiffstore(dest, keys, *args)

獲取多一個name對應集合的並集

sinter(keys, *args)

 獲取多一個name對應集合的並集，再講其加入到dest對應的集合中

sinterstore(dest, keys, *args)

 獲取多一個name對應的集合的並集

sunion(keys, *args)

獲取多一個name對應的集合的並集，並將結果保存到dest對應的集合中

sunionstore(dest,keys, *args)

檢查元素

 檢查value是不是name對應的集合的成員

sismember(name, value)

獲取全部元素

獲取name對應的集合的全部成員

smembers(name)

移動元素

將某個成員從一個集合中移動到另一個集合

smove(src, dst, value)

彈出元素

 從集合的右側（尾部）移除一個成員，並將其返回

spop(name)

隨機獲取指定數目元素

 從name對應的集合中隨機獲取 numbers 個元素

srandmember(name, numbers)

刪除指定元素

 在name對應的集合中刪除某些值

srem(name, values)

增量迭代

 同字符串的操做，用於增量迭代分批獲取元素，避免內存消耗太大

sscan(name, cursor=0, match=None, count=None)
sscan_iter(name, match=None, count=None)

 有序集合操做

 有序集合，在集合的基礎上，爲每元素排序；元素的排序須要根據另一個值來進行比較，因此，對於有序集合，每個元素有兩個值，即：值和分數，分數專門用來作排序。

添加元素

zadd(name, *args, **kwargs)

# 在name對應的有序集合中添加元素
# 如：
# zadd('zz', 'n1', 1, 'n2', 2)
# 或
# zadd('zz', n1=11, n2=22)

獲取元素數量 

獲取name對應的有序集合元素的數量

zcard(name)

獲取指定分數區間的元素

獲取name對應的有序集合中分數 在 [min,max] 之間的個數

zcount(name, min, max)

獲取元素分數

自增name對應的有序集合的 name 對應的分數

zincrby(name, value, amount)

 獲取name對應有序集合中 value 對應的分數

zscore(name, value)

獲取索引範圍元素

按照索引範圍獲取name對應的有序集合的元素

r.zrange( name, start, end, desc=False, withscores=False, score_cast_func=float)

# 按照索引範圍獲取name對應的有序集合的元素

# 參數：
# name，redis的name
# start，有序集合索引發始位置（非分數）
# end，有序集合索引結束位置（非分數）
# desc，排序規則，默認按照分數從小到大排序
# withscores，是否獲取元素的分數，默認只獲取元素的值
# score_cast_func，對分數進行數據轉換的函數

# 更多：
# 從大到小排序
# zrevrange(name, start, end, withscores=False, score_cast_func=float)

# 按照分數範圍獲取name對應的有序集合的元素
# zrangebyscore(name, min, max, start=None, num=None, withscores=False, score_cast_func=float)
# 從大到小排序
# zrevrangebyscore(name, max, min, start=None, num=None, withscores=False, score_cast_func=float)

獲取指定值排行

獲取某個值在 name對應的有序集合中的排行（從 0 開始）

zrank(name, value)

# 更多：
# zrevrank(name, value)，從大到小排序

字節排序

zrangebylex(name, min, max, start=None, num=None)

# 當有序集合的全部成員都具備相同的分值時，有序集合的元素會根據成員的 值 （lexicographical ordering）來進行排序，而這個命令則能夠返回給定的有序集合鍵 key 中， 元素的值介於 min 和 max 之間的成員
# 對集合中的每一個成員進行逐個字節的對比（byte-by-byte compare）， 並按照從低到高的順序， 返回排序後的集合成員。 若是兩個字符串有一部份內容是相同的話， 那麼命令會認爲較長的字符串比較短的字符串要大

# 參數：
# name，redis的name
# min，左區間（值）。 + 表示正無限； - 表示負無限； ( 表示開區間； [ 則表示閉區間
# min，右區間（值）
# start，對結果進行分片處理，索引位置
# num，對結果進行分片處理，索引後面的num個元素

# 如：
# ZADD myzset 0 aa 0 ba 0 ca 0 da 0 ea 0 fa 0 ga
# r.zrangebylex('myzset', "-", "[ca") 結果爲：['aa', 'ba', 'ca']

# 更多：
# 從大到小排序
# zrevrangebylex(name, max, min, start=None, num=None)

 刪除指定元素

 刪除name對應的有序集合中值是values的成員

zrem(name, values)

# 如：zrem('zz', ['s1', 's2'])

刪除排行範圍元素

根據排行範圍刪除

zremrangebyrank(name, min, max)

刪除分數範圍元素

 根據分數範圍刪除

zremrangebyscore(name, min, max)

返回值刪除

 根據值返回刪除

zremrangebylex(name, min, max)

獲取並集

zinterstore(dest, keys, aggregate=None)

# 獲取兩個有序集合的交集，若是遇到相同值不一樣分數，則按照aggregate進行操做
# aggregate的值爲: SUM MIN MAX

增量操做

同字符串類似，相較於字符串新增score_cast_func，用來對分數進行操做

zscan(name, cursor=0, match=None, count=None, score_cast_func=float)
zscan_iter(name, match=None, count=None,score_cast_func=float)

 其餘操做

delete(*names)

1	# 根據刪除redis中的任意數據類型

exists(name)

1	# 檢測redis的name是否存在

keys(pattern='*')

1 2 3 4 5 6 7

# 根據模型獲取redis的name   # 更多：      # KEYS * 匹配數據庫中全部 key 。      # KEYS h?llo 匹配 hello ， hallo 和 hxllo 等。      # KEYS h*llo 匹配 hllo 和 heeeeello 等。      # KEYS h[ae]llo 匹配 hello 和 hallo ，但不匹配 hillo

expire(name ,time)

1	# 爲某個redis的某個name設置超時時間

rename(src, dst)

1	# 對redis的name重命名爲

move(name, db))

1	# 將redis的某個值移動到指定的db下

randomkey()

1	# 隨機獲取一個redis的name（不刪除）

type(name)

1	# 獲取name對應值的類型

scan(cursor=0, match=None, count=None)
scan_iter(match=None, count=None)

1	# 同字符串操做，用於增量迭代獲取key