安裝
在終端環境下輸入:
pip install redis
pycharm操作redis之普通連接
# 1.匯入模塊
from redis import Redis
# 2.實體化產生鏈接物件
conn = Redis() # 連接本地的redis
# conn = Redis(host='',port='',password='',) 連接遠程的redis
# 3.獲取redis資料庫中鍵對應的值
ret = conn.get('name')
print(ret)
pycharm操作redis之鏈接池
# # 1.匯入模塊
import redis
#
# # 2.建一個連接池
# # max_connections指定池子里最多建100個連接
pool = redis.ConnectionPool(max_connections=100) # 這里還是一個不填host和port表示默認連接本地redis
#
# # 3.這句話表示:從池子中拿出一個連接
r = redis.Redis(connection_pool=pool)
ret = r.get('name')
print(ret)
# 但是一般我們會將連接池單獨放在一個模塊,當該模塊被匯入到其他py檔案時,就是一個連接物件
# 將上述代碼改為:
import redis
from t_pool import POOL #將連接池單獨放在一個模塊,每次匯入就是一個物件
r = redis.Redis(connection_pool=POOL)
ret = r.get('name')
print(ret)
pycharm操作redis之字串操作
重點:
set :很多引數
get
mset
mget
incr
decr
append
set的基本操作:
set(name, value, ex=None, px=None, nx=False, xx=False)
# conn.set('height',180) #基本使用
# conn.set('height','190',nx=True)
# conn.set('height','190',xx=True)
# conn.set('height1','190',xx=True)
'''
ex,過期時間(秒)
px,過期時間(毫秒)
nx,如果設定為True,則只有name不存在時,當前set操作才執行,值存在,就修改不了,執行沒效果
xx,如果設定為True,則只有name存在時,當前set操作才執行,值存在才能修改,值不存在,不會設定新值
'''
setnx(name, value)
設定值,只有name不存在時,執行設定操作(添加),如果存在,不會修改
setex(name, value, time)
# 設定值
# 引數:
# time,過期時間(數字秒 或 timedelta物件)
psetex(name, time_ms, value)
# 設定值
# 引數:
# time_ms,過期時間(數字毫秒 或 timedelta物件
mset(*args, **kwargs)
批量設定值
如:
mset(k1='v1', k2='v2')
或
mget({'k1': 'v1', 'k2': 'v2'})
get(name)
獲取值
mget(keys, *args)
批量獲取
如:
mget('k1', 'k2')
或
r.mget(['k3', 'k4'])
getset(name, value)
設定新值并獲取原來的值
getrange(key, start, end)
# 獲取子序列(根據位元組獲取,非字符)
# 引數:
# name,Redis 的 name
# start,起始位置(位元組)
# end,結束位置(位元組)
# 如: "劉清政" ,0-3表示 "劉"
setrange(name, offset, value)
# 修改字串內容,從指定字串索引開始向后替換(新值太長時,則向后添加)
# 引數:
# offset,字串的索引,位元組(一個漢字三個位元組)
# value,要設定的值
setbit(name, offset, value)
# 對name對應值的二進制表示的位進行操作
# 引數:
# name,redis的name
# offset,位的索引(將值變換成二進制后再進行索引)
# value,值只能是 1 或 0
# 注:如果在Redis中有一個對應: n1 = "foo",
那么字串foo的二進制表示為:01100110 01101111 01101111
所以,如果執行 setbit('n1', 7, 1),則就會將第7位設定為1,
那么最終二進制則變成 01100111 01101111 01101111,即:"goo"
getbit(name, offset)
# 獲取name對應的值的二進制表示中的某位的值 (0或1)
bitcount(key, start=None, end=None)
# 獲取name對應的值的二進制表示中 1 的個數
# 引數:
# key,Redis的name
# start,位起始位置
# end,位結束位置
incr(self, name, amount=1)
用來統計網站訪問量,頁面訪問量等
# 自增 name對應的值,當name不存在時,則創建name=amount,否則,則自增,
# 引數:
# name,Redis的name
# amount,自增數(必須是整數)
# 注:同incrby
decr(self, name, amount=1)
# 自減 name對應的值,當name不存在時,則創建name=amount,否則,則自減,
# 引數:
# name,Redis的name
# amount,自減數(整數)
append(key, value)
# 在redis name對應的值后面追加內容
# 引數:
key, redis的name
value, 要追加的字串
pycharm操作redis之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'})
hget(name,key)
# 在name對應的hash中獲取根據key獲取value
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')
hgetall(name)
# 獲取name對應hash的所有鍵值
hlen(name)
# 獲取name對應的hash中鍵值對的個數
hkeys(name)
# 獲取name對應的hash中所有的key的值
hvals(name)
# 獲取name對應的hash中所有的value的值
hexists(name, key)
# 檢查name對應的hash是否存在當前傳入的key
hdel(name,*keys)
# 將name對應的hash中指定key的鍵值對洗掉
print(re.hdel('xxx','sex','name'))
該方法會回傳洗掉的個數
hincrby(name, key, amount=1)
# 自增name對應的hash中的指定key的值,不存在則創建key=amount
# 引數:
# name,redis中的name
# key, hash對應的key
# amount,自增數(整數)
hscan_iter(name, match=None, count=None)
批量取資料,優先使用該方法,而不是hgetall
# 利用yield封裝hscan創建生成器,實作分批去redis中獲取資料
# 引數:
# match,匹配指定key,默認None 表示所有的key
# count,每次分片最少獲取個數,默認None表示采用Redis的默認分片個數
# 如:
# for item in r.hscan_iter('xx'):
# print item
pycharm操作redis之串列操作
List操作,redis中的List在在記憶體中按照一個name對應一個List來存盤,如圖:

lpush(name,values)
# 在name對應的list中添加元素,每個新的元素都添加到串列的最左邊
# 如:
# r.lpush('oo', 11,22,33)
# 保存順序為: 33,22,11
# 擴展:
# rpush(name, values) 表示從右向左操作
lpushx(name,value)
# 在name對應的list中添加元素,只有name已經存在時,值添加到串列的最左邊
# 更多:
# rpushx(name, value) 表示從右向左操作
llen(name)
# name對應的list元素的個數
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的索引位置 索引是從0開始
# value,要設定的值
r.lrem(name, count, value)
# 在name對應的list中洗掉指定的值
# 引數:
# name,redis的name
# value,要洗掉的值
# count, count=0,洗掉串列中所有的指定值;
# count=2,從前到后,洗掉2個;
# count=-2,從后向前,洗掉2個
lpop(name)
# 在name對應的串列的左側獲取第一個元素并在串列中移除,回傳值則是第一個元素
# 更多:
# rpop(name) 表示從右向左操作
lindex(name, index)
在name對應的串列中根據索引獲取串列元素
lrange(name, start, end)
# 在name對應的串列分片獲取資料
# 引數:
# name,redis的name
# start,索引的起始位置
# end,索引結束位置
ltrim(name, start, end)
# 在name對應的串列中移除沒有在start-end索引之間的值
# 引數:
# name,redis的name
# start,索引的起始位置
# end,索引結束位置(大于串列長度,則代表不移除任何)
rpoplpush(src, dst)
# 從一個串列取出最右邊的元素,同時將其添加至另一個串列的最左邊
# 引數:
# src,要取資料的串列的name
# dst,要添加資料的串列的name
blpop(keys, timeout)
# 將多個串列排列,按照從左到右去pop對應串列的元素
# 引數:
# keys,redis的name的集合
# timeout,超時時間,當元素所有串列的元素獲取完之后,阻塞等待串列內有資料的時間(秒), 0 表示永遠阻塞
# 更多:
# r.brpop(keys, timeout),從右向左獲取資料爬蟲實作簡單分布式:多個url放到串列里,往里不停放URL,程式回圈取值,但是只能一臺機器運行取值,可以把url放到redis中,多臺機器從redis中取值,爬取資料,實作簡單分布式
brpoplpush(src, dst, timeout=0)
# 從一個串列的右側移除一個元素并將其添加到另一個串列的左側
# 引數:
# src,取出并要移除元素的串列對應的name
# dst,要插入元素的串列對應的name
# timeout,當src對應的串列中沒有資料時,阻塞等待其有資料的超時時間(秒),0 表示永遠阻塞
pycharm操作redis之管道操作
redis-py默認在執行每次請求都會創建(連接池申請連接)和斷開(歸還連接池)一次連接操作,如果想要在一次請求中指定多個命令,則可以使用pipline實作一次請求指定多個命令,并且默認情況下一次pipline 是原子性操作,
import redis
pool = redis.ConnectionPool(host='10.211.55.4', port=6379)
conn = redis.Redis(connection_pool=pool)
# pipe = r.pipeline(transaction=False)
pipe = conn.pipeline(transaction=True) # 生成一個管道
pipe.multi()
pipe.set('name', 'alex')
pipe.set('role', 'sb')
pipe.execute() # 這句話才是真正的執行
其他操作
delete(*names)
# 根據洗掉redis中的任意資料型別
exists(name)
# 檢測redis的name是否存在
keys(pattern='*')
# 根據模型獲取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)
# 為某個redis的某個name設定超時時間
rename(src, dst)
# 對redis的name重命名為
move(name, db))
# 將redis的某個值移動到指定的db下
randomkey()
# 隨機獲取一個redis的name(不洗掉)
type(name)
# 獲取name對應值的型別
django中操作redis
方式一:
utils檔案夾下,建立redis_pool.py
import redis
POOL = redis.ConnectionPool(host='127.0.0.1', port=6379,password='1234',max_connections=1000)
在視圖函式中使用
import redis
from django.shortcuts import render,HttpResponse
from utils.redis_pool import POOL
def index(request):
conn = redis.Redis(connection_pool=POOL)
conn.hset('kkk','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",
}
}
}
在視圖函式中使用方法:
1.
from django_redis import get_redis_connection
conn = get_redis_connection('default') #相當于去上面settings配置的默認default中拿到一個連接
conn.set() # 以后就這樣使用就行
2.
正常操作cache
cache.set(key,value,過期時間秒)
cache.get(key)
轉載請註明出處,本文鏈接:https://www.uj5u.com/houduan/528045.html
標籤:Python
上一篇:安卓so ida動態除錯
