详解如何清理redis集群的所有数据

1. 背景:生产测试后redis中产生大量数据

生产前需要清理reids集群中的数据。、
你看有很多key呢:

使用工具

使用命令,查看是否有数据:

keys * 

2. 清理步骤

2.1 任意登录一台redis机器

执行下面脚本:

clear_redis_cluster.sh 10.1.33.101:8001 redis

执行日志如下:

clearing 10.1.33.112:8028 ...background append only file rewriting startedreadonly you can't write against a read only replica. clearing 10.1.33.110:8026 ...background append only file rewriting startedreadonly you can't write against a read only replica. clearing 10.1.33.111:8027 ...background append only file rewriting startedreadonly you can't write against a read only replica. clearing 10.1.33.107:8007 ...background append only file rewriting startedokclearing 10.1.33.108:8024 ...background append only file rewriting startedreadonly you can't write against a read only replica. clearing 10.1.33.104:8020 ...background append only file rewriting startedreadonly you can't write against a read only replica. clearing 10.1.33.114:8014 ...background append only file rewriting startedokclearing 10.1.33.109:8025 ...background append only file rewriting startedreadonly you can't write against a read only replica. clearing 10.1.33.105:8005 ...background append only file rewriting startedokclearing 10.1.33.108:8008 ...background append only file rewriting startedok

2.2 clear_redis_cluster.sh内容

#!/bin/bash# writed by yijian on 2018/8/20# batch to clear all nodes using flushall command# 用来清空一个redis集群中的所有数据,要求 flushall 命令可用,# 如果在 redis.conf 中使用 rename 改名了 flushall,则不能执行本脚本。# 可带两个参数:# 1)参数1 集群中的任一可用节点(必须)# 2)连接redis的密码(设置了密码才需要)redis_cli=${redis_cli:-redis-cli}redis_ip=${redis_ip:-127.0.0.1}redis_port=${redis_port:-6379}# 显示用法函数function usage(){  echo "usage: clear_redis_cluster.sh a_redis_node_of_cluster redis_password"  echo "example1: clear_redis_cluster.sh '127.0.0.1:6379'"  echo "example2: clear_redis_cluster.sh '127.0.0.1:6379' '123456'"}# 检查参数个数if test $# -lt 1 -o $# -gt 2; then  usage  exit 1fi# 第一个参数为集群中的节点,redis_node="$1"# 第二个参数为密码redis_password=""if test $# -ge 2; then  redis_password="$2"fi# 取得ip和端口eval $(echo "$redis_node" | awk -f[\:] '{ printf("redis_ip=%s\nredis_port=%s\n",$1,$2) }')if test -z "$redis_ip" -o -z "$redis_port"; then  echo "parameter error: \`$redis_node\`."  usage  exit 1fi# 确保redis-cli可用echo "checking \`redis-cli\` ..."which "$redis_cli" > /dev/null 2>&1if test $? -ne 0; then  echo "command \`redis-cli\` is not exists or not executable."  echo "you can set environment variable \`redis_cli\` to point to the redis-cli."  echo "example: export redis_cli=/usr/local/bin/redis-cli"  exit 1fiif test -z "$redis_password"; then  redis_nodes=`redis-cli -h $redis_ip -p $redis_port cluster nodes | awk -f[\ \:\@] '!/err/{ printf("%s:%s\n",$2,$3); }'`else  redis_nodes=`redis-cli --no-auth-warning -a "$redis_password" -h $redis_ip -p $redis_port cluster nodes | awk -f[\ \:\@] '!/err/{ printf("%s:%s\n",$2,$3); }'`fiif test -z "$redis_nodes"; then  # standlone(非集群)  if test -z "$redis_password"; then    $redis_cli -h $redis_ip -p $redis_port flushall async    $redis_cli -h $redis_ip -p $redis_port bgrewriteaof  else    $redis_cli --no-auth-warning -a "$redis_password" -h $redis_ip -p $redis_port flushall async    $redis_cli --no-auth-warning -a "$redis_password" -h $redis_ip -p $redis_port bgrewriteaof  fielse  # cluster(集群)  for redis_node in $redis_nodes;  do    if test ! -z "$redis_node"; then      eval $(echo "$redis_node" | awk -f[\:] '{ printf("redis_node_ip=%s\nredis_node_port=%s\n",$1,$2) }')      if test ! -z "$redis_node_ip" -a ! -z "$redis_node_port"; then        # clear        echo -e "clearing 3[1;33m${redis_node_ip}:${redis_node_port}3[m ..."        if test -z "$redis_password"; then          result=`$redis_cli -h $redis_node_ip -p $redis_node_port flushall async`          $redis_cli -h $redis_node_ip -p $redis_node_port bgrewriteaof        else          result=`$redis_cli --no-auth-warning -a "$redis_password" -h $redis_node_ip -p $redis_node_port flushall async`          $redis_cli --no-auth-warning -a "$redis_password" -h $redis_node_ip -p $redis_node_port bgrewriteaof        fi        if test ! -z "$result"; then          # success          if test "$result" = "ok"; then            echo -e "3[0;32;32m$result3[m"          else            echo -e "3[0;32;31m$result3[m"          fi        fi      fi    fi  donefi

这位仁兄的脚本写的特别好。直接执行即可。

2.3 确认删除成功

使用redis工具查看:

3.清理单机redis

flushall 

4.总结

使用脚本删除redis集群中的数据。
记得地址哦:

到此这篇关于详解如何清理redis集群的所有数据的文章就介绍到这了,更多相关清理redis集群数据内容请搜索www.887551.com以前的文章或继续浏览下面的相关文章希望大家以后多多支持www.887551.com!

(0)
上一篇 2022年3月21日
下一篇 2022年3月21日

相关推荐