ITPub博客

首页 > 自动化运维 > DevOps > python3.10监控redis实例

python3.10监控redis实例

原创 DevOps 作者:z597011036 时间:2023-03-02 19:20:20 0 删除 编辑

       使用python3.10监控redis单实例,实例可用,连接数,端口.

import sys
try:
    import redis
except Exception as e:
    print('pip install redis')   #安装redis模块
    sys.exit()
class Redis:
    def __init__(self,host,port,password=None):
        self.host = host
        self.port = port
        self.password = password
        if self.password:
            self.rds = redis.StrictRedis(host=host,port=port,password=self.password)
        else:
            self.rds = redis.StrictRedis(host=host, port=port)
        try:
            self.info = self.rds.info()
        except Exception as e:
            self.info = None
    #返回redis版本
    def redis_version(self):
        try:
            return "Redis版本:%s" % self.info['redis_version']
        except Exception as e:
            return e
    def redis_ping(self):
        if self.rds.ping():
            return "Redis实例可用"
        else:
            return "Redis实例不可用"
            sys.exit()
    def redis_connections(self):
        try:
            return "Redis连接数:%s" % self.info['connected_clients']
        except Exception as e:
            return e
    def redis_port(self):
        try:
            return "Redis端口:%s" % self.info['tcp_port']
        except Exception as e:
            return e
    def blocked_clients(self):
        try:
            return "Redis正在等待阻塞客房端的数量:%s" % self.info['blocked_clients']
        except Exception as e:
            return e
    def redis_used_memory(self):
        memory = self.info['used_memory']
        if memory:
            return "Redis内存使用:%.2fM" % (memory/1024)
    def redis_memory_usage(self):
        used_memory = self.info['used_memory']
        max_memory = self.info['maxmemory']
        system_memory = self.info['total_system_memory']
        rate = 0
        if max_memory:
            rate = float(used_memory) / float(max_memory)
        else:
            if system_memory:
                rate = float(used_memory) / float(system_memory)
        return "%.2f" % (rate * 100)
    def rejected_connections(self):
        try:
            return "Redis拒绝连接数:%s" % self.info['rejected_connections']
        except Exception as e:
            return e
    def ops(self):
        try:
            return "Redis OPS值:%s" % self.info['instantaneous_ops_per_sec']
        except Exception as e:
            return e
    def redis_expired(self):
        try:
            return "Redis命中率:%s" % self.info['expired_keys']
        except Exception as e:
            return e
    def check(self):
        print(self.redis_version())
        print(self.redis_ping())
        print(self.redis_connections())
        print(self.redis_port())
        print(self.blocked_clients())
        print(self.redis_used_memory())
        print(self.redis_memory_usage())
        print(self.rejected_connections())
        print(self.ops())
        print(self.redis_expired())
if __name__ == '__main__':
    a=Redis('127.0.0.1','6379','System135')
    a.check()


来自 “ ITPUB博客 ” ,链接:https://blog.itpub.net/25854343/viewspace-2937940/ ,如需转载,请注明出处,否则将追究法律责任。

下一篇: postgresql结构
请登录后发表评论 登录
全部评论

注册时间:2014-03-31

  • 博文量
    79
  • 访问量
    486684