Redis獲取某個(gè)大key值的腳本實(shí)例
1、前言
工作中,經(jīng)常有些Redis實(shí)例使用不恰當(dāng),或者對(duì)業(yè)務(wù)預(yù)估不準(zhǔn)確,或者key沒有及時(shí)進(jìn)行處理等等原因,導(dǎo)致某些KEY相當(dāng)大。
那么大Key會(huì)帶來哪些問題呢?
如果是集群模式下,無法做到負(fù)載均衡,導(dǎo)致請(qǐng)求傾斜到某個(gè)實(shí)例上,而這個(gè)實(shí)例的QPS會(huì)比較大,內(nèi)存占用也較多;對(duì)于Redis單線程模型又容易出現(xiàn)CPU瓶頸,當(dāng)內(nèi)存出現(xiàn)瓶頸時(shí),只能進(jìn)行縱向庫容,使用更牛逼的服務(wù)器。
涉及到大key的操作,尤其是使用hgetall、lrange 0 -1、get、hmget 等操作時(shí),網(wǎng)卡可能會(huì)成為瓶頸,也會(huì)到導(dǎo)致堵塞其它操作,qps 就有可能出現(xiàn)突降或者突升的情況,趨勢上看起來十分不平滑,嚴(yán)重時(shí)會(huì)導(dǎo)致應(yīng)用程序連不上,實(shí)例或者集群在某些時(shí)間段內(nèi)不可用的狀態(tài)。
假如這個(gè)key需要進(jìn)行刪除操作,如果直接進(jìn)行DEL 操作,被操作的實(shí)例會(huì)被Block住,導(dǎo)致無法響應(yīng)應(yīng)用的請(qǐng)求,而這個(gè)Block的時(shí)間會(huì)隨著key的變大而變長。
在redis中,對(duì)于一個(gè)很大的key,例如hash類型,直接查看其值會(huì)非常慢,于是想到寫個(gè)腳本通過增量迭代來獲取,下面話不多說了,來一起看看詳細(xì)的介紹吧。
2、具體的腳本如下:
功能:掃描redis某個(gè)key里面的所有元素
使用方法:python bigkey_save_values.py "zyyset" "*" 100
3、python腳本實(shí)現(xiàn)如下:
#!/usr/bin/env python # -*- coding: UTF-8 -*- #功能:掃描某個(gè)key里面的所有元素 #使用方法:python bigkey_save_values.py "zyyset" "m*" 100 #如需獲取全部的元素:python bigkey_save_values.py "zyyset" "*" 100 __author__ = "lcl" import sys import redis import os pool=redis.ConnectionPool(host='192.168.225.128',port=6379,db=0) r = redis.StrictRedis(connection_pool=pool) #指定key key = sys.argv[1] #掃描匹配值 match = sys.argv[2] #每次匹配數(shù)量 count = sys.argv[3] #總數(shù)量 total = 0 #獲取當(dāng)前路徑 path = os.getcwd() keytype = r.type(key) print "key的類型為%s" % (keytype) #掃描到的key輸出的文件 txt = path+"/%s.txt" % (key) #打開文件 #f = open(txt,"w") def list_iter(name): list_count = r.llen(key) for index in range(list_count): yield r.lindex(key, index) if keytype=='list': f = open(txt,"w") for item in list_iter(key): #將匹配到對(duì)應(yīng)key中的member/score輸出到文件中 f.write("%s %s" % (item,"\n")) total = total+1 f.close elif keytype=='hash': f = open(txt,"w") for item in r.hscan_iter(key,match = match,count = count): #將匹配到對(duì)應(yīng)key中的member/score輸出到文件中 f.write("%s %s" % (item,"\n")) total = total+1 f.close elif keytype=='set': f = open(txt,"w") for item in r.sscan_iter(key,match = match,count = count): f.write("%s %s" % (item,"\n")) total = total+1 f.close elif keytype=='zset': f = open(txt,"w") for item in r.zscan_iter(key,match = match,count = count): f.write("%s %s" % (item,"\n")) total = total+1 f.close else: print("key的類型為string,value為:" + r.get(key)) print "key:%s的match:%s的數(shù)量為:%d" % (key,match,total)
總結(jié)
以上就是這篇文章的全部內(nèi)容了,希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,如果有疑問大家可以留言交流,謝謝大家對(duì)腳本之家的支持。
相關(guān)文章
Redis實(shí)現(xiàn)主從復(fù)制方式(Master&Slave)
這篇文章主要介紹了Redis實(shí)現(xiàn)主從復(fù)制方式(Master&Slave),具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-06-06redis不能訪問本機(jī)真實(shí)ip地址的解決方案
這篇文章主要介紹了redis不能訪問本機(jī)真實(shí)ip地址的解決方案,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-07-07redis執(zhí)行l(wèi)ua腳本的實(shí)現(xiàn)方法
redis在2.6推出了腳本功能,允許開發(fā)者使用Lua語言編寫腳本傳到redis中執(zhí)行。本文就介紹了redis執(zhí)行l(wèi)ua腳本的實(shí)現(xiàn)方法,感興趣的可以了解一下2021-11-11Redis 的查詢很快的原因解析及Redis 如何保證查詢的高效
由于redis是內(nèi)存數(shù)據(jù)庫,歸功于它的數(shù)據(jù)結(jié)構(gòu)所以查詢效率非常高,今天通過本文給大家介紹下Redis 的查詢很快的原因解析及Redis 如何保證查詢的高效,感興趣的朋友一起看看吧2022-03-03Redis數(shù)據(jù)結(jié)構(gòu)原理淺析
這篇文章主要為大家介紹了Redis數(shù)據(jù)結(jié)構(gòu)原理淺析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-02-02淺談redis內(nèi)存數(shù)據(jù)的持久化方式
這篇文章主要介紹了淺談redis內(nèi)存數(shù)據(jù)的持久化方式,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-03-03redis服務(wù)器允許遠(yuǎn)程主機(jī)訪問的方法
今天小編就為大家分享一篇redis服務(wù)器允許遠(yuǎn)程主機(jī)訪問的方法,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2018-05-05