{"id":5446,"date":"2020-09-23T23:16:20","date_gmt":"2020-09-23T15:16:20","guid":{"rendered":"http:\/\/39.97.231.10\/?p=5446"},"modified":"2020-09-23T23:16:20","modified_gmt":"2020-09-23T15:16:20","slug":"python-%e8%bf%9e%e6%8e%a5%e7%ae%a1%e7%90%86%e4%bd%9credis%e9%9b%86%e7%be%a4","status":"publish","type":"post","link":"http:\/\/www.weijing.co\/?p=5446","title":{"rendered":"python \u8fde\u63a5\u7ba1\u7406\u4f5credis\u96c6\u7fa4"},"content":{"rendered":"
\u4e00\u3001\u8fde\u63a5redis\u96c6\u7fa4<\/span><\/div>\n
\n
\npython\u7684redis\u5e93\u662f\u4e0d\u652f\u6301\u96c6\u7fa4\u64cd\u4f5c\u7684\uff0c\u63a8\u8350\u5e93\uff1aredis-py-cluster<\/strong>\u3002
\n<\/code><\/p>\n

\u5b89\u88c5<\/h2>\n
\n
pip3 install redis-py-cluster<\/pre>\n<\/div>\n
<\/h2>\n
\u8fde\u63a5redis\u96c6\u7fa4<\/h2>\n
\\\"\\\" \\\"\\\"<\/p>\n
\n
#!\/usr\/bin\/env python\n# coding: utf-8\nfrom rediscluster import StrictRedisCluster\nclass RedisCluster(object):  # \u8fde\u63a5redis\u96c6\u7fa4\n    def __init__(self,conn_list):\n        self.conn_list = conn_list  # \u8fde\u63a5\u5217\u8868\n    def connect(self):\n        \\\"\\\"\\\"\n        \u8fde\u63a5redis\u96c6\u7fa4\n        :return: object\n        \\\"\\\"\\\"\n        try:\n            # \u975e\u5bc6\u7801\u8fde\u63a5redis\u96c6\u7fa4\n            # redisconn = StrictRedisCluster(startup_nodes=self.conn_list)\n            # \u4f7f\u7528\u5bc6\u7801\u8fde\u63a5redis\u96c6\u7fa4\n            redisconn = StrictRedisCluster(startup_nodes=self.conn_list, password=\\'123456\\')\n            return redisconn\n        except Exception as e:\n            print(e)\n            print(\\\"\u9519\u8bef,\u8fde\u63a5redis \u96c6\u7fa4\u5931\u8d25\\\")\n            return False\nredis_basis_conn = [{\\'host\\': \\'192.168.10.168\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.169\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.170\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.171\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.142\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.143\\', \\'port\\': 7201}]\nres = RedisCluster(redis_basis_conn).connect()\nif not res:\n    print(\\\"\u8fde\u63a5redis\u96c6\u7fa4\u5931\u8d25\\\")\nelse:\n    print(\\\"\u8fde\u63a5redis\u96c6\u7fa4\u6210\u529f\\\")<\/pre>\n<\/div>\n<\/div>\n
\u6267\u884c\u8f93\u51fa\uff1a<\/p>\n
\n
\u8fde\u63a5redis\u96c6\u7fa4\u6210\u529f<\/pre>\n<\/div>\n
<\/h1>\n
\u4e8c\u3001\u64cd\u4f5credis\u96c6\u7fa4<\/h1>\n
\u67e5\u770b\u8282\u70b9\u72b6\u6001<\/h2>\n
\\\"\\\" \\\"\\\"<\/p>\n
\n
#!\/usr\/bin\/env python\n# coding: utf-8\nfrom rediscluster import StrictRedisCluster\nclass RedisCluster(object):  # \u8fde\u63a5redis\u96c6\u7fa4\n    def __init__(self,conn_list):\n        self.conn_list = conn_list  # \u8fde\u63a5\u5217\u8868\n    def connect(self):\n        \\\"\\\"\\\"\n        \u8fde\u63a5redis\u96c6\u7fa4\n        :return: object\n        \\\"\\\"\\\"\n        try:\n            # \u975e\u5bc6\u7801\u8fde\u63a5redis\u96c6\u7fa4\n            # redisconn = StrictRedisCluster(startup_nodes=self.conn_list)\n            # \u4f7f\u7528\u5bc6\u7801\u8fde\u63a5redis\u96c6\u7fa4\n            redisconn = StrictRedisCluster(startup_nodes=self.conn_list, password=\\'123456\\')\n            return redisconn\n        except Exception as e:\n            print(e)\n            print(\\\"\u9519\u8bef,\u8fde\u63a5redis \u96c6\u7fa4\u5931\u8d25\\\")\n            return False\n    def get_state(self):\n        \\\"\\\"\\\"\n        \u83b7\u53d6\u72b6\u6001\n        :return:\n        \\\"\\\"\\\"\n        res = RedisCluster(self.conn_list).connect()\n        # print(\\\"\u8fde\u63a5\u96c6\u7fa4\u5bf9\u8c61\\\",res,type(res),res.__dict__)\n        if not res:\n            return False\n        dic = res.cluster_info()  # \u67e5\u770binfo\u4fe1\u606f, \u8fd4\u56dedict\n        for i in dic:  # \u904d\u5386dict\n            ip = i.split(\\\":\\\")[0]\n            if dic[i].get(\\'cluster_state\\'):  # \u83b7\u53d6\u72b6\u6001\n                print(\\\"\u8282\u70b9\u72b6\u6001, ip: \\\", ip, \\\"value: \\\", dic[i].get(\\'cluster_state\\'))\nredis_basis_conn = [{\\'host\\': \\'192.168.10.168\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.169\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.170\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.171\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.142\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.143\\', \\'port\\': 7201}]\nRedisCluster(redis_basis_conn).get_state()<\/pre>\n<\/div>\n<\/div>\n
\u6267\u884c\u8f93\u51fa\uff1a<\/p>\n
\n
\u8282\u70b9\u72b6\u6001, ip:  192.168.10.171 value:  ok\n\u8282\u70b9\u72b6\u6001, ip:  192.168.10.169 value:  ok\n\u8282\u70b9\u72b6\u6001, ip:  192.168.10.143 value:  ok\n\u8282\u70b9\u72b6\u6001, ip:  192.168.10.142 value:  ok\n\u8282\u70b9\u72b6\u6001, ip:  192.168.10.170 value:  ok\n\u8282\u70b9\u72b6\u6001, ip:  192.168.10.168 value:  ok<\/pre>\n<\/div>\n
\u67e5\u770baof\u662f\u5426\u5f00\u542f<\/h2>\n
\\\"\\\" \\\"\\\"<\/p>\n
\n
#!\/usr\/bin\/env python\n# coding: utf-8\nfrom rediscluster import StrictRedisCluster\nclass RedisCluster(object):  # \u8fde\u63a5redis\u96c6\u7fa4\n    def __init__(self,conn_list):\n        self.conn_list = conn_list  # \u8fde\u63a5\u5217\u8868\n    def connect(self):\n        \\\"\\\"\\\"\n        \u8fde\u63a5redis\u96c6\u7fa4\n        :return: object\n        \\\"\\\"\\\"\n        try:\n            # \u975e\u5bc6\u7801\u8fde\u63a5redis\u96c6\u7fa4\n            # redisconn = StrictRedisCluster(startup_nodes=self.conn_list)\n            # \u4f7f\u7528\u5bc6\u7801\u8fde\u63a5redis\u96c6\u7fa4\n            redisconn = StrictRedisCluster(startup_nodes=self.conn_list, password=\\'123456\\')\n            return redisconn\n        except Exception as e:\n            print(e)\n            print(\\\"\u9519\u8bef,\u8fde\u63a5redis \u96c6\u7fa4\u5931\u8d25\\\")\n            return False\n    def get_info(self):\n        \\\"\\\"\\\"\n        \u83b7\u53d6redis\u96c6\u7fa4info\u4fe1\u606f\n        :return: dict\n        \\\"\\\"\\\"\n        res = RedisCluster(self.conn_list).connect()\n        # print(\\\"\u8fde\u63a5\u96c6\u7fa4\u5bf9\u8c61\\\",res,type(res),res.__dict__)\n        if not res:\n            return False\n        dic = res.cluster_info()  # \u67e5\u770binfo\u4fe1\u606f, \u8fd4\u56dedict\n        if not dic:\n            return False\n        return dic\n    def get_state(self):\n        \\\"\\\"\\\"\n        \u83b7\u53d6\u72b6\u6001\n        :return:\n        \\\"\\\"\\\"\n        dic = self.get_info()  # type:dict\n        if not dic:\n            return dic\n        for i in dic:  # \u904d\u5386dict\n            ip = i.split(\\\":\\\")[0]\n            if dic[i].get(\\'cluster_state\\'):  # \u83b7\u53d6\u72b6\u6001\n                print(\\\"\u8282\u70b9\u72b6\u6001, ip: \\\", ip, \\\"value: \\\", dic[i].get(\\'cluster_state\\'))\n    def get_has_aof(self):\n        \\\"\\\"\\\"\n        \u67e5\u770baof\u662f\u5426\u6253\u5f00\n        :return:\n        \\\"\\\"\\\"\n        res = RedisCluster(self.conn_list).connect()\n        # print(\\\"\u8fde\u63a5\u96c6\u7fa4\u5bf9\u8c61\\\",res,type(res),res.__dict__)\n        if not res:\n            return False\n        dic = res.config_get(\\'appendonly\\')  # \u4ececonfig\u914d\u7f6e\u9879\u4e2d\u67e5\u8be2appendonly\n        for i in dic:\n            ip = i.split(\\\":\\\")[0]\n            # print(dic[i])\n            if dic[i].get(\\'appendonly\\'):\n                print(\\\"aof\u5f00\u5173, ip: \\\", ip,\\\"value: \\\",dic[i].get(\\'appendonly\\'))\nredis_basis_conn = [{\\'host\\': \\'192.168.10.168\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.169\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.170\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.171\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.142\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.143\\', \\'port\\': 7201}]\nRedisCluster(redis_basis_conn).get_has_aof()<\/pre>\n<\/div>\n<\/div>\n
\u6267\u884c\u8f93\u51fa\uff1a<\/p>\n
\n
aof\u5f00\u5173, ip:  192.168.10.170 value:  no\naof\u5f00\u5173, ip:  192.168.10.168 value:  no\naof\u5f00\u5173, ip:  192.168.10.142 value:  no\naof\u5f00\u5173, ip:  192.168.10.171 value:  no\naof\u5f00\u5173, ip:  192.168.10.169 value:  no\naof\u5f00\u5173, ip:  192.168.10.143 value:  no<\/pre>\n<\/div>\n
set\u548cget<\/h2>\n
\\\"\\\" \\\"\\\"<\/p>\n
\n
#!\/usr\/bin\/env python\n# coding: utf-8\nfrom rediscluster import StrictRedisCluster\nclass RedisCluster(object):  # \u8fde\u63a5redis\u96c6\u7fa4\n    def __init__(self,conn_list):\n        self.conn_list = conn_list  # \u8fde\u63a5\u5217\u8868\n    def connect(self):\n        \\\"\\\"\\\"\n        \u8fde\u63a5redis\u96c6\u7fa4\n        :return: object\n        \\\"\\\"\\\"\n        try:\n            # \u975e\u5bc6\u7801\u8fde\u63a5redis\u96c6\u7fa4\n            # redisconn = StrictRedisCluster(startup_nodes=self.conn_list)\n            # \u4f7f\u7528\u5bc6\u7801\u8fde\u63a5redis\u96c6\u7fa4\n            redisconn = StrictRedisCluster(startup_nodes=self.conn_list, password=\\'123456\\')\n            return redisconn\n        except Exception as e:\n            print(e)\n            print(\\\"\u9519\u8bef,\u8fde\u63a5redis \u96c6\u7fa4\u5931\u8d25\\\")\n            return False\n# \u8fde\u63a5\u5217\u8868\uff0c\u6ce8\u610f\uff1a\u5fc5\u987b\u4e25\u683c\u6309\u7167\u6b64\u683c\u5f0f\u6765\uff01\nredis_basis_conn = [{\\'host\\': \\'192.168.10.168\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.169\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.170\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.171\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.142\\', \\'port\\': 7201}, {\\'host\\': \\'192.168.10.143\\', \\'port\\': 7201}]\nredis_conn = RedisCluster(redis_basis_conn).connect()  # redis\u8fde\u63a5\u5bf9\u8c61\nredis_conn.set(\\'name\\',\\'weijing\\')  # \u63d2\u5165\u4e00\u4e2a\u503c\nprint(\\\"name is: \\\", redis_conn.get(\\'name\\'))  # \u67e5\u8be2\u503c<\/pre>\n<\/div>\n<\/div>\n
\u6267\u884c\u8f93\u51fa\uff1a<\/p>\n
\n
name is:  b\\'weijing\\'<\/pre>\n<\/div>\n<\/div>\n<\/div>\n","protected":false},"excerpt":{"rendered":"
\u4e00\u3001\u8fde\u63a5redis\u96c6\u7fa4 python\u7684redis\u5e93\u662f\u4e0d\u652f\u6301\u96c6\u7fa4\u64cd\u4f5c\u7684\uff0c\u63a8\u8350\u5e93\uff1aredis-py-cluster …<\/p>\n
  python \u8fde\u63a5\u7ba1\u7406\u4f5credis\u96c6\u7fa4<\/span> \u67e5\u770b\u5168\u6587 »<\/a><\/p>\n","protected":false},"author":4,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"site-sidebar-layout":"default","site-content-layout":"default","ast-main-header-display":"","ast-hfb-above-header-display":"","ast-hfb-below-header-display":"","ast-hfb-mobile-header-display":"","site-post-title":"","ast-breadcrumbs-content":"","ast-featured-img":"","footer-sml-layout":"","theme-transparent-header-meta":"enabled","adv-header-id-meta":"","stick-header-meta":"","header-above-stick-meta":"","header-main-stick-meta":"","header-below-stick-meta":""},"categories":[106,126],"tags":[147,148],"uagb_featured_image_src":{"full":false,"thumbnail":false,"medium":false,"medium_large":false,"large":false,"1536x1536":false,"2048x2048":false,"mailpoet_newsletter_max":false,"woocommerce_thumbnail":false,"woocommerce_single":false,"woocommerce_gallery_thumbnail":false,"shop_catalog":false,"shop_single":false,"shop_thumbnail":false},"uagb_author_info":{"display_name":"weijing","author_link":"http:\/\/www.weijing.co\/?author=4"},"uagb_comment_info":0,"uagb_excerpt":"\u4e00\u3001\u8fde\u63a5redis\u96c6\u7fa4 python\u7684redis\u5e93\u662f\u4e0d\u652f\u6301\u96c6\u7fa4\u64cd\u4f5c\u7684\uff0c\u63a8\u8350\u5e93\uff1aredis-py-cluster…","_links":{"self":[{"href":"http:\/\/www.weijing.co\/index.php?rest_route=\/wp\/v2\/posts\/5446"}],"collection":[{"href":"http:\/\/www.weijing.co\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/www.weijing.co\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/www.weijing.co\/index.php?rest_route=\/wp\/v2\/users\/4"}],"replies":[{"embeddable":true,"href":"http:\/\/www.weijing.co\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=5446"}],"version-history":[{"count":0,"href":"http:\/\/www.weijing.co\/index.php?rest_route=\/wp\/v2\/posts\/5446\/revisions"}],"wp:attachment":[{"href":"http:\/\/www.weijing.co\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=5446"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/www.weijing.co\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=5446"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/www.weijing.co\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=5446"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}