Add redis/redis-py@ad4779e

client_list (redis/redis-py#1517)

Signed-off-by: Andrew-Chen-Wang <[email protected]>

Author: Andrew-Chen-Wang

aioredis/client.py

@@ -581,7 +581,7 @@ def parse_client_info(value):
     "key1=value1 key2=value2 key3=value3"
     """
     client_info = {}
-    infos = value.split(" ")
+    infos = str_if_bytes(value).split(" ")
     for info in infos:
         key, value = info.split("=")
         client_info[key] = value
@@ -598,8 +598,10 @@ def parse_client_info(value):
         "qbuf",
         "qbuf-free",
         "obl",
+        "argv-mem",
         "oll",
         "omem",
+        "tot-mem",
     }:
         client_info[int_key] = int(client_info[int_key])
     return client_info
@@ -695,6 +697,7 @@ class Redis:
         "CLIENT ID": int,
         "CLIENT KILL": parse_client_kill,
         "CLIENT LIST": parse_client_list,
+        "CLIENT INFO": parse_client_info,
         "CLIENT SETNAME": bool_ok,
         "CLIENT UNBLOCK": lambda r: r and int(r) == 1 or False,
         "CLIENT PAUSE": bool_ok,
@@ -1391,6 +1394,13 @@ def client_kill_filter(
             )
         return self.execute_command("CLIENT KILL", *args)
 
+    def client_info(self) -> Awaitable:
+        """
+        Returns information and statistics about the current
+        client connection.
+        """
+        return self.execute_command("CLIENT INFO")
+
     def client_list(self, _type: Optional[str] = None) -> Awaitable:
         """
         Returns a list of currently connected clients.

tests/test_commands.py

@@ -345,6 +345,12 @@ async def test_client_list(self, r: aioredis.Redis):
         assert isinstance(clients[0], dict)
         assert "addr" in clients[0]
 
+    @skip_if_server_version_lt("6.2.0")
+    def test_client_info(self, r: aioredis.Redis):
+        info = r.client_info()
+        assert isinstance(info, dict)
+        assert "addr" in info
+
     @skip_if_server_version_lt("5.0.0")
     async def test_client_list_type(self, r: aioredis.Redis):
         with pytest.raises(exceptions.RedisError):