Redis獲取某個大key值的指令碼例項
阿新 • • 發佈:2020-01-09
1、前言
工作中,經常有些Redis例項使用不恰當,或者對業務預估不準確,或者key沒有及時進行處理等等原因,導致某些KEY相當大。
那麼大Key會帶來哪些問題呢?
如果是叢集模式下,無法做到負載均衡,導致請求傾斜到某個例項上,而這個例項的QPS會比較大,記憶體佔用也較多;對於Redis單執行緒模型又容易出現CPU瓶頸,當記憶體出現瓶頸時,只能進行縱向庫容,使用更牛逼的伺服器。
涉及到大key的操作,尤其是使用hgetall、lrange 0 -1、get、hmget 等操作時,網絡卡可能會成為瓶頸,也會到導致堵塞其它操作,qps 就有可能出現突降或者突升的情況,趨勢上看起來十分不平滑,嚴重時會導致應用程式連不上,例項或者叢集在某些時間段內不可用的狀態。
假如這個key需要進行刪除操作,如果直接進行DEL 操作,被操作的例項會被Block住,導致無法響應應用的請求,而這個Block的時間會隨著key的變大而變長。
在redis中,對於一個很大的key,例如hash型別,直接檢視其值會非常慢,於是想到寫個指令碼通過增量迭代來獲取,下面話不多說了,來一起看看詳細的介紹吧。
2、具體的指令碼如下:
功能:掃描redis某個key裡面的所有元素
使用方法:python bigkey_save_values.py "zyyset" "*" 100
3、python指令碼實現如下:
#!/usr/bin/env python # -*- coding: UTF-8 -*- #功能:掃描某個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] #每次匹配數量 count = sys.argv[3] #總數量 total = 0 #獲取當前路徑 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): #將匹配到對應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): #將匹配到對應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,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,"\n")) total = total+1 f.close else: print("key的型別為string,value為:" + r.get(key)) print "key:%s的match:%s的數量為:%d" % (key,match,total)
總結
以上就是這篇文章的全部內容了,希望本文的內容對大家的學習或者工作具有一定的參考學習價值,如果有疑問大家可以留言交流,謝謝大家對我們的支援。