<em>Mac</em>Book项目 2009年学校开始实施<em>Mac</em>Book项目,所有师生配备一本<em>Mac</em>Book,并同步更新了校园无线网络。学校每周进行电脑技术更新,每月发送技术支持资料,极大改变了教学及学习方式。因此2011
2021-06-01 09:32:01
Redis是一個開源的基於記憶體也可持久化的Key-Value資料庫,採用ANSI C語言編寫。它擁有豐富的資料結構,擁有事務功能,保證命令的原子性。由於是記憶體資料庫,讀寫非常高速,可達10w/s的評率,所以一般應用於資料變化快、實時通訊、快取等。但記憶體資料庫通常要考慮機器的記憶體大小。
redis支援儲存的value型別有很多種,如string(字串)、list(連結串列)、set(集合)、zset(有序集合)和hash(雜湊型別)。
為了保證效率,資料都是快取在記憶體中。可以週期性的把更新的資料寫入磁碟或者把修改操作寫入追加檔案。Redis提供了Python,Ruby,Java,Php的使用者端,使用很方便,本文主要以Python來講解Redis的操作。
pip install redis
連線redis,加上decode_responses=True,寫入的鍵值對中的value為str型別,不加這個引數寫入的則為位元組型別。
import redis # 匯入redis模組,通過python操作redis 也可以直接在redis主機的伺服器端操作快取資料庫 r = redis.Redis(host='localhost', port=6379, decode_responses=True) # host是redis主機,需要redis伺服器端和使用者端都啟動 redis預設埠是6379 r.set('name', 'junxi') # key是"foo" value是"bar" 將鍵值對存入redis快取 print(r['name']) print(r.get('name')) # 取出鍵name對應的值 print(type(r.get('name')))
redis-py 使用 connection pool 來管理對一個 redis server 的所有連線,避免每次建立、釋放連線的開銷。
預設,每個Redis範例都會維護一個自己的連線池。可以直接建立一個連線池,然後作為引數 Redis,這樣就可以實現多個 Redis 範例共用一個連線池。
import redis # 匯入redis 模組 pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True) r = redis.Redis(host='localhost', port=6379, decode_responses=True) r.set('name', 'runoob') # 設定 name 對應的值 print(r.get('name')) # 取出鍵 name 對應的值
set(name, value, ex=None, px=None, nx=False, xx=False)
在 Redis 中設定值,預設,不存在則建立,存在則修改。
引數:
import redis pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True) r = redis.Redis(connection_pool=pool) r.set('food', 'mutton', ex=3) # key是"food" value是"mutton" 將鍵值對存入redis快取 print(r.get('food')) # mutton 取出鍵food對應的值
import redis pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True) r = redis.Redis(connection_pool=pool) r.set('food', 'beef', px=3) print(r.get('food'))
import redis pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True) r = redis.Redis(connection_pool=pool) print(r.set('fruit', 'watermelon', nx=True)) # True--不存在 # 如果鍵fruit不存在,那麼輸出是True;如果鍵fruit已經存在,輸出是None
print((r.set('fruit', 'watermelon', xx=True))) # True--已經存在 # 如果鍵fruit已經存在,那麼輸出是True;如果鍵fruit不存在,輸出是None
設定值,只有name不存在時,執行設定操作(新增)
print(r.setnx('fruit1', 'banana')) # fruit1不存在,輸出為True
設定值
引數:
time - 過期時間(數位秒 或 timedelta物件)
import redis import time pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True) r = redis.Redis(connection_pool=pool) r.setex("fruit2", 5, "orange") time.sleep(5) print(r.get('fruit2')) # 5秒後,取值就從orange變成None
設定值
引數:
time_ms - 過期時間(數位毫秒 或 timedelta物件)
r.psetex("fruit3", 5000, "apple") time.sleep(5) print(r.get('fruit3')) # 5000毫秒後,取值就從apple變成None
批次設定值
如:
r.mget({'k1': 'v1', 'k2': 'v2'}) r.mset(k1="v1", k2="v2") # 這裡k1 和k2 不能帶引號,一次設定多個鍵值對 print(r.mget("k1", "k2")) # 一次取出多個鍵對應的值 print(r.mget("k1"))
批次獲取
如:
print(r.mget('k1', 'k2')) print(r.mget(['k1', 'k2'])) print(r.mget("fruit", "fruit1", "fruit2", "k1", "k2")) # 將目前redis快取中的鍵對應的值批次取出來
設定新值並獲取原來的值
print(r.getset("food", "barbecue")) # 設定的新值是barbecue 設定前的值是beef
獲取子序列(根據位元組獲取,非字元)
引數:
如: "君惜大大" ,0-3表示 "君"
r.set("cn_name", "君惜大大") # 漢字 print(r.getrange("cn_name", 0, 2)) # 取索引號是0-2 前3位的位元組 君 切片操作 (一個漢字3個位元組 1個字母一個位元組 每個位元組8bit) print(r.getrange("cn_name", 0, -1)) # 取所有的位元組 君惜大大 切片操作 r.set("en_name","junxi") # 字母 print(r.getrange("en_name", 0, 2)) # 取索引號是0-2 前3位的位元組 jun 切片操作 (一個漢字3個位元組 1個字母一個位元組 每個位元組8bit) print(r.getrange("en_name", 0, -1)) # 取所有的位元組 junxi 切片操作
修改字串內容,從指定字串索引開始向後替換(新值太長時,則向後新增)
引數:
r.setrange("en_name", 1, "ccc") print(r.get("en_name")) # jccci 原始值是junxi 從索引號是1開始替換成ccc 變成 jccci
對 name 對應值的二進位制表示的位進行操作
引數:
注:如果在Redis中有一個對應: n1 = "foo",
那麼字串foo的二進位制表示為:01100110 01101111 01101111
所以,如果執行 setbit('n1', 7, 1),則就會將第7位設定為1,
那麼最終二進位制則變成 01100111 01101111 01101111,即:"goo"
擴充套件,轉換二進位制表示:
source = "陳思維" source = "foo" for i in source: num = ord(i) print bin(num).replace('b','')
特別的,如果source是漢字 "陳思維"怎麼辦?
答:對於utf-8,每一個漢字佔 3 個位元組,那麼 "陳思維" 則有 9個位元組 對於漢字,for迴圈時候會按照 位元組 迭代,那麼在迭代時,將每一個位元組轉換 十進位制數,然後再將十進位制數轉換成二進位制 11100110 10101101 10100110 11100110 10110010 10011011 11101001 10111101 10010000
獲取name對應的值的二進位制表示中的某位的值 (0或1)
print(r.getbit("foo1", 0)) # 0 foo1 對應的二進位制 4個位元組 32位元 第0位是0還是1
獲取name對應的值的二進位制表示中 1 的個數
引數:
print(r.get("foo")) # goo1 01100111 print(r.bitcount("foo",0,1)) # 11 表示前2個位元組中,1出現的個數
獲取多個值,並將值做位運算,將最後的結果儲存至新的name對應的值
引數:
如:
bitop("AND", 'new_name', 'n1', 'n2', 'n3')
獲取Redis中n1,n2,n3對應的值,然後講所有的值做位運算(求並集),然後將結果儲存 new_name 對應的值中
r.set("foo","1") # 0110001 r.set("foo1","2") # 0110010 print(r.mget("foo","foo1")) # ['goo1', 'baaanew'] print(r.bitop("AND","new","foo","foo1")) # "new" 0 0110000 print(r.mget("foo","foo1","new")) source = "12" for i in source: num = ord(i) print(num) # 列印每個字母字元或者漢字字元對應的ascii碼值 f-102-0b100111-01100111 print(bin(num)) # 列印每個10進位制ascii碼值轉換成二進位制的值 0b1100110(0b表示二進位制) print bin(num).replace('b','') # 將二進位制0b1100110替換成01100110
返回name對應值的位元組長度(一個漢字3個位元組)
print(r.strlen("foo")) # 4 'goo1'的長度是4
自增 name 對應的值,當 name 不存在時,則建立 name=amount,否則,則自增。
引數:
注:同 incrby
r.set("foo", 123) print(r.mget("foo", "foo1", "foo2", "k1", "k2")) r.incr("foo", amount=1) print(r.mget("foo", "foo1", "foo2", "k1", "k2"))
應用場景 – 頁面點選數
假定我們對一系列頁面需要記錄點選次數。例如論壇的每個貼文都要記錄點選次數,而點選次數比回帖的次數的多得多。如果使用關聯式資料庫來儲存點選,可能存在大量的行級鎖爭用。所以,點選數的增加使用redis的INCR命令最好不過了。
當redis伺服器啟動時,可以從關聯式資料庫讀入點選數的初始值(12306這個頁面被存取了34634次)
r.set("visit:12306:totals", 34634) print(r.get("visit:12306:totals"))
每當有一個頁面點選,則使用INCR增加點選數即可。
r.incr("visit:12306:totals") r.incr("visit:12306:totals")
頁面載入的時候則可直接獲取這個值
print(r.get("visit:12306:totals"))
自增 name對應的值,當name不存在時,則建立name=amount,否則,則自增。
引數:
r.set("foo1", "123.0") r.set("foo2", "221.0") print(r.mget("foo1", "foo2")) r.incrbyfloat("foo1", amount=2.0) r.incrbyfloat("foo2", amount=3.0) print(r.mget("foo1", "foo2"))
自減 name 對應的值,當 name 不存在時,則建立 name=amount,否則,則自減。
引數:
r.decr("foo4", amount=3) # 遞減3 r.decr("foo1", amount=1) # 遞減1 print(r.mget("foo1", "foo4"))
在redis name對應的值後面追加內容
引數:
r.append("name", "haha") # 在name對應的值junxi後面追加字串haha print(r.mget("name"))
hset(name, key, value)
name對應的hash中設定一個鍵值對(不存在,則建立;否則,修改)
引數:
注:hsetnx(name, key, value) 當name對應的hash中不存在當前key時則建立(相當於新增)
import redis import time pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True) r = redis.Redis(connection_pool=pool) r.hset("hash1", "k1", "v1") r.hset("hash1", "k2", "v2") print(r.hkeys("hash1")) # 取hash中所有的key print(r.hget("hash1", "k1")) # 單個取hash的key對應的值 print(r.hmget("hash1", "k1", "k2")) # 多個取hash的key對應的值 r.hsetnx("hash1", "k2", "v3") # 只能新建 print(r.hget("hash1", "k2"))
hmset(name, mapping)
在name對應的hash中批次設定鍵值對
引數:
如:
r.hmset("hash2", {"k2": "v2", "k3": "v3"}) hget(name,key)
在name對應的hash中獲取根據key獲取value
hmget(name, keys, *args)
在name對應的hash中獲取多個key的值
引數:
如:
print(r.hget("hash2", "k2")) # 單個取出"hash2"的key-k2對應的value print(r.hmget("hash2", "k2", "k3")) # 批次取出"hash2"的key-k2 k3對應的value --方式1 print(r.hmget("hash2", ["k2", "k3"])) # 批次取出"hash2"的key-k2 k3對應的value --方式2
hgetall(name)
獲取name對應hash的所有鍵值
print(r.hgetall("hash1"))
hlen(name)
獲取name對應的hash中鍵值對的個數
print(r.hlen("hash1"))
hkeys(name)
獲取name對應的hash中所有的key的值
print(r.hkeys("hash1"))
hvals(name)
獲取name對應的hash中所有的value的值
print(r.hvals("hash1"))
hexists(name, key)
檢查 name 對應的 hash 是否存在當前傳入的 key
print(r.hexists("hash1", "k4")) # False 不存在 print(r.hexists("hash1", "k1")) # True 存在
hdel(name,*keys)
將name對應的hash中指定key的鍵值對刪除
print(r.hgetall("hash1")) r.hset("hash1", "k2", "v222") # 修改已有的key k2 r.hset("hash1", "k11", "v1") # 新增鍵值對 k11 r.hdel("hash1", "k1") # 刪除一個鍵值對 print(r.hgetall("hash1"))
hincrby(name, key, amount=1)
自增name對應的hash中的指定key的值,不存在則建立key=amount
引數:
r.hset("hash1", "k3", 123) r.hincrby("hash1", "k3", amount=-1) print(r.hgetall("hash1")) r.hincrby("hash1", "k4", amount=1) # 不存在的話,value預設就是1 print(r.hgetall("hash1"))
hincrbyfloat(name, key, amount=1.0)
自增name對應的hash中的指定key的值,不存在則建立key=amount
引數:
自增 name 對應的 hash 中的指定 key 的值,不存在則建立 key=amount。
r.hset("hash1", "k5", "1.0") r.hincrbyfloat("hash1", "k5", amount=-1.0) # 已經存在,遞減-1.0 print(r.hgetall("hash1")) r.hincrbyfloat("hash1", "k6", amount=-1.0) # 不存在,value初始值是-1.0 每次遞減1.0 print(r.hgetall("hash1"))
hscan(name, cursor=0, match=None, count=None)
增量式迭代獲取,對於資料大的資料非常有用,hscan可以實現分片的獲取資料,並非一次性將資料全部獲取完,從而放置記憶體被撐爆
引數:
如:
第一次:cursor1, data1 = r.hscan('xx', cursor=0, match=None, count=None) 第二次:cursor2, data1 = r.hscan('xx', cursor=cursor1, match=None, count=None) ...
直到返回值cursor的值為0時,表示資料已經通過分片獲取完畢
print(r.hscan("hash1"))
利用yield封裝hscan建立生成器,實現分批去redis中獲取資料
引數:
如:
for item in r.hscan_iter('hash1'): print(item) print(r.hscan_iter("hash1")) # 生成器記憶體地址
lpush(name,values)
在name對應的list中新增元素,每個新的元素都新增到列表的最左邊
如:
import redis import time pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True) r = redis.Redis(connection_pool=pool) r.lpush("list1", 11, 22, 33) print(r.lrange('list1', 0, -1))
儲存順序為: 33,22,11
擴充套件:
r.rpush("list2", 11, 22, 33) # 表示從右向左操作 print(r.llen("list2")) # 列表長度 print(r.lrange("list2", 0, 3)) # 切片取出值,範圍是索引號0-3
r.rpush("list2", 44, 55, 66) # 在列表的右邊,依次新增44,55,66 print(r.llen("list2")) # 列表長度 print(r.lrange("list2", 0, -1)) # 切片取出值,範圍是索引號0到-1(最後一個元素)
lpushx(name,value)
在name對應的list中新增元素,只有name已經存在時,值新增到列表的最左邊
r.lpushx("list10", 10) # 這裡list10不存在 print(r.llen("list10")) # 0 print(r.lrange("list10", 0, -1)) # [] r.lpushx("list2", 77) # 這裡"list2"之前已經存在,往列表最左邊新增一個元素,一次只能新增一個 print(r.llen("list2")) # 列表長度 print(r.lrange("list2", 0, -1)) # 切片取出值,範圍是索引號0到-1(最後一個元素
r.rpushx("list2", 99) # 這裡"foo_list1"之前已經存在,往列表最右邊新增一個元素,一次只能新增一個 print(r.llen("list2")) # 列表長度 print(r.lrange("list2", 0, -1)) # 切片取出值,範圍是索引號0到-1(最後一個元素)
linsert(name, where, refvalue, value))
在name對應的列表的某一個值前或後插入一個新值
引數:
r.linsert("list2", "before", "11", "00") # 往列表中左邊第一個出現的元素"11"前插入元素"00" print(r.lrange("list2", 0, -1)) # 切片取出值,範圍是索引號0-最後一個元素
r.lset(name, index, value)
對name對應的list中的某一個索引位置重新賦值
引數:
r.lset("list2", 0, -11) # 把索引號是0的元素修改成-11 print(r.lrange("list2", 0, -1))
r.lrem(name, value, num)
在name對應的list中刪除指定的值
引數:
r.lrem("list2", "11", 1) # 將列表中左邊第一次出現的"11"刪除 print(r.lrange("list2", 0, -1)) r.lrem("list2", "99", -1) # 將列表中右邊第一次出現的"99"刪除 print(r.lrange("list2", 0, -1)) r.lrem("list2", "22", 0) # 將列表中所有的"22"刪除 print(r.lrange("list2", 0, -1))
8.刪除並返回
lpop(name)
在name對應的列表的左側獲取第一個元素並在列表中移除,返回值則是第一個元素
rpop(name) 表示從右向左操作
r.lpop("list2") # 刪除列表最左邊的元素,並且返回刪除的元素 print(r.lrange("list2", 0, -1)) r.rpop("list2") # 刪除列表最右邊的元素,並且返回刪除的元素 print(r.lrange("list2", 0, -1))
ltrim(name, start, end)
在name對應的列表中移除沒有在start-end索引之間的值
引數:
r.ltrim("list2", 0, 2) # 刪除索引號是0-2之外的元素,值保留索引號是0-2的元素 print(r.lrange("list2", 0, -1))
lindex(name, index)
在name對應的列表中根據索引獲取列表元素
print(r.lindex("list2", 0)) # 取出索引號是0的值
rpoplpush(src, dst)
從一個列表取出最右邊的元素,同時將其新增至另一個列表的最左邊
引數:
r.rpoplpush("list1", "list2") print(r.lrange("list2", 0, -1))
brpoplpush(src, dst, timeout=0)
從一個列表的右側移除一個元素並將其新增到另一個列表的左側
引數:
r.brpoplpush("list1", "list2", timeout=2) print(r.lrange("list2", 0, -1))
blpop(keys, timeout)
將多個列表排列,按照從左到右去pop對應列表的元素
引數:
更多:
r.brpop(keys, timeout) 同 blpop,將多個列表排列,按照從右像左去移除各個列表內的元素
r.lpush("list10", 3, 4, 5) r.lpush("list11", 3, 4, 5) while True: r.blpop(["list10", "list11"], timeout=2) print(r.lrange("list10", 0, -1), r.lrange("list11", 0, -1))
由於redis類庫中沒有提供對列表元素的增量迭代,如果想要回圈name對應的列表的所有元素,那麼就需要獲取name對應的所有列表。
迴圈列表
但是,如果列表非常大,那麼就有可能在第一步時就將程式的內容撐爆,所有有必要自定義一個增量迭代的功能:
def list_iter(name): """ 自定義redis列表增量迭代 :param name: redis中的name,即:迭代name對應的列表 :return: yield 返回 列表元素 """ list_count = r.llen(name) for index in range(list_count): yield r.lindex(name, index) # 使用 for item in list_iter('list2'): # 遍歷這個列表 print(item)
Set集合就是不允許重複的列表
sadd(key,values),給key對應的集合中新增元素
smembers(key),獲取key對應的集合的所有成員
scard(key),獲取key對應的集合中的元素個數
r.sadd("key12","a1") r.sadd("key12","a1","a1") print(r.smembers("key12")) #輸出:{'a1'}print(r.scard("key12")) #輸出:1
sdiff(keys, *args),在第一個key對應的集合中且不在其他key對應的集合的元素集合
r.sadd("key13","a1","a2","a4") r.sadd("key14","a2","a3") r.sadd("key15","a1","a2","a3") print(r.sdiff("key13","key14","key15"))#輸出:{'a4'}
sdiffstore(newkey, keys, *args),相當於把sdiff獲取的值加入到newkey對應的集合中
r.sdiffstore("key16","key13","key14","key15") print(r.smembers("key16")) #輸出:{'a4'}
sinter(keys, *args),獲取多個key對應集合的並集
r.sadd("key13","a1","a2","a4") r.sadd("key14","a2","a3") r.sadd("key15","a1","a2","a3") print(r.sinter("key13","key14","key15"))#輸出:{'a2'}
sinterstore(newkey, keys, *args),獲取多個key對應集合的並集,再講其加入到newkey對應的集合中
r.sinterstore("key17","key13","key14","key15") print(r.smembers("key17")) #輸出:{'a2'}
sismember(name, value),檢查value是否是name對應的集合內的元素
r.sadd("key13", "a1", "a2", "a4") print(r.sismember("key13","a1")) # 輸出:Trueprint(r.sismember("key13","a5")) # 輸出:False
smove(src, dst, value),將某個元素從一個集合中移動到另外一個集合
r.sadd("key18", "a1", "a2", "a4") r.sadd("key19", "a5") r.smove("key18", "key19", "a2") print(r.smembers("key19")) #輸出:{'a2', 'a5'}
spop(name),從集合的右側移除一個元素,並將其返回
print(r.spop("key19")) #輸出:a5print(r.smembers("key19")) #輸出:{'a2'}
此外還有有序集合操作:在集合的基礎上,為每一個元素排序。
zadd(name, mapping),其中name為有序集合名,mapping為dict型別的鍵-值對
zcard(name),獲取有序集合內元素的數量
zcount(name, min, max),#獲取有序集合中分數在[min,max]之間的個數
r.zadd("key20", {"a": 10, "b": 3, "c": 8}) print(r.zcard("key20")) #輸出:3print(r.zcount("key20", 2, 5)) #輸出:1print(r.zcount("key20", 7, 15)) #輸出:1
以上是按不同型別的value進行對應的操作,redis有一些無視型別的通用操作方法。(這裡就只是列出方法並說明,就不再一一演示)
delete(*names),根據name刪除redis中的任意資料型別
exists(name),檢測redis的name是否存在
keys(pattern='*'),根據* ?等萬用字元匹配獲取redis的name
expire(name ,time),為某個name設定超時時間
rename(src, dst),重新命名
move(name, db)),將redis的某個值移動到指定的db下
randomkey(),隨機獲取一個redis的name(不刪除)
type(name),獲取name對應值的型別
今天的技術講解文章就到此結束,主要是將瞭如何通過python去連線Redis,Redis的儲存結構是key-value型別,本文按value型別分類講解了string字串操作、list操作、hash操作、set操作以及通用操作。
到此這篇關於python中使用redis用法詳解的文章就介紹到這了,更多相關Python操作Redis內容請搜尋it145.com以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援it145.com!
相關文章
<em>Mac</em>Book项目 2009年学校开始实施<em>Mac</em>Book项目,所有师生配备一本<em>Mac</em>Book,并同步更新了校园无线网络。学校每周进行电脑技术更新,每月发送技术支持资料,极大改变了教学及学习方式。因此2011
2021-06-01 09:32:01
综合看Anker超能充系列的性价比很高,并且与不仅和iPhone12/苹果<em>Mac</em>Book很配,而且适合多设备充电需求的日常使用或差旅场景,不管是安卓还是Switch同样也能用得上它,希望这次分享能给准备购入充电器的小伙伴们有所
2021-06-01 09:31:42
除了L4WUDU与吴亦凡已经多次共事,成为了明面上的厂牌成员,吴亦凡还曾带领20XXCLUB全队参加2020年的一场音乐节,这也是20XXCLUB首次全员合照,王嗣尧Turbo、陈彦希Regi、<em>Mac</em> Ova Seas、林渝植等人全部出场。然而让
2021-06-01 09:31:34
目前应用IPFS的机构:1 谷歌<em>浏览器</em>支持IPFS分布式协议 2 万维网 (历史档案博物馆)数据库 3 火狐<em>浏览器</em>支持 IPFS分布式协议 4 EOS 等数字货币数据存储 5 美国国会图书馆,历史资料永久保存在 IPFS 6 加
2021-06-01 09:31:24
开拓者的车机是兼容苹果和<em>安卓</em>,虽然我不怎么用,但确实兼顾了我家人的很多需求:副驾的门板还配有解锁开关,有的时候老婆开车,下车的时候偶尔会忘记解锁,我在副驾驶可以自己开门:第二排设计很好,不仅配置了一个很大的
2021-06-01 09:30:48
不仅是<em>安卓</em>手机,苹果手机的降价力度也是前所未有了,iPhone12也“跳水价”了,发布价是6799元,如今已经跌至5308元,降价幅度超过1400元,最新定价确认了。iPhone12是苹果首款5G手机,同时也是全球首款5nm芯片的智能机,它
2021-06-01 09:30:45