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)突降或者突升的情況,趨勢(shì)上看起來十分不平滑,嚴(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的變大而變長(zhǎng)。
在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é)
以上就是這篇文章的全部?jī)?nèi)容了,希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,如果有疑問大家可以留言交流,謝謝大家對(duì)腳本之家的支持。
您可能感興趣的文章:- Redis批量刪除KEY的方法
- Redis教程(七):Key操作命令詳解
- Redis獲取某個(gè)前綴的key腳本實(shí)例
- redis數(shù)據(jù)庫查找key在內(nèi)存中的位置的方法
- 關(guān)于使用key/value數(shù)據(jù)庫redis和TTSERVER的心得體會(huì)
- 關(guān)于redis Key淘汰策略的實(shí)現(xiàn)方法
- redis 用scan指令 代替keys指令(詳解)
- Redis未授權(quán)訪問配合SSH key文件利用詳解
- redis中熱key問題該如何解決