d0zingcat/redis-keys-statistics
1
0
Fork 0
mirror of https://github.com/d0zingcat/redis-keys-statistics.git synced 2026-05-13 15:09:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1 from d0zingcat/enh/username_args

Browse Source 
allow user username to auth
This commit is contained in:
d0zingcat
2024-07-24 11:09:21 +08:00
committed by GitHub
parent 3f342dcf87 e945a6e7a7
commit a0d951e1d1
1 changed files with 39 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

57
rks/main.py
View File

@@ -4,15 +4,22 @@ import rediscluster
from datetime import datetime
from .redis_utils import get_redis_keys, get_redis_cluster_keys
def main():
parser = argparse.ArgumentParser(description='Analyze Redis Instance Key Statistics.')
parser = argparse.ArgumentParser(
description='Analyze Redis Instance Key Statistics.')
parser.add_argument('--host', required=True, help='Redis host')
parser.add_argument('--port', required=True, help='Redis port')
parser.add_argument('--username', default=None, help='Redis username')
parser.add_argument('--password', default=None, help='Redis password')
parser.add_argument('--cluster', action='store_true', help='Enable cluster mode')
parser.add_argument('--batch_size', type=int, default=1000, help='Batch size for SCAN command')
parser.add_argument('--replica_only', action='store_true', help='Execute only on replica instances')
parser.add_argument('--pretty_format', action='store_true', help='Display output in a human-readable format')
parser.add_argument('--cluster', action='store_true',
help='Enable cluster mode')
parser.add_argument('--batch_size', type=int, default=1000,
help='Batch size for SCAN command')
parser.add_argument('--replica_only', action='store_true',
help='Execute only on replica instances')
parser.add_argument('--pretty_format', action='store_true',
help='Display output in a human-readable format')
args = parser.parse_args()
CONNECTION_TIMEOUT = 10
@@ -22,50 +29,60 @@ def main():
rc = rediscluster.RedisCluster(startup_nodes=[{"host": args.host, "port": int(args.port)}],
skip_full_coverage_check=True,
password=args.password,
username=args.username,
socket_timeout=CONNECTION_TIMEOUT)
redis_info = rc.info()
if list(redis_info.values())[0].get('cluster_enabled') != 1:
print("Error: Specified Redis instance is not running in cluster mode but --cluster flag was provided.")
print(
"Error: Specified Redis instance is not running in cluster mode but --cluster flag was provided.")
return
process_start_time = datetime.now()
if get_redis_cluster_keys(rc, args.batch_size, args.replica_only, args.pretty_format) == -1:
print(f"Aborted the operation on non-readonly redis at host: {args.host}")
print(
f"Aborted the operation on non-readonly redis at host: {args.host}")
return
rc.close()
process_end_time = datetime.now()
process_taken_time = str(process_end_time - process_start_time).split(".")[0]
process_taken_time = str(
process_end_time - process_start_time).split(".")[0]
print(f'Process completed in {process_taken_time} (HH:MM:SS)')
except rediscluster.exceptions.RedisClusterError as e:
print(f"Error connecting to Redis cluster: {args.host}. Error message: {str(e)}")
print(
f"Error connecting to Redis cluster: {args.host}. Error message: {str(e)}")
return
except rediscluster.exceptions.RedisClusterException as e:
if "ERROR sending 'cluster slots' command to redis server" in str(e):
print("Error: Specified Redis instance is not running in cluster mode but --cluster flag was provided.")
print(
"Error: Specified Redis instance is not running in cluster mode but --cluster flag was provided.")
return
else:
print(f"Failed to connect to Redis cluster: {args.host}. Error message: {str(e)}")
print(
f"Failed to connect to Redis cluster: {args.host}. Error message: {str(e)}")
return
else:
try:
r = redis.Redis(host=args.host, port=int(args.port),
password=args.password,
username=args.username,
socket_timeout=CONNECTION_TIMEOUT)
redis_info = r.info()
if redis_info.get('cluster_enabled') != 0:
print("Error: Specified Redis instance is running in cluster mode but --cluster flag was not provided.")
print(
"Error: Specified Redis instance is running in cluster mode but --cluster flag was not provided.")
return
if redis_info.get('role') != 'slave' and args.replica_only:
print(f"Aborted the operation on non-readonly redis at host: {args.host}")
print(
f"Aborted the operation on non-readonly redis at host: {args.host}")
return
process_start_time = datetime.now()
@@ -73,19 +90,23 @@ def main():
for db in redis_info.keys():
if db.startswith('db'):
db_num = int(db[2:])
get_redis_keys(r, args.batch_size, db_num, args.pretty_format)
get_redis_keys(r, args.batch_size,
db_num, args.pretty_format)
r.close()
process_end_time = datetime.now()
process_taken_time = str(process_end_time - process_start_time).split(".")[0]
process_taken_time = str(
process_end_time - process_start_time).split(".")[0]
print(f'Process completed in {process_taken_time} (HH:MM:SS)')
except redis.exceptions.TimeoutError as e:
print(f"Timeout connecting to Redis: {args.host}. Error message: {str(e)}")
print(
f"Timeout connecting to Redis: {args.host}. Error message: {str(e)}")
except redis.exceptions.ConnectionError as e:
print(f"Failed to connect to Redis: {args.host}. Error message: {str(e)}")
print(
f"Failed to connect to Redis: {args.host}. Error message: {str(e)}")
if __name__ == "__main__":
main()
main()